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() {  argument