Lines Matching defs:readEventStream
625 func (r *readEmptyEventStream) readEventStream() { func
746 type readEventStream struct { struct
747 eventReader *eventstreamapi.EventReader
748 stream chan EventStreamEvent
749 err *eventstreamapi.OnceError
751 done chan struct{}
752 closeOnce sync.Once
768 func (r *readEventStream) Close() error {
773 func (r *readEventStream) ErrorSet() <-chan struct{} {
777 func (r *readEventStream) Closed() <-chan struct{} {
781 func (r *readEventStream) safeClose() {
785 func (r *readEventStream) Err() error {
789 func (r *readEventStream) Events() <-chan EventStreamEvent {
793 func (r *readEventStream) readEventStream() { argument