Lines Matching defs:GetEventStreamEventStream
383 type GetEventStreamEventStream struct { struct
391 Reader EventStreamReader
393 outputReader io.ReadCloser
394 output *GetEventStreamOutput
396 done chan struct{}
397 closeOnce sync.Once
398 err *eventstreamapi.OnceError
410 func NewGetEventStreamEventStream(opts ...func(*GetEventStreamEventStream)) *GetEventStreamEventStr…
423 func (es *GetEventStreamEventStream) runOnStreamPartClose(r *request.Request) {
431 func (es *GetEventStreamEventStream) waitStreamPartClose() {
478 func (es *GetEventStreamEventStream) Events() <-chan EventStreamEvent {
482 func (es *GetEventStreamEventStream) runOutputStream(r *request.Request) {
510 func (es *GetEventStreamEventStream) recvInitialEvent(r *request.Request) {
542 func (es *GetEventStreamEventStream) Close() (err error) {
547 func (es *GetEventStreamEventStream) safeClose() {
560 func (es *GetEventStreamEventStream) Err() error {