AWS SDK

rev. 24b01eb5db276bb003a50c3217d5e7030eff55ff

Files changed:

tmp-codegen-diff/aws-sdk/sdk/aws-smithy-http/src/event_stream/receiver.rs

@@ -1,1 +39,39 @@

 /*
  * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
  * SPDX-License-Identifier: Apache-2.0
  */
-5
 use aws_smithy_eventstream::frame::{
     DecodedFrame, MessageFrameDecoder, UnmarshallMessage, UnmarshalledMessage,
 };
 use aws_smithy_runtime_api::client::result::{ConnectorError, ResponseError, SdkError};
 use aws_smithy_runtime_api::client::result::{ConnectorError, SdkError};
 use aws_smithy_types::body::SdkBody;
 use aws_smithy_types::event_stream::{Message, RawMessage};
 use bytes::Buf;
 use bytes::Bytes;
 use bytes_utils::SegmentedBuf;
 use std::error::Error as StdError;
 use std::fmt;
 use std::marker::PhantomData;
 use std::mem;
 use tracing::trace;

↧ Expand context

-20
 /// Wrapper around SegmentedBuf that tracks the state of the stream.
 #[derive(Debug)]
 enum RecvBuf {
     /// Nothing has been buffered yet.
     Empty,
     /// Some data has been buffered.
     /// The SegmentedBuf will automatically purge when it reads off the end of a chunk boundary.
     Partial(SegmentedBuf<Bytes>),
     /// The end of the stream has been reached, but there may still be some buffered data.
     EosPartial(SegmentedBuf<Bytes>),
     /// An exception terminated this stream.
     Terminated,
-33
+}
-34
 impl RecvBuf {
     /// Returns true if there's more buffered data.
     fn has_data(&self) -> bool {
         match self {
             RecvBuf::Empty | RecvBuf::Terminated => false,

@@ -202,202 +300,277 @@

↥ Expand context

-202
+                        )
                     })?
-204
+                {
                     trace!(message = ?message, "received complete event stream message");
                     return Ok(Some(message));
-207
+                }
-208
+            }
-209
             self.buffer_next_chunk().await?;
-211
+        }
         if self.buffer.has_data() {
             trace!(remaining_data = ?self.buffer, "data left over in the event stream response stream");
             let buf = self.buffer.buffered();
             return Err(SdkError::response_error(
                 ReceiverError {
                     kind: ReceiverErrorKind::UnexpectedEndOfStream,
                 },
                 RawMessage::invalid(Some(buf.copy_to_bytes(buf.remaining()))),
             ));
-221
+        }

         Ok(None)
-223
+    }
-224
     /// Tries to receive the initial response message that has `:event-type` of a given `message_type`.
     /// If a different event type is received, then it is buffered and `Ok(None)` is returned.
     #[doc(hidden)]
     pub async fn try_recv_initial(
         &mut self,
         message_type: InitialMessageType,
     ) -> Result<Option<Message>, SdkError<E, RawMessage>> {
         self.try_recv_initial_with_preprocessor(message_type, |msg| Ok((msg, ())))
             .await
             .map(|opt| opt.map(|(msg, _)| msg))
--
+    }
--
     /// Tries to receive the initial response message with preprocessing support.
     ///
     /// The preprocessor function can transform the raw message (e.g., unwrap envelopes)
     /// and return metadata alongside the transformed message. If the transformed message
     /// matches the expected `message_type`, both the message and metadata are returned.
     /// Otherwise, the transformed message is buffered and `Ok(None)` is returned.
     #[doc(hidden)]
     pub async fn try_recv_initial_with_preprocessor<F, M>(
         &mut self,
         message_type: InitialMessageType,
         preprocessor: F,
     ) -> Result<Option<(Message, M)>, SdkError<E, RawMessage>>
     where
         F: FnOnce(Message) -> Result<(Message, M), ResponseError<RawMessage>>,
--
+    {
         if let Some(message) = self.next_message().await? {
             let (processed_message, metadata) =
                 preprocessor(message.clone()).map_err(|err| SdkError::ResponseError(err))?;
--
             if let Some(event_type) = processed_message
             if let Some(event_type) = message
                 .headers()
                 .iter()
                 .find(|h| h.name().as_str() == ":event-type")
-237
+            {
                 if event_type
                     .value()
                     .as_string()
                     .map(|s| s.as_str() == message_type.as_str())
                     .unwrap_or(false)
-243
+                {
                     return Ok(Some((processed_message, metadata)));
                     return Ok(Some(message));
-245
+                }
-246
+            }
             // Buffer the processed message so that it can be returned by the next call to `recv()`
             // Buffer the message so that it can be returned by the next call to `recv()`
             self.buffered_message = Some(message);
-249
+        }
         Ok(None)
-251
+    }
-252
     /// Asynchronously tries to receive a message from the stream. If the stream has ended,
     /// it returns an `Ok(None)`. If there is a transport layer error, it will return
     /// `Err(SdkError::DispatchFailure)`. Service-modeled errors will be a part of the returned
     /// messages.
     pub async fn recv(&mut self) -> Result<Option<T>, SdkError<E, RawMessage>> {

↧ Expand context

         if let Some(buffered) = self.buffered_message.take() {
             return match self.unmarshall(buffered) {
                 Ok(message) => Ok(message),
                 Err(error) => {
                     self.buffer = RecvBuf::Terminated;
                     Err(error)
-264
+                }
             };
-266
+        }
         if let Some(message) = self.next_message().await? {
             match self.unmarshall(message) {
                 Ok(message) => Ok(message),
                 Err(error) => {
                     self.buffer = RecvBuf::Terminated;
                     Err(error)
-273
+                }
-274
+            }
         } else {
             Ok(None)
-277
+        }

tmp-codegen-diff/aws-sdk/sdk/bedrockruntime/src/protocol_serde/shape_converse_stream_output.rs

@@ -1,1 +12,14 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub fn de_stream_payload(
     body: &mut ::aws_smithy_types::body::SdkBody,
 ) -> std::result::Result<
     crate::event_receiver::EventReceiver<crate::types::ConverseStreamOutput, crate::types::error::ConverseStreamOutputError>,
     crate::operation::converse_stream::ConverseStreamError,
 > {
     let unmarshaller = crate::event_stream_serde::ConverseStreamOutputUnmarshaller::new();
     let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
     let receiver = crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(unmarshaller, body));
     Ok(receiver)
     Ok(crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(
         unmarshaller,
         body,
     )))
-14
+}

tmp-codegen-diff/aws-sdk/sdk/bedrockruntime/src/protocol_serde/shape_invoke_model_with_bidirectional_stream_output.rs

@@ -1,1 +15,17 @@

↥ Expand context

     body: &mut ::aws_smithy_types::body::SdkBody,
 ) -> std::result::Result<
     crate::event_receiver::EventReceiver<
         crate::types::InvokeModelWithBidirectionalStreamOutput,
         crate::types::error::InvokeModelWithBidirectionalStreamOutputError,
     >,
     crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError,
 > {
     let unmarshaller = crate::event_stream_serde::InvokeModelWithBidirectionalStreamOutputUnmarshaller::new();
     let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
     let receiver = crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(unmarshaller, body));
     Ok(receiver)
     Ok(crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(
         unmarshaller,
         body,
     )))
-17
+}

tmp-codegen-diff/aws-sdk/sdk/bedrockruntime/src/protocol_serde/shape_invoke_model_with_response_stream_output.rs

@@ -1,1 +26,28 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub fn de_body_payload(
     body: &mut ::aws_smithy_types::body::SdkBody,
 ) -> std::result::Result<
     crate::event_receiver::EventReceiver<crate::types::ResponseStream, crate::types::error::ResponseStreamError>,
     crate::operation::invoke_model_with_response_stream::InvokeModelWithResponseStreamError,
 > {
     let unmarshaller = crate::event_stream_serde::ResponseStreamUnmarshaller::new();
     let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
     let receiver = crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(unmarshaller, body));
     Ok(receiver)
     Ok(crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(
         unmarshaller,
         body,
     )))
-14
+}
-15
 pub(crate) fn de_content_type_header(
     header_map: &::aws_smithy_runtime_api::http::Headers,
 ) -> ::std::result::Result<::std::option::Option<::std::string::String>, ::aws_smithy_http::header::ParseError> {
     let headers = header_map.get_all("X-Amzn-Bedrock-Content-Type");
     ::aws_smithy_http::header::one_or_none(headers)
-21
+}
-22
 pub(crate) fn de_performance_config_latency_header(

↧ Expand context

     header_map: &::aws_smithy_runtime_api::http::Headers,
 ) -> ::std::result::Result<::std::option::Option<crate::types::PerformanceConfigLatency>, ::aws_smithy_http::header::ParseError> {
     let headers = header_map.get_all("X-Amzn-Bedrock-PerformanceConfig-Latency");
     ::aws_smithy_http::header::one_or_none(headers)
-28
+}

tmp-codegen-diff/aws-sdk/sdk/cloudwatchlogs/src/protocol_serde/shape_get_log_object_output.rs

@@ -1,1 +12,14 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub fn de_field_stream_payload(
     body: &mut ::aws_smithy_types::body::SdkBody,
 ) -> std::result::Result<
     crate::event_receiver::EventReceiver<crate::types::GetLogObjectResponseStream, crate::types::error::GetLogObjectResponseStreamError>,
     crate::operation::get_log_object::GetLogObjectError,
 > {
     let unmarshaller = crate::event_stream_serde::GetLogObjectResponseStreamUnmarshaller::new();
     let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
     let receiver = crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(unmarshaller, body));
     Ok(receiver)
     Ok(crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(
         unmarshaller,
         body,
     )))
-14
+}

tmp-codegen-diff/aws-sdk/sdk/cloudwatchlogs/src/protocol_serde/shape_start_live_tail_output.rs

@@ -1,1 +12,14 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub fn de_response_stream_payload(
     body: &mut ::aws_smithy_types::body::SdkBody,
 ) -> std::result::Result<
     crate::event_receiver::EventReceiver<crate::types::StartLiveTailResponseStream, crate::types::error::StartLiveTailResponseStreamError>,
     crate::operation::start_live_tail::StartLiveTailError,
 > {
     let unmarshaller = crate::event_stream_serde::StartLiveTailResponseStreamUnmarshaller::new();
     let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
     let receiver = crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(unmarshaller, body));
     Ok(receiver)
     Ok(crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(
         unmarshaller,
         body,
     )))
-14
+}

tmp-codegen-diff/aws-sdk/sdk/lambda/src/protocol_serde/shape_invoke_with_response_stream_output.rs

@@ -1,1 +29,31 @@

↥ Expand context

     body: &mut ::aws_smithy_types::body::SdkBody,
 ) -> std::result::Result<
     crate::event_receiver::EventReceiver<
         crate::types::InvokeWithResponseStreamResponseEvent,
         crate::types::error::InvokeWithResponseStreamResponseEventError,
     >,
     crate::operation::invoke_with_response_stream::InvokeWithResponseStreamError,
 > {
     let unmarshaller = crate::event_stream_serde::InvokeWithResponseStreamResponseEventUnmarshaller::new();
     let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
     let receiver = crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(unmarshaller, body));
     Ok(receiver)
     Ok(crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(
         unmarshaller,
         body,
     )))
-17
+}
-18
 pub(crate) fn de_executed_version_header(
     header_map: &::aws_smithy_runtime_api::http::Headers,
 ) -> ::std::result::Result<::std::option::Option<::std::string::String>, ::aws_smithy_http::header::ParseError> {
     let headers = header_map.get_all("X-Amz-Executed-Version");
     ::aws_smithy_http::header::one_or_none(headers)
-24
+}
-25
 pub(crate) fn de_response_stream_content_type_header(

↧ Expand context

     header_map: &::aws_smithy_runtime_api::http::Headers,
 ) -> ::std::result::Result<::std::option::Option<::std::string::String>, ::aws_smithy_http::header::ParseError> {
     let headers = header_map.get_all("Content-Type");
     ::aws_smithy_http::header::one_or_none(headers)
-31
+}

tmp-codegen-diff/aws-sdk/sdk/s3/src/protocol_serde/shape_select_object_content_output.rs

@@ -1,1 +12,14 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub fn de_payload_payload(
     body: &mut ::aws_smithy_types::body::SdkBody,
 ) -> std::result::Result<
     crate::event_receiver::EventReceiver<crate::types::SelectObjectContentEventStream, crate::types::error::SelectObjectContentEventStreamError>,
     crate::operation::select_object_content::SelectObjectContentError,
 > {
     let unmarshaller = crate::event_stream_serde::SelectObjectContentEventStreamUnmarshaller::new();
     let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
     let receiver = crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(unmarshaller, body));
     Ok(receiver)
     Ok(crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(
         unmarshaller,
         body,
     )))
-14
+}

tmp-codegen-diff/aws-sdk/sdk/transcribestreaming/src/protocol_serde/shape_start_call_analytics_stream_transcription_output.rs

@@ -1,1 +44,46 @@

↥ Expand context

     body: &mut ::aws_smithy_types::body::SdkBody,
 ) -> std::result::Result<
     crate::event_receiver::EventReceiver<
         crate::types::CallAnalyticsTranscriptResultStream,
         crate::types::error::CallAnalyticsTranscriptResultStreamError,
     >,
     crate::operation::start_call_analytics_stream_transcription::StartCallAnalyticsStreamTranscriptionError,
 > {
     let unmarshaller = crate::event_stream_serde::CallAnalyticsTranscriptResultStreamUnmarshaller::new();
     let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
     let receiver = crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(unmarshaller, body));
     Ok(receiver)
     Ok(crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(
         unmarshaller,
         body,
     )))
-17
+}
-18
 pub(crate) fn de_content_identification_type_header(
     header_map: &::aws_smithy_runtime_api::http::Headers,
 ) -> ::std::result::Result<::std::option::Option<crate::types::ContentIdentificationType>, ::aws_smithy_http::header::ParseError> {
     let headers = header_map.get_all("x-amzn-transcribe-content-identification-type");
     ::aws_smithy_http::header::one_or_none(headers)
-24
+}
-25
 pub(crate) fn de_content_redaction_type_header(

↧ Expand context

     header_map: &::aws_smithy_runtime_api::http::Headers,
 ) -> ::std::result::Result<::std::option::Option<crate::types::ContentRedactionType>, ::aws_smithy_http::header::ParseError> {
     let headers = header_map.get_all("x-amzn-transcribe-content-redaction-type");
     ::aws_smithy_http::header::one_or_none(headers)
-31
+}
-32
 pub(crate) fn de_enable_partial_results_stabilization_header(
     header_map: &::aws_smithy_runtime_api::http::Headers,
 ) -> ::std::result::Result<::std::option::Option<bool>, ::aws_smithy_http::header::ParseError> {
     let headers = header_map.get_all("x-amzn-transcribe-enable-partial-results-stabilization");
     let var_1 = ::aws_smithy_http::header::read_many_primitive::<bool>(headers)?;
     if var_1.len() > 1 {
         Err(::aws_smithy_http::header::ParseError::new(format!(
             "expected one item but found {}",
             var_1.len()
         )))
     } else {
         let mut var_1 = var_1;
         Ok(var_1.pop())
-46
+    }

tmp-codegen-diff/aws-sdk/sdk/transcribestreaming/src/protocol_serde/shape_start_medical_scribe_stream_output.rs

@@ -17,17 +56,58 @@

↥ Expand context

     header_map: &::aws_smithy_runtime_api::http::Headers,
 ) -> ::std::result::Result<::std::option::Option<i32>, ::aws_smithy_http::header::ParseError> {
     let headers = header_map.get_all("x-amzn-transcribe-sample-rate");
     let var_1 = ::aws_smithy_http::header::read_many_primitive::<i32>(headers)?;
     if var_1.len() > 1 {
         Err(::aws_smithy_http::header::ParseError::new(format!(
             "expected one item but found {}",
             var_1.len()
         )))
     } else {
         let mut var_1 = var_1;
         Ok(var_1.pop())
-29
+    }
-30
+}
-31
 pub(crate) fn de_request_id_header(
     header_map: &::aws_smithy_runtime_api::http::Headers,
 ) -> ::std::result::Result<::std::option::Option<::std::string::String>, ::aws_smithy_http::header::ParseError> {
     let headers = header_map.get_all("x-amzn-request-id");
     ::aws_smithy_http::header::one_or_none(headers)

-37
+}
-38
 pub fn de_result_stream_payload(
     body: &mut ::aws_smithy_types::body::SdkBody,
 ) -> std::result::Result<
     crate::event_receiver::EventReceiver<crate::types::MedicalScribeResultStream, crate::types::error::MedicalScribeResultStreamError>,
     crate::operation::start_medical_scribe_stream::StartMedicalScribeStreamError,
 > {
     let unmarshaller = crate::event_stream_serde::MedicalScribeResultStreamUnmarshaller::new();
     let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
     let receiver = crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(unmarshaller, body));
     Ok(receiver)
     Ok(crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(
         unmarshaller,
         body,
     )))
-51
+}
-52
 pub(crate) fn de_session_id_header(
     header_map: &::aws_smithy_runtime_api::http::Headers,
 ) -> ::std::result::Result<::std::option::Option<::std::string::String>, ::aws_smithy_http::header::ParseError> {
     let headers = header_map.get_all("x-amzn-transcribe-session-id");
     ::aws_smithy_http::header::one_or_none(headers)
-58
+}

tmp-codegen-diff/aws-sdk/sdk/transcribestreaming/src/protocol_serde/shape_start_medical_stream_transcription_output.rs

@@ -86,86 +132,134 @@

↥ Expand context

     header_map: &::aws_smithy_runtime_api::http::Headers,
 ) -> ::std::result::Result<::std::option::Option<bool>, ::aws_smithy_http::header::ParseError> {
     let headers = header_map.get_all("x-amzn-transcribe-show-speaker-label");
     let var_4 = ::aws_smithy_http::header::read_many_primitive::<bool>(headers)?;
     if var_4.len() > 1 {
         Err(::aws_smithy_http::header::ParseError::new(format!(
             "expected one item but found {}",
             var_4.len()
         )))
     } else {
         let mut var_4 = var_4;
         Ok(var_4.pop())
-98
+    }
-99
+}
-100
 pub(crate) fn de_specialty_header(
     header_map: &::aws_smithy_runtime_api::http::Headers,
 ) -> ::std::result::Result<::std::option::Option<crate::types::Specialty>, ::aws_smithy_http::header::ParseError> {
     let headers = header_map.get_all("x-amzn-transcribe-specialty");
     ::aws_smithy_http::header::one_or_none(headers)

-106
+}
-107
 pub fn de_transcript_result_stream_payload(
     body: &mut ::aws_smithy_types::body::SdkBody,
 ) -> std::result::Result<
     crate::event_receiver::EventReceiver<crate::types::MedicalTranscriptResultStream, crate::types::error::MedicalTranscriptResultStreamError>,
     crate::operation::start_medical_stream_transcription::StartMedicalStreamTranscriptionError,
 > {
     let unmarshaller = crate::event_stream_serde::MedicalTranscriptResultStreamUnmarshaller::new();
     let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
     let receiver = crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(unmarshaller, body));
     Ok(receiver)
     Ok(crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(
         unmarshaller,
         body,
     )))
-120
+}
-121
 pub(crate) fn de_type_header(
     header_map: &::aws_smithy_runtime_api::http::Headers,
 ) -> ::std::result::Result<::std::option::Option<crate::types::Type>, ::aws_smithy_http::header::ParseError> {
     let headers = header_map.get_all("x-amzn-transcribe-type");
     ::aws_smithy_http::header::one_or_none(headers)
-127
+}
-128
 pub(crate) fn de_vocabulary_name_header(

↧ Expand context

     header_map: &::aws_smithy_runtime_api::http::Headers,
 ) -> ::std::result::Result<::std::option::Option<::std::string::String>, ::aws_smithy_http::header::ParseError> {
     let headers = header_map.get_all("x-amzn-transcribe-vocabulary-name");
     ::aws_smithy_http::header::one_or_none(headers)
-134
+}

tmp-codegen-diff/aws-sdk/sdk/transcribestreaming/src/protocol_serde/shape_start_stream_transcription_output.rs

@@ -169,169 +230,232 @@

↥ Expand context

     header_map: &::aws_smithy_runtime_api::http::Headers,
 ) -> ::std::result::Result<::std::option::Option<::std::string::String>, ::aws_smithy_http::header::ParseError> {
     let headers = header_map.get_all("x-amzn-transcribe-session-id");
     ::aws_smithy_http::header::one_or_none(headers)
-173
+}
-174
 pub(crate) fn de_show_speaker_label_header(
     header_map: &::aws_smithy_runtime_api::http::Headers,
 ) -> ::std::result::Result<::std::option::Option<bool>, ::aws_smithy_http::header::ParseError> {
     let headers = header_map.get_all("x-amzn-transcribe-show-speaker-label");
     let var_7 = ::aws_smithy_http::header::read_many_primitive::<bool>(headers)?;
     if var_7.len() > 1 {
         Err(::aws_smithy_http::header::ParseError::new(format!(
             "expected one item but found {}",
             var_7.len()
         )))
     } else {
         let mut var_7 = var_7;
         Ok(var_7.pop())
-188
+    }

-189
+}
-190
 pub fn de_transcript_result_stream_payload(
     body: &mut ::aws_smithy_types::body::SdkBody,
 ) -> std::result::Result<
     crate::event_receiver::EventReceiver<crate::types::TranscriptResultStream, crate::types::error::TranscriptResultStreamError>,
     crate::operation::start_stream_transcription::StartStreamTranscriptionError,
 > {
     let unmarshaller = crate::event_stream_serde::TranscriptResultStreamUnmarshaller::new();
     let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
     let receiver = crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(unmarshaller, body));
     Ok(receiver)
     Ok(crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(
         unmarshaller,
         body,
     )))
-203
+}
-204
 pub(crate) fn de_vocabulary_filter_method_header(
     header_map: &::aws_smithy_runtime_api::http::Headers,
 ) -> ::std::result::Result<::std::option::Option<crate::types::VocabularyFilterMethod>, ::aws_smithy_http::header::ParseError> {
     let headers = header_map.get_all("x-amzn-transcribe-vocabulary-filter-method");
     ::aws_smithy_http::header::one_or_none(headers)
-210
+}
-211
 pub(crate) fn de_vocabulary_filter_name_header(

↧ Expand context

     header_map: &::aws_smithy_runtime_api::http::Headers,
 ) -> ::std::result::Result<::std::option::Option<::std::string::String>, ::aws_smithy_http::header::ParseError> {
     let headers = header_map.get_all("x-amzn-transcribe-vocabulary-filter-name");
     ::aws_smithy_http::header::one_or_none(headers)
-217
+}
-218
 pub(crate) fn de_vocabulary_filter_names_header(
     header_map: &::aws_smithy_runtime_api::http::Headers,
 ) -> ::std::result::Result<::std::option::Option<::std::string::String>, ::aws_smithy_http::header::ParseError> {
     let headers = header_map.get_all("x-amzn-transcribe-vocabulary-filter-names");
     ::aws_smithy_http::header::one_or_none(headers)
-224
+}
-225
 pub(crate) fn de_vocabulary_name_header(
     header_map: &::aws_smithy_runtime_api::http::Headers,
 ) -> ::std::result::Result<::std::option::Option<::std::string::String>, ::aws_smithy_http::header::ParseError> {
     let headers = header_map.get_all("x-amzn-transcribe-vocabulary-name");
     ::aws_smithy_http::header::one_or_none(headers)
-231
+}
-232

Pages: 1

1 1	`// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.`
2 2	`pub fn de_body_payload(`

1 1	`// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.`
2 2	`pub fn de_event_stream_payload(`

1 1	`// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.`
2 2	`pub fn de_call_analytics_transcript_result_stream_payload(`