Lines Matching defs:readEventStream
672 func (r *readEmptyEventStream) readEventStream() { func
822 type readEventStream struct { struct
823 eventReader *eventstreamapi.EventReader
824 stream chan EventStreamEvent
825 err *eventstreamapi.OnceError
827 done chan struct{}
828 closeOnce sync.Once
844 func (r *readEventStream) Close() error {
849 func (r *readEventStream) ErrorSet() <-chan struct{} {
853 func (r *readEventStream) Closed() <-chan struct{} {
857 func (r *readEventStream) safeClose() {
861 func (r *readEventStream) Err() error {
865 func (r *readEventStream) Events() <-chan EventStreamEvent {
869 func (r *readEventStream) readEventStream() { func