Lines Matching defs:GetEventStreamEventStream

355 type GetEventStreamEventStream struct {  struct
363 	Reader EventStreamReader
365 	outputReader io.ReadCloser
366 	output       *GetEventStreamOutput
368 	done      chan struct{}
369 	closeOnce sync.Once
370 	err       *eventstreamapi.OnceError
380 func (es *GetEventStreamEventStream) runOnStreamPartClose(r *request.Request) {
388 func (es *GetEventStreamEventStream) waitStreamPartClose() {
434 func (es *GetEventStreamEventStream) Events() <-chan EventStreamEvent {
438 func (es *GetEventStreamEventStream) runOutputStream(r *request.Request) {
466 func (es *GetEventStreamEventStream) recvInitialEvent(r *request.Request) {
498 func (es *GetEventStreamEventStream) Close() (err error) {
503 func (es *GetEventStreamEventStream) safeClose() {
516 func (es *GetEventStreamEventStream) Err() error {