Method IsStreaming

intercept/eventstream/eventstream.go:204–206

IsStreaming checks if the stream has been initiated, or when events are buffered which - when processed - will initiate the stream.

()

// IsStreaming checks if the stream has been initiated, or
// when events are buffered which - when processed - will initiate the stream.
func (s *EventStream) IsStreaming() bool {
	return s.initiated.Load() || len(s.eventsCh) > 0
}

// IsConnError checks if an error is related to client disconnection or context cancellation.
func IsConnError(err error) bool {