From 93bba0ba25d0412be95298cfc9cc6de131bd3ad7 Mon Sep 17 00:00:00 2001 From: Sean McGrail Date: Wed, 23 Mar 2022 00:06:12 +0000 Subject: [PATCH] Regnerated Clients --- service/kinesis/eventstream.go | 24 +++---- service/lexruntimev2/eventstream.go | 54 +++++++-------- service/s3/eventstream.go | 24 +++---- service/transcribestreaming/eventstream.go | 80 +++++++++++----------- 4 files changed, 91 insertions(+), 91 deletions(-) diff --git a/service/kinesis/eventstream.go b/service/kinesis/eventstream.go index 73b053e7f06..c044348a4f0 100644 --- a/service/kinesis/eventstream.go +++ b/service/kinesis/eventstream.go @@ -45,7 +45,7 @@ type subscribeToShardEventStreamReadEventInitialResponse struct { func (*subscribeToShardEventStreamReadEventInitialResponse) isSubscribeToShardEventStreamReadEvent() { } -type subscribeToShardEventStream struct { +type subscribeToShardEventStreamReader struct { stream chan types.SubscribeToShardEventStream decoder *eventstream.Decoder eventStream io.ReadCloser @@ -57,8 +57,8 @@ type subscribeToShardEventStream struct { initialResponse chan interface{} } -func newSubscribeToShardEventStream(readCloser io.ReadCloser, decoder *eventstream.Decoder, ird func(*eventstream.Message) (interface{}, error)) *subscribeToShardEventStream { - w := &subscribeToShardEventStream{ +func newSubscribeToShardEventStreamWriter(readCloser io.ReadCloser, decoder *eventstream.Decoder, ird func(*eventstream.Message) (interface{}, error)) *subscribeToShardEventStreamReader { + w := &subscribeToShardEventStreamReader{ stream: make(chan types.SubscribeToShardEventStream), decoder: decoder, eventStream: readCloser, @@ -74,11 +74,11 @@ func newSubscribeToShardEventStream(readCloser io.ReadCloser, decoder *eventstre return w } -func (r *subscribeToShardEventStream) Events() <-chan types.SubscribeToShardEventStream { +func (r *subscribeToShardEventStreamReader) Events() <-chan types.SubscribeToShardEventStream { return r.stream } -func (r *subscribeToShardEventStream) readEventStream() { +func (r *subscribeToShardEventStreamReader) readEventStream() { defer r.Close() defer close(r.stream) @@ -128,7 +128,7 @@ func (r *subscribeToShardEventStream) readEventStream() { } } -func (r *subscribeToShardEventStream) deserializeEventMessage(msg *eventstream.Message) (subscribeToShardEventStreamReadEvent, error) { +func (r *subscribeToShardEventStreamReader) deserializeEventMessage(msg *eventstream.Message) (subscribeToShardEventStreamReadEvent, error) { messageType := msg.Headers.Get(eventstreamapi.MessageTypeHeader) if messageType == nil { return nil, fmt.Errorf("%s event header not present", eventstreamapi.MessageTypeHeader) @@ -182,26 +182,26 @@ func (r *subscribeToShardEventStream) deserializeEventMessage(msg *eventstream.M } } -func (r *subscribeToShardEventStream) ErrorSet() <-chan struct{} { +func (r *subscribeToShardEventStreamReader) ErrorSet() <-chan struct{} { return r.err.ErrorSet() } -func (r *subscribeToShardEventStream) Close() error { +func (r *subscribeToShardEventStreamReader) Close() error { r.closeOnce.Do(r.safeClose) return r.Err() } -func (r *subscribeToShardEventStream) safeClose() { +func (r *subscribeToShardEventStreamReader) safeClose() { close(r.done) r.eventStream.Close() } -func (r *subscribeToShardEventStream) Err() error { +func (r *subscribeToShardEventStreamReader) Err() error { return r.err.Err() } -func (r *subscribeToShardEventStream) Closed() <-chan struct{} { +func (r *subscribeToShardEventStreamReader) Closed() <-chan struct{} { return r.done } @@ -251,7 +251,7 @@ func (m *awsAwsjson11_deserializeOpEventStreamSubscribeToShard) HandleDeserializ out.Result = output } - eventReader := newSubscribeToShardEventStream( + eventReader := newSubscribeToShardEventStreamWriter( deserializeOutput.Body, eventstream.NewDecoder(func(options *eventstream.DecoderOptions) { options.Logger = logger diff --git a/service/lexruntimev2/eventstream.go b/service/lexruntimev2/eventstream.go index 6d9509501bb..bec14364018 100644 --- a/service/lexruntimev2/eventstream.go +++ b/service/lexruntimev2/eventstream.go @@ -62,7 +62,7 @@ func (e asyncStartConversationRequestEventStream) ReportResult(cancel <-chan str } } -type startConversationRequestEventStream struct { +type startConversationRequestEventStreamWriter struct { encoder *eventstream.Encoder signer eventStreamSigner stream chan asyncStartConversationRequestEventStream @@ -74,8 +74,8 @@ type startConversationRequestEventStream struct { err *smithysync.OnceErr } -func newStartConversationRequestEventStream(stream io.WriteCloser, encoder *eventstream.Encoder, signer eventStreamSigner) *startConversationRequestEventStream { - w := &startConversationRequestEventStream{ +func newStartConversationRequestEventStreamReader(stream io.WriteCloser, encoder *eventstream.Encoder, signer eventStreamSigner) *startConversationRequestEventStreamWriter { + w := &startConversationRequestEventStreamWriter{ encoder: encoder, signer: signer, stream: make(chan asyncStartConversationRequestEventStream), @@ -92,11 +92,11 @@ func newStartConversationRequestEventStream(stream io.WriteCloser, encoder *even } -func (w *startConversationRequestEventStream) Send(ctx context.Context, event types.StartConversationRequestEventStream) error { +func (w *startConversationRequestEventStreamWriter) Send(ctx context.Context, event types.StartConversationRequestEventStream) error { return w.send(ctx, event) } -func (w *startConversationRequestEventStream) send(ctx context.Context, event types.StartConversationRequestEventStream) error { +func (w *startConversationRequestEventStreamWriter) send(ctx context.Context, event types.StartConversationRequestEventStream) error { if err := w.err.Err(); err != nil { return err } @@ -129,7 +129,7 @@ func (w *startConversationRequestEventStream) send(ctx context.Context, event ty } -func (w *startConversationRequestEventStream) writeStream() { +func (w *startConversationRequestEventStreamWriter) writeStream() { defer w.Close() for { @@ -152,7 +152,7 @@ func (w *startConversationRequestEventStream) writeStream() { } } -func (w *startConversationRequestEventStream) writeEvent(event types.StartConversationRequestEventStream) error { +func (w *startConversationRequestEventStreamWriter) writeEvent(event types.StartConversationRequestEventStream) error { // serializedEvent returned bytes refers to an underlying byte buffer and must not // escape this writeEvent scope without first copying. Any previous bytes stored in // the buffer are cleared by this call. @@ -174,7 +174,7 @@ func (w *startConversationRequestEventStream) writeEvent(event types.StartConver return err } -func (w *startConversationRequestEventStream) serializeEvent(event types.StartConversationRequestEventStream) ([]byte, error) { +func (w *startConversationRequestEventStreamWriter) serializeEvent(event types.StartConversationRequestEventStream) ([]byte, error) { w.serializationBuffer.Reset() eventMessage := eventstream.Message{} @@ -190,7 +190,7 @@ func (w *startConversationRequestEventStream) serializeEvent(event types.StartCo return w.serializationBuffer.Bytes(), nil } -func (w *startConversationRequestEventStream) signEvent(payload []byte) ([]byte, error) { +func (w *startConversationRequestEventStreamWriter) signEvent(payload []byte) ([]byte, error) { w.signingBuffer.Reset() date := time.Now().UTC() @@ -218,7 +218,7 @@ func (w *startConversationRequestEventStream) signEvent(payload []byte) ([]byte, return w.signingBuffer.Bytes(), nil } -func (w *startConversationRequestEventStream) closeStream() (err error) { +func (w *startConversationRequestEventStreamWriter) closeStream() (err error) { defer func() { if cErr := w.eventStream.Close(); cErr != nil && err == nil { err = cErr @@ -236,24 +236,24 @@ func (w *startConversationRequestEventStream) closeStream() (err error) { return err } -func (w *startConversationRequestEventStream) ErrorSet() <-chan struct{} { +func (w *startConversationRequestEventStreamWriter) ErrorSet() <-chan struct{} { return w.err.ErrorSet() } -func (w *startConversationRequestEventStream) Close() error { +func (w *startConversationRequestEventStreamWriter) Close() error { w.closeOnce.Do(w.safeClose) return w.Err() } -func (w *startConversationRequestEventStream) safeClose() { +func (w *startConversationRequestEventStreamWriter) safeClose() { close(w.done) } -func (w *startConversationRequestEventStream) Err() error { +func (w *startConversationRequestEventStreamWriter) Err() error { return w.err.Err() } -type startConversationResponseEventStream struct { +type startConversationResponseEventStreamReader struct { stream chan types.StartConversationResponseEventStream decoder *eventstream.Decoder eventStream io.ReadCloser @@ -263,8 +263,8 @@ type startConversationResponseEventStream struct { closeOnce sync.Once } -func newStartConversationResponseEventStream(readCloser io.ReadCloser, decoder *eventstream.Decoder) *startConversationResponseEventStream { - w := &startConversationResponseEventStream{ +func newStartConversationResponseEventStreamWriter(readCloser io.ReadCloser, decoder *eventstream.Decoder) *startConversationResponseEventStreamReader { + w := &startConversationResponseEventStreamReader{ stream: make(chan types.StartConversationResponseEventStream), decoder: decoder, eventStream: readCloser, @@ -278,11 +278,11 @@ func newStartConversationResponseEventStream(readCloser io.ReadCloser, decoder * return w } -func (r *startConversationResponseEventStream) Events() <-chan types.StartConversationResponseEventStream { +func (r *startConversationResponseEventStreamReader) Events() <-chan types.StartConversationResponseEventStream { return r.stream } -func (r *startConversationResponseEventStream) readEventStream() { +func (r *startConversationResponseEventStreamReader) readEventStream() { defer r.Close() defer close(r.stream) @@ -317,7 +317,7 @@ func (r *startConversationResponseEventStream) readEventStream() { } } -func (r *startConversationResponseEventStream) deserializeEventMessage(msg *eventstream.Message) (types.StartConversationResponseEventStream, error) { +func (r *startConversationResponseEventStreamReader) deserializeEventMessage(msg *eventstream.Message) (types.StartConversationResponseEventStream, error) { messageType := msg.Headers.Get(eventstreamapi.MessageTypeHeader) if messageType == nil { return nil, fmt.Errorf("%s event header not present", eventstreamapi.MessageTypeHeader) @@ -358,26 +358,26 @@ func (r *startConversationResponseEventStream) deserializeEventMessage(msg *even } } -func (r *startConversationResponseEventStream) ErrorSet() <-chan struct{} { +func (r *startConversationResponseEventStreamReader) ErrorSet() <-chan struct{} { return r.err.ErrorSet() } -func (r *startConversationResponseEventStream) Close() error { +func (r *startConversationResponseEventStreamReader) Close() error { r.closeOnce.Do(r.safeClose) return r.Err() } -func (r *startConversationResponseEventStream) safeClose() { +func (r *startConversationResponseEventStreamReader) safeClose() { close(r.done) r.eventStream.Close() } -func (r *startConversationResponseEventStream) Err() error { +func (r *startConversationResponseEventStreamReader) Err() error { return r.err.Err() } -func (r *startConversationResponseEventStream) Closed() <-chan struct{} { +func (r *startConversationResponseEventStreamReader) Closed() <-chan struct{} { return r.done } @@ -424,7 +424,7 @@ func (m *awsRestjson1_deserializeOpEventStreamStartConversation) HandleDeseriali requestSignature, ) - eventWriter := newStartConversationRequestEventStream( + eventWriter := newStartConversationRequestEventStreamReader( eventstreamapi.GetInputStreamWriter(ctx), eventstream.NewEncoder(func(options *eventstream.EncoderOptions) { options.Logger = logger @@ -459,7 +459,7 @@ func (m *awsRestjson1_deserializeOpEventStreamStartConversation) HandleDeseriali out.Result = output } - eventReader := newStartConversationResponseEventStream( + eventReader := newStartConversationResponseEventStreamWriter( deserializeOutput.Body, eventstream.NewDecoder(func(options *eventstream.DecoderOptions) { options.Logger = logger diff --git a/service/s3/eventstream.go b/service/s3/eventstream.go index 38d579a3a4f..0e267c92730 100644 --- a/service/s3/eventstream.go +++ b/service/s3/eventstream.go @@ -28,7 +28,7 @@ type SelectObjectContentEventStreamReader interface { Err() error } -type selectObjectContentEventStream struct { +type selectObjectContentEventStreamReader struct { stream chan types.SelectObjectContentEventStream decoder *eventstream.Decoder eventStream io.ReadCloser @@ -38,8 +38,8 @@ type selectObjectContentEventStream struct { closeOnce sync.Once } -func newSelectObjectContentEventStream(readCloser io.ReadCloser, decoder *eventstream.Decoder) *selectObjectContentEventStream { - w := &selectObjectContentEventStream{ +func newSelectObjectContentEventStreamWriter(readCloser io.ReadCloser, decoder *eventstream.Decoder) *selectObjectContentEventStreamReader { + w := &selectObjectContentEventStreamReader{ stream: make(chan types.SelectObjectContentEventStream), decoder: decoder, eventStream: readCloser, @@ -53,11 +53,11 @@ func newSelectObjectContentEventStream(readCloser io.ReadCloser, decoder *events return w } -func (r *selectObjectContentEventStream) Events() <-chan types.SelectObjectContentEventStream { +func (r *selectObjectContentEventStreamReader) Events() <-chan types.SelectObjectContentEventStream { return r.stream } -func (r *selectObjectContentEventStream) readEventStream() { +func (r *selectObjectContentEventStreamReader) readEventStream() { defer r.Close() defer close(r.stream) @@ -92,7 +92,7 @@ func (r *selectObjectContentEventStream) readEventStream() { } } -func (r *selectObjectContentEventStream) deserializeEventMessage(msg *eventstream.Message) (types.SelectObjectContentEventStream, error) { +func (r *selectObjectContentEventStreamReader) deserializeEventMessage(msg *eventstream.Message) (types.SelectObjectContentEventStream, error) { messageType := msg.Headers.Get(eventstreamapi.MessageTypeHeader) if messageType == nil { return nil, fmt.Errorf("%s event header not present", eventstreamapi.MessageTypeHeader) @@ -133,26 +133,26 @@ func (r *selectObjectContentEventStream) deserializeEventMessage(msg *eventstrea } } -func (r *selectObjectContentEventStream) ErrorSet() <-chan struct{} { +func (r *selectObjectContentEventStreamReader) ErrorSet() <-chan struct{} { return r.err.ErrorSet() } -func (r *selectObjectContentEventStream) Close() error { +func (r *selectObjectContentEventStreamReader) Close() error { r.closeOnce.Do(r.safeClose) return r.Err() } -func (r *selectObjectContentEventStream) safeClose() { +func (r *selectObjectContentEventStreamReader) safeClose() { close(r.done) r.eventStream.Close() } -func (r *selectObjectContentEventStream) Err() error { +func (r *selectObjectContentEventStreamReader) Err() error { return r.err.Err() } -func (r *selectObjectContentEventStream) Closed() <-chan struct{} { +func (r *selectObjectContentEventStreamReader) Closed() <-chan struct{} { return r.done } @@ -202,7 +202,7 @@ func (m *awsRestxml_deserializeOpEventStreamSelectObjectContent) HandleDeseriali out.Result = output } - eventReader := newSelectObjectContentEventStream( + eventReader := newSelectObjectContentEventStreamWriter( deserializeOutput.Body, eventstream.NewDecoder(func(options *eventstream.DecoderOptions) { options.Logger = logger diff --git a/service/transcribestreaming/eventstream.go b/service/transcribestreaming/eventstream.go index f33c4a7fdd1..b6814886e25 100644 --- a/service/transcribestreaming/eventstream.go +++ b/service/transcribestreaming/eventstream.go @@ -71,7 +71,7 @@ func (e asyncAudioStream) ReportResult(cancel <-chan struct{}, err error) bool { } } -type audioStream struct { +type audioStreamWriter struct { encoder *eventstream.Encoder signer eventStreamSigner stream chan asyncAudioStream @@ -83,8 +83,8 @@ type audioStream struct { err *smithysync.OnceErr } -func newAudioStream(stream io.WriteCloser, encoder *eventstream.Encoder, signer eventStreamSigner) *audioStream { - w := &audioStream{ +func newAudioStreamReader(stream io.WriteCloser, encoder *eventstream.Encoder, signer eventStreamSigner) *audioStreamWriter { + w := &audioStreamWriter{ encoder: encoder, signer: signer, stream: make(chan asyncAudioStream), @@ -101,11 +101,11 @@ func newAudioStream(stream io.WriteCloser, encoder *eventstream.Encoder, signer } -func (w *audioStream) Send(ctx context.Context, event types.AudioStream) error { +func (w *audioStreamWriter) Send(ctx context.Context, event types.AudioStream) error { return w.send(ctx, event) } -func (w *audioStream) send(ctx context.Context, event types.AudioStream) error { +func (w *audioStreamWriter) send(ctx context.Context, event types.AudioStream) error { if err := w.err.Err(); err != nil { return err } @@ -138,7 +138,7 @@ func (w *audioStream) send(ctx context.Context, event types.AudioStream) error { } -func (w *audioStream) writeStream() { +func (w *audioStreamWriter) writeStream() { defer w.Close() for { @@ -161,7 +161,7 @@ func (w *audioStream) writeStream() { } } -func (w *audioStream) writeEvent(event types.AudioStream) error { +func (w *audioStreamWriter) writeEvent(event types.AudioStream) error { // serializedEvent returned bytes refers to an underlying byte buffer and must not // escape this writeEvent scope without first copying. Any previous bytes stored in // the buffer are cleared by this call. @@ -183,7 +183,7 @@ func (w *audioStream) writeEvent(event types.AudioStream) error { return err } -func (w *audioStream) serializeEvent(event types.AudioStream) ([]byte, error) { +func (w *audioStreamWriter) serializeEvent(event types.AudioStream) ([]byte, error) { w.serializationBuffer.Reset() eventMessage := eventstream.Message{} @@ -199,7 +199,7 @@ func (w *audioStream) serializeEvent(event types.AudioStream) ([]byte, error) { return w.serializationBuffer.Bytes(), nil } -func (w *audioStream) signEvent(payload []byte) ([]byte, error) { +func (w *audioStreamWriter) signEvent(payload []byte) ([]byte, error) { w.signingBuffer.Reset() date := time.Now().UTC() @@ -227,7 +227,7 @@ func (w *audioStream) signEvent(payload []byte) ([]byte, error) { return w.signingBuffer.Bytes(), nil } -func (w *audioStream) closeStream() (err error) { +func (w *audioStreamWriter) closeStream() (err error) { defer func() { if cErr := w.eventStream.Close(); cErr != nil && err == nil { err = cErr @@ -245,24 +245,24 @@ func (w *audioStream) closeStream() (err error) { return err } -func (w *audioStream) ErrorSet() <-chan struct{} { +func (w *audioStreamWriter) ErrorSet() <-chan struct{} { return w.err.ErrorSet() } -func (w *audioStream) Close() error { +func (w *audioStreamWriter) Close() error { w.closeOnce.Do(w.safeClose) return w.Err() } -func (w *audioStream) safeClose() { +func (w *audioStreamWriter) safeClose() { close(w.done) } -func (w *audioStream) Err() error { +func (w *audioStreamWriter) Err() error { return w.err.Err() } -type medicalTranscriptResultStream struct { +type medicalTranscriptResultStreamReader struct { stream chan types.MedicalTranscriptResultStream decoder *eventstream.Decoder eventStream io.ReadCloser @@ -272,8 +272,8 @@ type medicalTranscriptResultStream struct { closeOnce sync.Once } -func newMedicalTranscriptResultStream(readCloser io.ReadCloser, decoder *eventstream.Decoder) *medicalTranscriptResultStream { - w := &medicalTranscriptResultStream{ +func newMedicalTranscriptResultStreamWriter(readCloser io.ReadCloser, decoder *eventstream.Decoder) *medicalTranscriptResultStreamReader { + w := &medicalTranscriptResultStreamReader{ stream: make(chan types.MedicalTranscriptResultStream), decoder: decoder, eventStream: readCloser, @@ -287,11 +287,11 @@ func newMedicalTranscriptResultStream(readCloser io.ReadCloser, decoder *eventst return w } -func (r *medicalTranscriptResultStream) Events() <-chan types.MedicalTranscriptResultStream { +func (r *medicalTranscriptResultStreamReader) Events() <-chan types.MedicalTranscriptResultStream { return r.stream } -func (r *medicalTranscriptResultStream) readEventStream() { +func (r *medicalTranscriptResultStreamReader) readEventStream() { defer r.Close() defer close(r.stream) @@ -326,7 +326,7 @@ func (r *medicalTranscriptResultStream) readEventStream() { } } -func (r *medicalTranscriptResultStream) deserializeEventMessage(msg *eventstream.Message) (types.MedicalTranscriptResultStream, error) { +func (r *medicalTranscriptResultStreamReader) deserializeEventMessage(msg *eventstream.Message) (types.MedicalTranscriptResultStream, error) { messageType := msg.Headers.Get(eventstreamapi.MessageTypeHeader) if messageType == nil { return nil, fmt.Errorf("%s event header not present", eventstreamapi.MessageTypeHeader) @@ -367,30 +367,30 @@ func (r *medicalTranscriptResultStream) deserializeEventMessage(msg *eventstream } } -func (r *medicalTranscriptResultStream) ErrorSet() <-chan struct{} { +func (r *medicalTranscriptResultStreamReader) ErrorSet() <-chan struct{} { return r.err.ErrorSet() } -func (r *medicalTranscriptResultStream) Close() error { +func (r *medicalTranscriptResultStreamReader) Close() error { r.closeOnce.Do(r.safeClose) return r.Err() } -func (r *medicalTranscriptResultStream) safeClose() { +func (r *medicalTranscriptResultStreamReader) safeClose() { close(r.done) r.eventStream.Close() } -func (r *medicalTranscriptResultStream) Err() error { +func (r *medicalTranscriptResultStreamReader) Err() error { return r.err.Err() } -func (r *medicalTranscriptResultStream) Closed() <-chan struct{} { +func (r *medicalTranscriptResultStreamReader) Closed() <-chan struct{} { return r.done } -type transcriptResultStream struct { +type transcriptResultStreamReader struct { stream chan types.TranscriptResultStream decoder *eventstream.Decoder eventStream io.ReadCloser @@ -400,8 +400,8 @@ type transcriptResultStream struct { closeOnce sync.Once } -func newTranscriptResultStream(readCloser io.ReadCloser, decoder *eventstream.Decoder) *transcriptResultStream { - w := &transcriptResultStream{ +func newTranscriptResultStreamWriter(readCloser io.ReadCloser, decoder *eventstream.Decoder) *transcriptResultStreamReader { + w := &transcriptResultStreamReader{ stream: make(chan types.TranscriptResultStream), decoder: decoder, eventStream: readCloser, @@ -415,11 +415,11 @@ func newTranscriptResultStream(readCloser io.ReadCloser, decoder *eventstream.De return w } -func (r *transcriptResultStream) Events() <-chan types.TranscriptResultStream { +func (r *transcriptResultStreamReader) Events() <-chan types.TranscriptResultStream { return r.stream } -func (r *transcriptResultStream) readEventStream() { +func (r *transcriptResultStreamReader) readEventStream() { defer r.Close() defer close(r.stream) @@ -454,7 +454,7 @@ func (r *transcriptResultStream) readEventStream() { } } -func (r *transcriptResultStream) deserializeEventMessage(msg *eventstream.Message) (types.TranscriptResultStream, error) { +func (r *transcriptResultStreamReader) deserializeEventMessage(msg *eventstream.Message) (types.TranscriptResultStream, error) { messageType := msg.Headers.Get(eventstreamapi.MessageTypeHeader) if messageType == nil { return nil, fmt.Errorf("%s event header not present", eventstreamapi.MessageTypeHeader) @@ -495,26 +495,26 @@ func (r *transcriptResultStream) deserializeEventMessage(msg *eventstream.Messag } } -func (r *transcriptResultStream) ErrorSet() <-chan struct{} { +func (r *transcriptResultStreamReader) ErrorSet() <-chan struct{} { return r.err.ErrorSet() } -func (r *transcriptResultStream) Close() error { +func (r *transcriptResultStreamReader) Close() error { r.closeOnce.Do(r.safeClose) return r.Err() } -func (r *transcriptResultStream) safeClose() { +func (r *transcriptResultStreamReader) safeClose() { close(r.done) r.eventStream.Close() } -func (r *transcriptResultStream) Err() error { +func (r *transcriptResultStreamReader) Err() error { return r.err.Err() } -func (r *transcriptResultStream) Closed() <-chan struct{} { +func (r *transcriptResultStreamReader) Closed() <-chan struct{} { return r.done } @@ -561,7 +561,7 @@ func (m *awsRestjson1_deserializeOpEventStreamStartMedicalStreamTranscription) H requestSignature, ) - eventWriter := newAudioStream( + eventWriter := newAudioStreamReader( eventstreamapi.GetInputStreamWriter(ctx), eventstream.NewEncoder(func(options *eventstream.EncoderOptions) { options.Logger = logger @@ -596,7 +596,7 @@ func (m *awsRestjson1_deserializeOpEventStreamStartMedicalStreamTranscription) H out.Result = output } - eventReader := newMedicalTranscriptResultStream( + eventReader := newMedicalTranscriptResultStreamWriter( deserializeOutput.Body, eventstream.NewDecoder(func(options *eventstream.DecoderOptions) { options.Logger = logger @@ -678,7 +678,7 @@ func (m *awsRestjson1_deserializeOpEventStreamStartStreamTranscription) HandleDe requestSignature, ) - eventWriter := newAudioStream( + eventWriter := newAudioStreamReader( eventstreamapi.GetInputStreamWriter(ctx), eventstream.NewEncoder(func(options *eventstream.EncoderOptions) { options.Logger = logger @@ -713,7 +713,7 @@ func (m *awsRestjson1_deserializeOpEventStreamStartStreamTranscription) HandleDe out.Result = output } - eventReader := newTranscriptResultStream( + eventReader := newTranscriptResultStreamWriter( deserializeOutput.Body, eventstream.NewDecoder(func(options *eventstream.DecoderOptions) { options.Logger = logger