Lines Matching refs:EmptyStreamEventStream
111 type EmptyStreamEventStream struct { struct
137 func NewEmptyStreamEventStream(opts ...func(*EmptyStreamEventStream)) *EmptyStreamEventStream { argument
138 es := &EmptyStreamEventStream{
150 func (es *EmptyStreamEventStream) runOnStreamPartClose(r *request.Request) { argument
158 func (es *EmptyStreamEventStream) waitStreamPartClose() { argument
186 func (es *EmptyStreamEventStream) Events() <-chan EmptyEventStreamEvent { argument
190 func (es *EmptyStreamEventStream) runOutputStream(r *request.Request) { argument
222 func (es *EmptyStreamEventStream) Close() (err error) { argument
227 func (es *EmptyStreamEventStream) safeClose() { argument
240 func (es *EmptyStreamEventStream) Err() error { argument
760 eventStream *EmptyStreamEventStream
774 func (s *EmptyStreamOutput) GetStream() *EmptyStreamEventStream {