AWS SDK

tmp-codegen-diff/aws-sdk/sdk/transcribestreaming/src/operation/start_stream_transcription.rs

@@ -1,1 +40,46 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /// Orchestration and serialization glue logic for `StartStreamTranscription`.
 #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
 #[non_exhaustive]
 pub struct StartStreamTranscription;
 impl StartStreamTranscription {
     /// Creates a new `StartStreamTranscription`
     pub fn new() -> Self {
         Self
-10
+    }
     /// The schema for this operation's input shape.
     pub const INPUT_SCHEMA: &'static ::aws_smithy_schema::Schema =
         crate::operation::start_stream_transcription::StartStreamTranscriptionInput::SCHEMA;
     /// The schema for this operation's output shape.
     pub const OUTPUT_SCHEMA: &'static ::aws_smithy_schema::Schema =
         crate::operation::start_stream_transcription::StartStreamTranscriptionOutput::SCHEMA;
     pub(crate) async fn orchestrate(
         runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         input: crate::operation::start_stream_transcription::StartStreamTranscriptionInput,
     ) -> ::std::result::Result<
         crate::operation::start_stream_transcription::StartStreamTranscriptionOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::start_stream_transcription::StartStreamTranscriptionError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {

↧ Expand context

         let map_err = |err: ::aws_smithy_runtime_api::client::result::SdkError<
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >| {
             err.map_service_error(|err| {
                 err.downcast::<crate::operation::start_stream_transcription::StartStreamTranscriptionError>()
                     .expect("correct error type")
             })
         };
         let context = Self::orchestrate_with_stop_point(runtime_plugins, input, ::aws_smithy_runtime::client::orchestrator::StopPoint::None)
             .await
             .map_err(map_err)?;
         let output = context.finalize().map_err(map_err)?;
         ::std::result::Result::Ok(
             output
                 .downcast::<crate::operation::start_stream_transcription::StartStreamTranscriptionOutput>()
                 .expect("correct output type"),
-44
+        )
-45
+    }
-46

@@ -140,146 +271,399 @@

↥ Expand context

                 crate::operation::start_stream_transcription::StartStreamTranscriptionError,
             >::new())
             .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<
                 crate::operation::start_stream_transcription::StartStreamTranscriptionError,
             >::new());
-151
         ::std::borrow::Cow::Owned(rcb)
-153
+    }
-154
+}
-155
 #[derive(Debug)]
 struct StartStreamTranscriptionResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for StartStreamTranscriptionResponseDeserializer {
     fn deserialize_streaming(
         &self,
         response: &mut ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
     ) -> ::std::option::Option<::aws_smithy_runtime_api::client::interceptors::context::OutputOrError> {
         #[allow(unused_mut)]
         let mut force_error = false;
         ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));

-166
         // If this is an error, defer to the non-streaming parser
         if (!response.status().is_success() && response.status().as_u16() != 200) || force_error {
             return ::std::option::Option::None;
-170
+        }
         ::std::option::Option::Some(crate::protocol_serde::type_erase_result(
             crate::protocol_serde::shape_start_stream_transcription::de_start_stream_transcription_http_response(response),
         ))
-174
+    }
-175
     fn deserialize_nonstreaming(
     fn deserialize_nonstreaming_with_config(
         &self,
         response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         _cfg: &::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
         // For streaming operations, we only hit this case if its an error
         let body = response.body().bytes().expect("body loaded");
         crate::protocol_serde::type_erase_result(
             crate::protocol_serde::shape_start_stream_transcription::de_start_stream_transcription_http_error(
                 response.status().as_u16(),
                 response.headers(),
                 body,
             ),
--
+        )
         let status = response.status().as_u16();
         let headers = response.headers();
         #[allow(unused_mut)]
         let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(status, headers, body).map_err(|e| {
             ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(::aws_smithy_runtime_api::box_error::BoxError::from(e))
         })?;
         generic_builder = ::aws_types::request_id::apply_request_id(generic_builder, headers);
         let generic = generic_builder.build();
         let error_code = match generic.code() {
             ::std::option::Option::Some(code) => code,
             ::std::option::Option::None => {
                 return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                     ::aws_smithy_runtime_api::box_error::BoxError::from(
                         crate::operation::start_stream_transcription::StartStreamTranscriptionError::unhandled(generic),
                     ),
                 ))
-+
+            }
         };
         let _error_message = generic.message().map(|msg| msg.to_owned());
         let protocol = _cfg
             .load::<::aws_smithy_schema::protocol::SharedClientProtocol>()
             .expect("a SharedClientProtocol is required");
         let err = match error_code {
             "BadRequestException" => crate::operation::start_stream_transcription::StartStreamTranscriptionError::BadRequestException({
                 let mut tmp = match protocol
                     .deserialize_response(response, crate::types::error::BadRequestException::SCHEMA, _cfg)
                     .and_then(|mut deser| {
                         crate::types::error::BadRequestException::deserialize_with_response(
                             &mut *deser,
                             response.headers(),
                             response.status().into(),
                             body,
-+
+                        )
                     }) {
                     ::std::result::Result::Ok(val) => val,
                     ::std::result::Result::Err(e) => {
                         return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                             ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                         ))
-+
+                    }
                 };
                 tmp.meta = generic;
                 if tmp.message.is_none() {
                     tmp.message = _error_message;
-+
+                }
                 tmp
             }),
             "ConflictException" => crate::operation::start_stream_transcription::StartStreamTranscriptionError::ConflictException({
                 let mut tmp = match protocol
                     .deserialize_response(response, crate::types::error::ConflictException::SCHEMA, _cfg)
                     .and_then(|mut deser| {
                         crate::types::error::ConflictException::deserialize_with_response(
                             &mut *deser,
                             response.headers(),
                             response.status().into(),
                             body,
-+
+                        )
                     }) {
                     ::std::result::Result::Ok(val) => val,
                     ::std::result::Result::Err(e) => {
                         return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                             ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                         ))
-+
+                    }
                 };
                 tmp.meta = generic;
                 if tmp.message.is_none() {
                     tmp.message = _error_message;
-+
+                }
                 tmp
             }),
             "InternalFailureException" => crate::operation::start_stream_transcription::StartStreamTranscriptionError::InternalFailureException({
                 let mut tmp = match protocol
                     .deserialize_response(response, crate::types::error::InternalFailureException::SCHEMA, _cfg)
                     .and_then(|mut deser| {
                         crate::types::error::InternalFailureException::deserialize_with_response(
                             &mut *deser,
                             response.headers(),
                             response.status().into(),
                             body,
-+
+                        )
                     }) {
                     ::std::result::Result::Ok(val) => val,
                     ::std::result::Result::Err(e) => {
                         return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                             ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                         ))
-+
+                    }
                 };
                 tmp.meta = generic;
                 if tmp.message.is_none() {
                     tmp.message = _error_message;
-+
+                }
                 tmp
             }),
             "LimitExceededException" => crate::operation::start_stream_transcription::StartStreamTranscriptionError::LimitExceededException({
                 let mut tmp = match protocol
                     .deserialize_response(response, crate::types::error::LimitExceededException::SCHEMA, _cfg)
                     .and_then(|mut deser| {
                         crate::types::error::LimitExceededException::deserialize_with_response(
                             &mut *deser,
                             response.headers(),
                             response.status().into(),
                             body,
-+
+                        )
                     }) {
                     ::std::result::Result::Ok(val) => val,
                     ::std::result::Result::Err(e) => {
                         return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                             ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                         ))
-+
+                    }
                 };
                 tmp.meta = generic;
                 if tmp.message.is_none() {
                     tmp.message = _error_message;
-+
+                }
                 tmp
             }),
             "ServiceUnavailableException" => {
                 crate::operation::start_stream_transcription::StartStreamTranscriptionError::ServiceUnavailableException({
                     let mut tmp = match protocol
                         .deserialize_response(response, crate::types::error::ServiceUnavailableException::SCHEMA, _cfg)
                         .and_then(|mut deser| {
                             crate::types::error::ServiceUnavailableException::deserialize_with_response(
                                 &mut *deser,
                                 response.headers(),
                                 response.status().into(),
                                 body,
-+
+                            )
                         }) {
                         ::std::result::Result::Ok(val) => val,
                         ::std::result::Result::Err(e) => {
                             return ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::other(
                                 ::aws_smithy_runtime_api::box_error::BoxError::from(e),
                             ))
-+
+                        }
                     };
                     tmp.meta = generic;
                     if tmp.message.is_none() {
                         tmp.message = _error_message;
-+
+                    }
                     tmp
                 })
-+
+            }
             _ => crate::operation::start_stream_transcription::StartStreamTranscriptionError::generic(generic),
         };
         ::std::result::Result::Err(::aws_smithy_runtime_api::client::orchestrator::OrchestratorError::operation(
             ::aws_smithy_runtime_api::client::interceptors::context::Error::erase(err),
         ))
-333
+    }
-334
+}
 #[derive(Debug)]
 struct StartStreamTranscriptionRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for StartStreamTranscriptionRequestSerializer {
     #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
     fn serialize_input(
         &self,
         input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
         _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
         let input = input
             .downcast::<crate::operation::start_stream_transcription::StartStreamTranscriptionInput>()
             .expect("correct type");
         let _header_serialization_settings = _cfg
             .load::<crate::serialization_settings::HeaderSerializationSettings>()
             .cloned()
             .unwrap_or_default();
         let mut request_builder = {
             #[allow(clippy::uninlined_format_args)]
             fn uri_base(
                 _input: &crate::operation::start_stream_transcription::StartStreamTranscriptionInput,
                 output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 use ::std::fmt::Write as _;
                 ::std::write!(output, "/stream-transcription").expect("formatting should succeed");
                 ::std::result::Result::Ok(())
--
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::start_stream_transcription::StartStreamTranscriptionInput,
                 builder: ::http_1x::request::Builder,
             ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
                 let mut uri = ::std::string::String::new();
                 uri_base(input, &mut uri)?;
                 let builder = crate::protocol_serde::shape_start_stream_transcription::ser_start_stream_transcription_headers(input, builder)?;
                 ::std::result::Result::Ok(builder.method("POST").uri(uri))
--
+            }
             let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
             builder =
                 _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/vnd.amazon.eventstream");
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from({
         let protocol = _cfg
             .load::<::aws_smithy_schema::protocol::SharedClientProtocol>()
             .expect("a SharedClientProtocol is required");
         let mut request = protocol
             .serialize_request(&input, StartStreamTranscription::INPUT_SCHEMA, "", _cfg)
             .map_err(::aws_smithy_runtime_api::box_error::BoxError::from)?;
         *request.body_mut() = ::aws_smithy_types::body::SdkBody::from({
             let error_marshaller = crate::event_stream_serde::AudioStreamErrorMarshaller::new();
             let marshaller = crate::event_stream_serde::AudioStreamMarshaller::new();
             let (signer, signer_sender) = ::aws_smithy_eventstream::frame::DeferredSigner::new();
             _cfg.interceptor_state().store_put(signer_sender);
             ::aws_smithy_types::body::SdkBody::from_body_1_x(::http_body_util::StreamBody::new(input.audio_stream.into_body_stream(
                 marshaller,
                 error_marshaller,
                 signer,
             )))
         });
         if let Some(content_length) = body.content_length() {
             let content_length = content_length.to_string();
             request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
--
+        }
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
         // The protocol may have set Content-Length based on the initial empty body.
         // Remove it since the event stream body has unknown length.
         request.headers_mut().remove("Content-Length");
         request.headers_mut().insert("Content-Type", "application/vnd.amazon.eventstream");
-+
         return ::std::result::Result::Ok(request);
-370
+    }
-371
+}
 #[derive(Debug)]
 struct StartStreamTranscriptionEndpointParamsInterceptor;
-374
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for StartStreamTranscriptionEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "StartStreamTranscriptionEndpointParamsInterceptor"
-378
+    }
-379

↧ Expand context

     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<StartStreamTranscriptionInput>()
             .ok_or("failed to downcast to StartStreamTranscriptionInput")?;
-394
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))

tmp-codegen-diff/aws-sdk/sdk/transcribestreaming/src/operation/start_stream_transcription/_start_stream_transcription_input.rs

@@ -259,259 +769,891 @@

↥ Expand context

-259
+    }
     /// <p>Specify the names of the custom vocabularies that you want to use when processing your transcription. Note that vocabulary names are case sensitive.</p>
     /// <p>If none of the languages of the specified custom vocabularies match the language identified in your media, your job fails.</p><important>
     /// <p>This parameter is only intended for use <b>with</b> the <code>IdentifyLanguage</code> parameter. If you're <b>not</b> including <code>IdentifyLanguage</code> in your request and want to use a custom vocabulary with your transcription, use the <code>VocabularyName</code> parameter instead.</p>
     /// </important>
     /// <p>For more information, see <a href="https://docs.aws.amazon.com/transcribe/latest/dg/custom-vocabulary.html">Custom vocabularies</a>.</p>
     pub fn vocabulary_names(&self) -> ::std::option::Option<&str> {
         self.vocabulary_names.as_deref()
-267
+    }
     /// <p>Specify the names of the custom vocabulary filters that you want to use when processing your transcription. Note that vocabulary filter names are case sensitive.</p>
     /// <p>If none of the languages of the specified custom vocabulary filters match the language identified in your media, your job fails.</p><important>
     /// <p>This parameter is only intended for use <b>with</b> the <code>IdentifyLanguage</code> parameter. If you're <b>not</b> including <code>IdentifyLanguage</code> in your request and want to use a custom vocabulary filter with your transcription, use the <code>VocabularyFilterName</code> parameter instead.</p>
     /// </important>
     /// <p>For more information, see <a href="https://docs.aws.amazon.com/transcribe/latest/dg/vocabulary-filtering.html">Using vocabulary filtering with unwanted words</a>.</p>
     pub fn vocabulary_filter_names(&self) -> ::std::option::Option<&str> {
         self.vocabulary_filter_names.as_deref()
-275
+    }
-276
+}
 static STARTSTREAMTRANSCRIPTIONINPUT_SCHEMA_ID: ::aws_smithy_schema::ShapeId = ::aws_smithy_schema::ShapeId::from_static(
     "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput",

     "com.amazonaws.transcribestreaming.synthetic",
     "StartStreamTranscriptionInput",
 );
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_LANGUAGE_CODE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$LanguageCode",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "language_code",
     "LanguageCode",
 ,
-291
+)
 .with_http_header("x-amzn-transcribe-language-code");
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_MEDIA_SAMPLE_RATE_HERTZ: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$MediaSampleRateHertz",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionInput",
     ),
     ::aws_smithy_schema::ShapeType::Integer,
     "media_sample_rate_hertz",
     "MediaSampleRateHertz",
 ,
-302
+)
 .with_http_header("x-amzn-transcribe-sample-rate");
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_MEDIA_ENCODING: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$MediaEncoding",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "media_encoding",
     "MediaEncoding",
 ,
-313
+)
 .with_http_header("x-amzn-transcribe-media-encoding");
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_VOCABULARY_NAME: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$VocabularyName",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "vocabulary_name",
     "VocabularyName",
 ,
-324
+)
 .with_http_header("x-amzn-transcribe-vocabulary-name");
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_SESSION_ID: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$SessionId",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "session_id",
     "SessionId",
 ,
-335
+)
 .with_http_header("x-amzn-transcribe-session-id");
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_AUDIO_STREAM: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$AudioStream",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionInput",
     ),
     ::aws_smithy_schema::ShapeType::Union,
     "audio_stream",
     "AudioStream",
 ,
-346
+)
 .with_http_payload();
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_VOCABULARY_FILTER_NAME: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$VocabularyFilterName",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "vocabulary_filter_name",
     "VocabularyFilterName",
 ,
-357
+)
 .with_http_header("x-amzn-transcribe-vocabulary-filter-name");
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_VOCABULARY_FILTER_METHOD: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$VocabularyFilterMethod",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "vocabulary_filter_method",
     "VocabularyFilterMethod",
 ,
-368
+)
 .with_http_header("x-amzn-transcribe-vocabulary-filter-method");
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_SHOW_SPEAKER_LABEL: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$ShowSpeakerLabel",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionInput",
     ),
     ::aws_smithy_schema::ShapeType::Boolean,
     "show_speaker_label",
     "ShowSpeakerLabel",
 ,
-379
+)
 .with_http_header("x-amzn-transcribe-show-speaker-label");
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_ENABLE_CHANNEL_IDENTIFICATION: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$EnableChannelIdentification",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionInput",
     ),
     ::aws_smithy_schema::ShapeType::Boolean,
     "enable_channel_identification",
     "EnableChannelIdentification",
 ,
-390
+)
 .with_http_header("x-amzn-transcribe-enable-channel-identification");
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_NUMBER_OF_CHANNELS: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$NumberOfChannels",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionInput",
     ),
     ::aws_smithy_schema::ShapeType::Integer,
     "number_of_channels",
     "NumberOfChannels",
 ,
-401
+)
 .with_http_header("x-amzn-transcribe-number-of-channels");
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_ENABLE_PARTIAL_RESULTS_STABILIZATION: ::aws_smithy_schema::Schema =
     ::aws_smithy_schema::Schema::new_member(
         ::aws_smithy_schema::ShapeId::from_static(
             "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$EnablePartialResultsStabilization",
             "com.amazonaws.transcribestreaming.synthetic",
             "StartStreamTranscriptionInput",
         ),
         ::aws_smithy_schema::ShapeType::Boolean,
         "enable_partial_results_stabilization",
         "EnablePartialResultsStabilization",
 ,
-413
+    )
     .with_http_header("x-amzn-transcribe-enable-partial-results-stabilization");
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_PARTIAL_RESULTS_STABILITY: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$PartialResultsStability",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "partial_results_stability",
     "PartialResultsStability",
 ,
-424
+)
 .with_http_header("x-amzn-transcribe-partial-results-stability");
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_CONTENT_IDENTIFICATION_TYPE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$ContentIdentificationType",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "content_identification_type",
     "ContentIdentificationType",
 ,
-435
+)
 .with_http_header("x-amzn-transcribe-content-identification-type");
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_CONTENT_REDACTION_TYPE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$ContentRedactionType",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "content_redaction_type",
     "ContentRedactionType",
 ,
-446
+)
 .with_http_header("x-amzn-transcribe-content-redaction-type");
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_PII_ENTITY_TYPES: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$PiiEntityTypes",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "pii_entity_types",
     "PiiEntityTypes",
 ,
-457
+)
 .with_http_header("x-amzn-transcribe-pii-entity-types");
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_LANGUAGE_MODEL_NAME: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$LanguageModelName",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "language_model_name",
     "LanguageModelName",
 ,
-468
+)
 .with_http_header("x-amzn-transcribe-language-model-name");
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_IDENTIFY_LANGUAGE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$IdentifyLanguage",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionInput",
     ),
     ::aws_smithy_schema::ShapeType::Boolean,
     "identify_language",
     "IdentifyLanguage",
 ,
-479
+)
 .with_http_header("x-amzn-transcribe-identify-language");
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_LANGUAGE_OPTIONS: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$LanguageOptions",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "language_options",
     "LanguageOptions",
 ,
-490
+)
 .with_http_header("x-amzn-transcribe-language-options");
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_PREFERRED_LANGUAGE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$PreferredLanguage",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "preferred_language",
     "PreferredLanguage",
 ,
-501
+)
 .with_http_header("x-amzn-transcribe-preferred-language");
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_IDENTIFY_MULTIPLE_LANGUAGES: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$IdentifyMultipleLanguages",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionInput",
     ),
     ::aws_smithy_schema::ShapeType::Boolean,
     "identify_multiple_languages",
     "IdentifyMultipleLanguages",
 ,
-512
+)
 .with_http_header("x-amzn-transcribe-identify-multiple-languages");
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_VOCABULARY_NAMES: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$VocabularyNames",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "vocabulary_names",
     "VocabularyNames",
 ,
-523
+)
 .with_http_header("x-amzn-transcribe-vocabulary-names");
 static STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_VOCABULARY_FILTER_NAMES: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionInput$VocabularyFilterNames",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionInput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "vocabulary_filter_names",
     "VocabularyFilterNames",
 ,
-534
+)
 .with_http_header("x-amzn-transcribe-vocabulary-filter-names");
 static STARTSTREAMTRANSCRIPTIONINPUT_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
     STARTSTREAMTRANSCRIPTIONINPUT_SCHEMA_ID,
     ::aws_smithy_schema::ShapeType::Structure,
     &[
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_LANGUAGE_CODE,
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_MEDIA_SAMPLE_RATE_HERTZ,
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_MEDIA_ENCODING,
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_VOCABULARY_NAME,
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_SESSION_ID,
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_AUDIO_STREAM,
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_VOCABULARY_FILTER_NAME,
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_VOCABULARY_FILTER_METHOD,
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_SHOW_SPEAKER_LABEL,
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_ENABLE_CHANNEL_IDENTIFICATION,
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_NUMBER_OF_CHANNELS,
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_ENABLE_PARTIAL_RESULTS_STABILIZATION,
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_PARTIAL_RESULTS_STABILITY,
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_CONTENT_IDENTIFICATION_TYPE,
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_CONTENT_REDACTION_TYPE,
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_PII_ENTITY_TYPES,
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_LANGUAGE_MODEL_NAME,
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_IDENTIFY_LANGUAGE,
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_LANGUAGE_OPTIONS,
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_PREFERRED_LANGUAGE,
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_IDENTIFY_MULTIPLE_LANGUAGES,
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_VOCABULARY_NAMES,
         &STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_VOCABULARY_FILTER_NAMES,
     ],
 );
-+
+)
 .with_http(aws_smithy_schema::traits::HttpTrait::new("POST", "/stream-transcription", None));
 impl StartStreamTranscriptionInput {
     /// The schema for this shape.
     pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &STARTSTREAMTRANSCRIPTIONINPUT_SCHEMA;
-569
+}
 impl ::aws_smithy_schema::serde::SerializableStruct for StartStreamTranscriptionInput {
     #[allow(unused_variables, clippy::diverging_sub_expression)]
     fn serialize_members(
         &self,
         ser: &mut dyn ::aws_smithy_schema::serde::ShapeSerializer,
     ) -> ::std::result::Result<(), ::aws_smithy_schema::serde::SerdeError> {
         if let Some(ref val) = self.language_code {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_LANGUAGE_CODE, val.as_str())?;
-578
+        }
         if let Some(ref val) = self.media_sample_rate_hertz {
             ser.write_integer(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_MEDIA_SAMPLE_RATE_HERTZ, *val)?;
-581
+        }
         if let Some(ref val) = self.media_encoding {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_MEDIA_ENCODING, val.as_str())?;
-584
+        }
         if let Some(ref val) = self.vocabulary_name {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_VOCABULARY_NAME, val)?;
-587
+        }
         if let Some(ref val) = self.session_id {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_SESSION_ID, val)?;
-590
+        }
--
+        {
             let val = &self.audio_stream;
             ser.write_null(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_AUDIO_STREAM)?;
--
+        }
         if let Some(ref val) = self.vocabulary_filter_name {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_VOCABULARY_FILTER_NAME, val)?;
-593
+        }
         if let Some(ref val) = self.vocabulary_filter_method {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_VOCABULARY_FILTER_METHOD, val.as_str())?;
-596
+        }
         if let Some(ref val) = self.show_speaker_label {
             ser.write_boolean(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_SHOW_SPEAKER_LABEL, *val)?;
-599
+        }
         if let Some(ref val) = self.enable_channel_identification {
             ser.write_boolean(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_ENABLE_CHANNEL_IDENTIFICATION, *val)?;
-602
+        }
         if let Some(ref val) = self.number_of_channels {
             ser.write_integer(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_NUMBER_OF_CHANNELS, *val)?;
-605
+        }
         if let Some(ref val) = self.enable_partial_results_stabilization {
             ser.write_boolean(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_ENABLE_PARTIAL_RESULTS_STABILIZATION, *val)?;
-608
+        }
         if let Some(ref val) = self.partial_results_stability {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_PARTIAL_RESULTS_STABILITY, val.as_str())?;
-611
+        }
         if let Some(ref val) = self.content_identification_type {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_CONTENT_IDENTIFICATION_TYPE, val.as_str())?;
-614
+        }
         if let Some(ref val) = self.content_redaction_type {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_CONTENT_REDACTION_TYPE, val.as_str())?;
-617
+        }
         if let Some(ref val) = self.pii_entity_types {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_PII_ENTITY_TYPES, val)?;
-620
+        }
         if let Some(ref val) = self.language_model_name {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_LANGUAGE_MODEL_NAME, val)?;
-623
+        }
         if let Some(ref val) = self.identify_language {
             ser.write_boolean(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_IDENTIFY_LANGUAGE, *val)?;
-626
+        }
         if let Some(ref val) = self.language_options {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_LANGUAGE_OPTIONS, val)?;
-629
+        }
         if let Some(ref val) = self.preferred_language {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_PREFERRED_LANGUAGE, val.as_str())?;
-632
+        }
         if let Some(ref val) = self.identify_multiple_languages {
             ser.write_boolean(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_IDENTIFY_MULTIPLE_LANGUAGES, *val)?;
-635
+        }
         if let Some(ref val) = self.vocabulary_names {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_VOCABULARY_NAMES, val)?;
-638
+        }
         if let Some(ref val) = self.vocabulary_filter_names {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONINPUT_MEMBER_VOCABULARY_FILTER_NAMES, val)?;
-641
+        }
         Ok(())
-643
+    }
-644
+}
 impl StartStreamTranscriptionInput {
     /// Deserializes this structure from a [`ShapeDeserializer`].
     pub fn deserialize<D: ::aws_smithy_schema::serde::ShapeDeserializer>(
         deserializer: &mut D,
     pub fn deserialize(
         deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
     ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
         #[allow(unused_variables, unused_mut)]
         let mut builder = Self::builder();
         #[allow(
             unused_variables,
             unreachable_code,
             clippy::single_match,
             clippy::match_single_binding,
             clippy::diverging_sub_expression
         )]
         deserializer.read_struct(&STARTSTREAMTRANSCRIPTIONINPUT_SCHEMA, (), |_, member, deser| {
         deserializer.read_struct(&STARTSTREAMTRANSCRIPTIONINPUT_SCHEMA, &mut |member, deser| {
             match member.member_index() {
                 Some(0) => {
                     builder.language_code = Some(crate::types::LanguageCode::from(deser.read_string(member)?.as_str()));
-663
+                }
                 Some(1) => {
                     builder.media_sample_rate_hertz = Some(deser.read_integer(member)?);
-666
+                }
                 Some(2) => {
                     builder.media_encoding = Some(crate::types::MediaEncoding::from(deser.read_string(member)?.as_str()));
-669
+                }
                 Some(3) => {
                     builder.vocabulary_name = Some(deser.read_string(member)?);
-672
+                }
                 Some(4) => {
                     builder.session_id = Some(deser.read_string(member)?);
-675
+                }
                 Some(5) => {
                     builder.audio_stream = Some({
                         let _ = member;
                         todo!("deserialize aggregate")
                         todo!("deserialize streaming union")
                     });
-681
+                }
                 Some(6) => {
                     builder.vocabulary_filter_name = Some(deser.read_string(member)?);
-684
+                }
                 Some(7) => {
                     builder.vocabulary_filter_method = Some(crate::types::VocabularyFilterMethod::from(deser.read_string(member)?.as_str()));
-687
+                }
                 Some(8) => {
                     builder.show_speaker_label = Some(deser.read_boolean(member)?);
-690
+                }
                 Some(9) => {
                     builder.enable_channel_identification = Some(deser.read_boolean(member)?);
-693
+                }
                 Some(10) => {
                     builder.number_of_channels = Some(deser.read_integer(member)?);
-696
+                }
                 Some(11) => {
                     builder.enable_partial_results_stabilization = Some(deser.read_boolean(member)?);
-699
+                }
                 Some(12) => {
                     builder.partial_results_stability = Some(crate::types::PartialResultsStability::from(deser.read_string(member)?.as_str()));
-702
+                }
                 Some(13) => {
                     builder.content_identification_type = Some(crate::types::ContentIdentificationType::from(deser.read_string(member)?.as_str()));
-705
+                }
                 Some(14) => {
                     builder.content_redaction_type = Some(crate::types::ContentRedactionType::from(deser.read_string(member)?.as_str()));
-708
+                }
                 Some(15) => {
                     builder.pii_entity_types = Some(deser.read_string(member)?);
-711
+                }
                 Some(16) => {
                     builder.language_model_name = Some(deser.read_string(member)?);
-714
+                }
                 Some(17) => {
                     builder.identify_language = Some(deser.read_boolean(member)?);
-717
+                }
                 Some(18) => {
                     builder.language_options = Some(deser.read_string(member)?);
-720
+                }
                 Some(19) => {
                     builder.preferred_language = Some(crate::types::LanguageCode::from(deser.read_string(member)?.as_str()));
-723
+                }
                 Some(20) => {
                     builder.identify_multiple_languages = Some(deser.read_boolean(member)?);
-726
+                }
                 Some(21) => {
                     builder.vocabulary_names = Some(deser.read_string(member)?);
-729
+                }
                 Some(22) => {
                     builder.vocabulary_filter_names = Some(deser.read_string(member)?);
-732
+                }
                 _ => {}
-734
+            }
             Ok(())
         })?;
         builder.media_sample_rate_hertz = builder.media_sample_rate_hertz.or(Some(0i32));
         builder
             .build()
             .map_err(|e| aws_smithy_schema::serde::SerdeError::Custom { message: e.to_string() })
-+
+    }
-+
+}
 impl StartStreamTranscriptionInput {
     /// Deserializes this structure from a body deserializer and HTTP response headers.
     /// Header-bound members are read directly from headers, avoiding runtime
     /// member iteration overhead. Body members are read via the deserializer.
     pub fn deserialize_with_response(
         deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
         headers: &::aws_smithy_runtime_api::http::Headers,
         _status: u16,
         _body: &[u8],
     ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
         #[allow(unused_variables, unused_mut)]
         let mut builder = Self::builder();
         if let Some(val) = headers.get("x-amzn-transcribe-language-code") {
             builder.language_code = Some(crate::types::LanguageCode::from(val));
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-sample-rate") {
             builder.media_sample_rate_hertz = val.parse::<i32>().ok();
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-media-encoding") {
             builder.media_encoding = Some(crate::types::MediaEncoding::from(val));
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-vocabulary-name") {
             builder.vocabulary_name = Some(val.to_string());
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-session-id") {
             builder.session_id = Some(val.to_string());
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-vocabulary-filter-name") {
             builder.vocabulary_filter_name = Some(val.to_string());
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-vocabulary-filter-method") {
             builder.vocabulary_filter_method = Some(crate::types::VocabularyFilterMethod::from(val));
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-show-speaker-label") {
             builder.show_speaker_label = val.parse::<bool>().ok();
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-enable-channel-identification") {
             builder.enable_channel_identification = val.parse::<bool>().ok();
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-number-of-channels") {
             builder.number_of_channels = val.parse::<i32>().ok();
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-enable-partial-results-stabilization") {
             builder.enable_partial_results_stabilization = val.parse::<bool>().ok();
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-partial-results-stability") {
             builder.partial_results_stability = Some(crate::types::PartialResultsStability::from(val));
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-content-identification-type") {
             builder.content_identification_type = Some(crate::types::ContentIdentificationType::from(val));
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-content-redaction-type") {
             builder.content_redaction_type = Some(crate::types::ContentRedactionType::from(val));
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-pii-entity-types") {
             builder.pii_entity_types = Some(val.to_string());
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-language-model-name") {
             builder.language_model_name = Some(val.to_string());
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-identify-language") {
             builder.identify_language = val.parse::<bool>().ok();
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-language-options") {
             builder.language_options = Some(val.to_string());
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-preferred-language") {
             builder.preferred_language = Some(crate::types::LanguageCode::from(val));
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-identify-multiple-languages") {
             builder.identify_multiple_languages = val.parse::<bool>().ok();
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-vocabulary-names") {
             builder.vocabulary_names = Some(val.to_string());
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-vocabulary-filter-names") {
             builder.vocabulary_filter_names = Some(val.to_string());
-+
+        }
         #[allow(
             unused_variables,
             unreachable_code,
             clippy::single_match,
             clippy::match_single_binding,
             clippy::diverging_sub_expression
         )]
         deserializer.read_struct(&STARTSTREAMTRANSCRIPTIONINPUT_SCHEMA, &mut |member, deser| {
             match member.member_index() {
                 Some(0) => { /* read from headers above */ }
                 Some(1) => { /* read from headers above */ }
                 Some(2) => { /* read from headers above */ }
                 Some(3) => { /* read from headers above */ }
                 Some(4) => { /* read from headers above */ }
                 Some(5) => {
                     builder.audio_stream = Some({
                         let _ = member;
                         todo!("deserialize streaming union")
                     });
-+
+                }
                 Some(6) => { /* read from headers above */ }
                 Some(7) => { /* read from headers above */ }
                 Some(8) => { /* read from headers above */ }
                 Some(9) => { /* read from headers above */ }
                 Some(10) => { /* read from headers above */ }
                 Some(11) => { /* read from headers above */ }
                 Some(12) => { /* read from headers above */ }
                 Some(13) => { /* read from headers above */ }
                 Some(14) => { /* read from headers above */ }
                 Some(15) => { /* read from headers above */ }
                 Some(16) => { /* read from headers above */ }
                 Some(17) => { /* read from headers above */ }
                 Some(18) => { /* read from headers above */ }
                 Some(19) => { /* read from headers above */ }
                 Some(20) => { /* read from headers above */ }
                 Some(21) => { /* read from headers above */ }
                 Some(22) => { /* read from headers above */ }
                 _ => {}
-+
+            }
             Ok(())
         })?;
         builder
             .build()
             .map_err(|e| aws_smithy_schema::serde::SerdeError::Custom { message: e.to_string() })
-865
+    }
-866
+}
 impl StartStreamTranscriptionInput {
     /// Creates a new builder-style object to manufacture [`StartStreamTranscriptionInput`](crate::operation::start_stream_transcription::StartStreamTranscriptionInput).
     pub fn builder() -> crate::operation::start_stream_transcription::builders::StartStreamTranscriptionInputBuilder {
         crate::operation::start_stream_transcription::builders::StartStreamTranscriptionInputBuilder::default()
-871
+    }

↧ Expand context

-872
+}
-873
 /// A builder for [`StartStreamTranscriptionInput`](crate::operation::start_stream_transcription::StartStreamTranscriptionInput).
 #[derive(::std::default::Default, ::std::fmt::Debug)]
 #[non_exhaustive]
 pub struct StartStreamTranscriptionInputBuilder {
     pub(crate) language_code: ::std::option::Option<crate::types::LanguageCode>,
     pub(crate) media_sample_rate_hertz: ::std::option::Option<i32>,
     pub(crate) media_encoding: ::std::option::Option<crate::types::MediaEncoding>,
     pub(crate) vocabulary_name: ::std::option::Option<::std::string::String>,
     pub(crate) session_id: ::std::option::Option<::std::string::String>,
     pub(crate) audio_stream:
         ::std::option::Option<::aws_smithy_http::event_stream::EventStreamSender<crate::types::AudioStream, crate::types::error::AudioStreamError>>,
     pub(crate) vocabulary_filter_name: ::std::option::Option<::std::string::String>,
     pub(crate) vocabulary_filter_method: ::std::option::Option<crate::types::VocabularyFilterMethod>,
     pub(crate) show_speaker_label: ::std::option::Option<bool>,
     pub(crate) enable_channel_identification: ::std::option::Option<bool>,
     pub(crate) number_of_channels: ::std::option::Option<i32>,
     pub(crate) enable_partial_results_stabilization: ::std::option::Option<bool>,
     pub(crate) partial_results_stability: ::std::option::Option<crate::types::PartialResultsStability>,

tmp-codegen-diff/aws-sdk/sdk/transcribestreaming/src/operation/start_stream_transcription/_start_stream_transcription_output.rs

@@ -139,139 +518,522 @@

↥ Expand context

-139
+    }
     /// <p>Provides the preferred language that you specified in your request.</p>
     pub fn preferred_language(&self) -> ::std::option::Option<&crate::types::LanguageCode> {
         self.preferred_language.as_ref()
-143
+    }
     /// <p>Shows whether automatic multi-language identification was enabled for your transcription.</p>
     pub fn identify_multiple_languages(&self) -> bool {
         self.identify_multiple_languages
-147
+    }
     /// <p>Provides the names of the custom vocabularies that you specified in your request.</p>
     pub fn vocabulary_names(&self) -> ::std::option::Option<&str> {
         self.vocabulary_names.as_deref()
-151
+    }
     /// <p>Provides the names of the custom vocabulary filters that you specified in your request.</p>
     pub fn vocabulary_filter_names(&self) -> ::std::option::Option<&str> {
         self.vocabulary_filter_names.as_deref()
-155
+    }
-156
+}
 static STARTSTREAMTRANSCRIPTIONOUTPUT_SCHEMA_ID: ::aws_smithy_schema::ShapeId = ::aws_smithy_schema::ShapeId::from_static(
     "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput",

     "com.amazonaws.transcribestreaming.synthetic",
     "StartStreamTranscriptionOutput",
 );
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_REQUEST_ID: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$RequestId",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "request_id",
     "RequestId",
 ,
-171
+)
 .with_http_header("x-amzn-request-id");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_LANGUAGE_CODE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$LanguageCode",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "language_code",
     "LanguageCode",
 ,
-182
+)
 .with_http_header("x-amzn-transcribe-language-code");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_MEDIA_SAMPLE_RATE_HERTZ: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$MediaSampleRateHertz",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::Integer,
     "media_sample_rate_hertz",
     "MediaSampleRateHertz",
 ,
-193
+)
 .with_http_header("x-amzn-transcribe-sample-rate");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_MEDIA_ENCODING: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$MediaEncoding",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "media_encoding",
     "MediaEncoding",
 ,
-204
+)
 .with_http_header("x-amzn-transcribe-media-encoding");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_VOCABULARY_NAME: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$VocabularyName",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "vocabulary_name",
     "VocabularyName",
 ,
-215
+)
 .with_http_header("x-amzn-transcribe-vocabulary-name");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_SESSION_ID: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$SessionId",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "session_id",
     "SessionId",
 ,
-226
+)
 .with_http_header("x-amzn-transcribe-session-id");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_TRANSCRIPT_RESULT_STREAM: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$TranscriptResultStream",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::Union,
     "transcript_result_stream",
     "TranscriptResultStream",
 ,
-237
+)
 .with_http_payload();
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_VOCABULARY_FILTER_NAME: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$VocabularyFilterName",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "vocabulary_filter_name",
     "VocabularyFilterName",
 ,
-248
+)
 .with_http_header("x-amzn-transcribe-vocabulary-filter-name");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_VOCABULARY_FILTER_METHOD: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$VocabularyFilterMethod",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "vocabulary_filter_method",
     "VocabularyFilterMethod",
 ,
-259
+)
 .with_http_header("x-amzn-transcribe-vocabulary-filter-method");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_SHOW_SPEAKER_LABEL: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$ShowSpeakerLabel",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::Boolean,
     "show_speaker_label",
     "ShowSpeakerLabel",
 ,
-270
+)
 .with_http_header("x-amzn-transcribe-show-speaker-label");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_ENABLE_CHANNEL_IDENTIFICATION: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$EnableChannelIdentification",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::Boolean,
     "enable_channel_identification",
     "EnableChannelIdentification",
 ,
-281
+)
 .with_http_header("x-amzn-transcribe-enable-channel-identification");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_NUMBER_OF_CHANNELS: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$NumberOfChannels",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::Integer,
     "number_of_channels",
     "NumberOfChannels",
 ,
-292
+)
 .with_http_header("x-amzn-transcribe-number-of-channels");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_ENABLE_PARTIAL_RESULTS_STABILIZATION: ::aws_smithy_schema::Schema =
     ::aws_smithy_schema::Schema::new_member(
         ::aws_smithy_schema::ShapeId::from_static(
             "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$EnablePartialResultsStabilization",
             "com.amazonaws.transcribestreaming.synthetic",
             "StartStreamTranscriptionOutput",
         ),
         ::aws_smithy_schema::ShapeType::Boolean,
         "enable_partial_results_stabilization",
         "EnablePartialResultsStabilization",
 ,
-304
+    )
     .with_http_header("x-amzn-transcribe-enable-partial-results-stabilization");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_PARTIAL_RESULTS_STABILITY: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$PartialResultsStability",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "partial_results_stability",
     "PartialResultsStability",
 ,
-315
+)
 .with_http_header("x-amzn-transcribe-partial-results-stability");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_CONTENT_IDENTIFICATION_TYPE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$ContentIdentificationType",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "content_identification_type",
     "ContentIdentificationType",
 ,
-326
+)
 .with_http_header("x-amzn-transcribe-content-identification-type");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_CONTENT_REDACTION_TYPE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$ContentRedactionType",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "content_redaction_type",
     "ContentRedactionType",
 ,
-337
+)
 .with_http_header("x-amzn-transcribe-content-redaction-type");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_PII_ENTITY_TYPES: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$PiiEntityTypes",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "pii_entity_types",
     "PiiEntityTypes",
 ,
-348
+)
 .with_http_header("x-amzn-transcribe-pii-entity-types");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_LANGUAGE_MODEL_NAME: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$LanguageModelName",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "language_model_name",
     "LanguageModelName",
 ,
-359
+)
 .with_http_header("x-amzn-transcribe-language-model-name");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_IDENTIFY_LANGUAGE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$IdentifyLanguage",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::Boolean,
     "identify_language",
     "IdentifyLanguage",
 ,
-370
+)
 .with_http_header("x-amzn-transcribe-identify-language");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_LANGUAGE_OPTIONS: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$LanguageOptions",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "language_options",
     "LanguageOptions",
 ,
-381
+)
 .with_http_header("x-amzn-transcribe-language-options");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_PREFERRED_LANGUAGE: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$PreferredLanguage",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "preferred_language",
     "PreferredLanguage",
 ,
-392
+)
 .with_http_header("x-amzn-transcribe-preferred-language");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_IDENTIFY_MULTIPLE_LANGUAGES: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$IdentifyMultipleLanguages",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::Boolean,
     "identify_multiple_languages",
     "IdentifyMultipleLanguages",
 ,
-403
+)
 .with_http_header("x-amzn-transcribe-identify-multiple-languages");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_VOCABULARY_NAMES: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$VocabularyNames",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "vocabulary_names",
     "VocabularyNames",
 ,
-414
+)
 .with_http_header("x-amzn-transcribe-vocabulary-names");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_VOCABULARY_FILTER_NAMES: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static(
         "com.amazonaws.transcribestreaming.synthetic#StartStreamTranscriptionOutput$VocabularyFilterNames",
         "com.amazonaws.transcribestreaming.synthetic",
         "StartStreamTranscriptionOutput",
     ),
     ::aws_smithy_schema::ShapeType::String,
     "vocabulary_filter_names",
     "VocabularyFilterNames",
 ,
-425
+)
 .with_http_header("x-amzn-transcribe-vocabulary-filter-names");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER__REQUEST_ID: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_member(
     ::aws_smithy_schema::ShapeId::from_static("synthetic#request_id", "synthetic", "request_id"),
     ::aws_smithy_schema::ShapeType::String,
     "request_id",
 ,
-+
+)
 .with_http_header("x-amzn-requestid");
 static STARTSTREAMTRANSCRIPTIONOUTPUT_SCHEMA: ::aws_smithy_schema::Schema = ::aws_smithy_schema::Schema::new_struct(
     STARTSTREAMTRANSCRIPTIONOUTPUT_SCHEMA_ID,
     ::aws_smithy_schema::ShapeType::Structure,
     &[
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_REQUEST_ID,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_LANGUAGE_CODE,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_MEDIA_SAMPLE_RATE_HERTZ,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_MEDIA_ENCODING,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_VOCABULARY_NAME,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_SESSION_ID,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_TRANSCRIPT_RESULT_STREAM,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_VOCABULARY_FILTER_NAME,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_VOCABULARY_FILTER_METHOD,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_SHOW_SPEAKER_LABEL,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_ENABLE_CHANNEL_IDENTIFICATION,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_NUMBER_OF_CHANNELS,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_ENABLE_PARTIAL_RESULTS_STABILIZATION,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_PARTIAL_RESULTS_STABILITY,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_CONTENT_IDENTIFICATION_TYPE,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_CONTENT_REDACTION_TYPE,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_PII_ENTITY_TYPES,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_LANGUAGE_MODEL_NAME,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_IDENTIFY_LANGUAGE,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_LANGUAGE_OPTIONS,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_PREFERRED_LANGUAGE,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_IDENTIFY_MULTIPLE_LANGUAGES,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_VOCABULARY_NAMES,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_VOCABULARY_FILTER_NAMES,
         &STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER__REQUEST_ID,
     ],
 );
 impl StartStreamTranscriptionOutput {
     /// The schema for this shape.
     pub const SCHEMA: &'static ::aws_smithy_schema::Schema = &STARTSTREAMTRANSCRIPTIONOUTPUT_SCHEMA;
-468
+}
 impl ::aws_smithy_schema::serde::SerializableStruct for StartStreamTranscriptionOutput {
     #[allow(unused_variables, clippy::diverging_sub_expression)]
     fn serialize_members(
         &self,
         ser: &mut dyn ::aws_smithy_schema::serde::ShapeSerializer,
     ) -> ::std::result::Result<(), ::aws_smithy_schema::serde::SerdeError> {
         if let Some(ref val) = self.request_id {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_REQUEST_ID, val)?;
-477
+        }
         if let Some(ref val) = self.language_code {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_LANGUAGE_CODE, val.as_str())?;
-480
+        }
         if let Some(ref val) = self.media_sample_rate_hertz {
             ser.write_integer(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_MEDIA_SAMPLE_RATE_HERTZ, *val)?;
-483
+        }
         if let Some(ref val) = self.media_encoding {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_MEDIA_ENCODING, val.as_str())?;
-486
+        }
         if let Some(ref val) = self.vocabulary_name {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_VOCABULARY_NAME, val)?;
-489
+        }
         if let Some(ref val) = self.session_id {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_SESSION_ID, val)?;
-492
+        }
--
+        {
             let val = &self.transcript_result_stream;
             ser.write_null(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_TRANSCRIPT_RESULT_STREAM)?;
--
+        }
         if let Some(ref val) = self.vocabulary_filter_name {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_VOCABULARY_FILTER_NAME, val)?;
-495
+        }
         if let Some(ref val) = self.vocabulary_filter_method {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_VOCABULARY_FILTER_METHOD, val.as_str())?;
-498
+        }
-499
+        {
             let val = &self.show_speaker_label;
             ser.write_boolean(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_SHOW_SPEAKER_LABEL, *val)?;
-502
+        }

↧ Expand context

-503
+        {
             let val = &self.enable_channel_identification;
             ser.write_boolean(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_ENABLE_CHANNEL_IDENTIFICATION, *val)?;
-506
+        }
         if let Some(ref val) = self.number_of_channels {
             ser.write_integer(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_NUMBER_OF_CHANNELS, *val)?;
-509
+        }
-510
+        {
             let val = &self.enable_partial_results_stabilization;
             ser.write_boolean(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_ENABLE_PARTIAL_RESULTS_STABILIZATION, *val)?;
-513
+        }
         if let Some(ref val) = self.partial_results_stability {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_PARTIAL_RESULTS_STABILITY, val.as_str())?;
-516
+        }
         if let Some(ref val) = self.content_identification_type {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_CONTENT_IDENTIFICATION_TYPE, val.as_str())?;
-519
+        }
         if let Some(ref val) = self.content_redaction_type {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_CONTENT_REDACTION_TYPE, val.as_str())?;
-522
+        }

@@ -520,524 +668,806 @@

↥ Expand context

             ser.write_string(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_PII_ENTITY_TYPES, val)?;
-525
+        }
         if let Some(ref val) = self.language_model_name {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_LANGUAGE_MODEL_NAME, val)?;
-528
+        }
-529
+        {
             let val = &self.identify_language;
             ser.write_boolean(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_IDENTIFY_LANGUAGE, *val)?;
-532
+        }
         if let Some(ref val) = self.language_options {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_LANGUAGE_OPTIONS, val)?;
-535
+        }
         if let Some(ref val) = self.preferred_language {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_PREFERRED_LANGUAGE, val.as_str())?;
-538
+        }
-539
+        {
             let val = &self.identify_multiple_languages;
             ser.write_boolean(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_IDENTIFY_MULTIPLE_LANGUAGES, *val)?;
-542
+        }
         if let Some(ref val) = self.vocabulary_names {

             ser.write_string(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_VOCABULARY_NAMES, val)?;
-545
+        }
         if let Some(ref val) = self.vocabulary_filter_names {
             ser.write_string(&STARTSTREAMTRANSCRIPTIONOUTPUT_MEMBER_VOCABULARY_FILTER_NAMES, val)?;
-548
+        }
         Ok(())
-550
+    }
-551
+}
 impl StartStreamTranscriptionOutput {
     /// Deserializes this structure from a [`ShapeDeserializer`].
     pub fn deserialize<D: ::aws_smithy_schema::serde::ShapeDeserializer>(
         deserializer: &mut D,
     pub fn deserialize(
         deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
     ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
         #[allow(unused_variables, unused_mut)]
         let mut builder = Self::builder();
         #[allow(
             unused_variables,
             unreachable_code,
             clippy::single_match,
             clippy::match_single_binding,
             clippy::diverging_sub_expression
         )]
         deserializer.read_struct(&STARTSTREAMTRANSCRIPTIONOUTPUT_SCHEMA, (), |_, member, deser| {
         deserializer.read_struct(&STARTSTREAMTRANSCRIPTIONOUTPUT_SCHEMA, &mut |member, deser| {
             match member.member_index() {
                 Some(0) => {
                     builder.request_id = Some(deser.read_string(member)?);
-570
+                }
                 Some(1) => {
                     builder.language_code = Some(crate::types::LanguageCode::from(deser.read_string(member)?.as_str()));
-573
+                }
                 Some(2) => {
                     builder.media_sample_rate_hertz = Some(deser.read_integer(member)?);
-576
+                }
                 Some(3) => {
                     builder.media_encoding = Some(crate::types::MediaEncoding::from(deser.read_string(member)?.as_str()));
-579
+                }
                 Some(4) => {
                     builder.vocabulary_name = Some(deser.read_string(member)?);
-582
+                }
                 Some(5) => {
                     builder.session_id = Some(deser.read_string(member)?);
-585
+                }
                 Some(6) => {
                     builder.transcript_result_stream = Some({
                         let _ = member;
                         todo!("deserialize aggregate")
                         todo!("deserialize streaming union")
                     });
-591
+                }
                 Some(7) => {
                     builder.vocabulary_filter_name = Some(deser.read_string(member)?);
-594
+                }
                 Some(8) => {
                     builder.vocabulary_filter_method = Some(crate::types::VocabularyFilterMethod::from(deser.read_string(member)?.as_str()));
-597
+                }
                 Some(9) => {
                     builder.show_speaker_label = Some(deser.read_boolean(member)?);
-600
+                }
                 Some(10) => {
                     builder.enable_channel_identification = Some(deser.read_boolean(member)?);
-603
+                }
                 Some(11) => {
                     builder.number_of_channels = Some(deser.read_integer(member)?);
-606
+                }
                 Some(12) => {
                     builder.enable_partial_results_stabilization = Some(deser.read_boolean(member)?);
-609
+                }
                 Some(13) => {
                     builder.partial_results_stability = Some(crate::types::PartialResultsStability::from(deser.read_string(member)?.as_str()));
-612
+                }
                 Some(14) => {
                     builder.content_identification_type = Some(crate::types::ContentIdentificationType::from(deser.read_string(member)?.as_str()));
-615
+                }
                 Some(15) => {
                     builder.content_redaction_type = Some(crate::types::ContentRedactionType::from(deser.read_string(member)?.as_str()));
-618
+                }
                 Some(16) => {
                     builder.pii_entity_types = Some(deser.read_string(member)?);
-621
+                }
                 Some(17) => {
                     builder.language_model_name = Some(deser.read_string(member)?);
-624
+                }
                 Some(18) => {
                     builder.identify_language = Some(deser.read_boolean(member)?);
-627
+                }
                 Some(19) => {
                     builder.language_options = Some(deser.read_string(member)?);
-630
+                }
                 Some(20) => {
                     builder.preferred_language = Some(crate::types::LanguageCode::from(deser.read_string(member)?.as_str()));
-633
+                }
                 Some(21) => {
                     builder.identify_multiple_languages = Some(deser.read_boolean(member)?);
-636
+                }
                 Some(22) => {
                     builder.vocabulary_names = Some(deser.read_string(member)?);
-639
+                }
                 Some(23) => {
                     builder.vocabulary_filter_names = Some(deser.read_string(member)?);
-642
+                }
                 Some(24) => {
                     builder._request_id = Some(deser.read_string(member)?);
-+
+                }
                 _ => {}
-+
+            }
             Ok(())
         })?;
         builder
             .build()
             .map_err(|e| aws_smithy_schema::serde::SerdeError::Custom { message: e.to_string() })
-+
+    }
-+
+}
 impl StartStreamTranscriptionOutput {
     /// Deserializes this structure from a body deserializer and HTTP response headers.
     /// Header-bound members are read directly from headers, avoiding runtime
     /// member iteration overhead. Body members are read via the deserializer.
     pub fn deserialize_with_response(
         deserializer: &mut dyn ::aws_smithy_schema::serde::ShapeDeserializer,
         headers: &::aws_smithy_runtime_api::http::Headers,
         _status: u16,
         _body: &[u8],
     ) -> ::std::result::Result<Self, ::aws_smithy_schema::serde::SerdeError> {
         #[allow(unused_variables, unused_mut)]
         let mut builder = Self::builder();
         if let Some(val) = headers.get("x-amzn-request-id") {
             builder.request_id = Some(val.to_string());
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-language-code") {
             builder.language_code = Some(crate::types::LanguageCode::from(val));
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-sample-rate") {
             builder.media_sample_rate_hertz = val.parse::<i32>().ok();
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-media-encoding") {
             builder.media_encoding = Some(crate::types::MediaEncoding::from(val));
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-vocabulary-name") {
             builder.vocabulary_name = Some(val.to_string());
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-session-id") {
             builder.session_id = Some(val.to_string());
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-vocabulary-filter-name") {
             builder.vocabulary_filter_name = Some(val.to_string());
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-vocabulary-filter-method") {
             builder.vocabulary_filter_method = Some(crate::types::VocabularyFilterMethod::from(val));
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-show-speaker-label") {
             builder.show_speaker_label = val.parse::<bool>().ok();
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-enable-channel-identification") {
             builder.enable_channel_identification = val.parse::<bool>().ok();
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-number-of-channels") {
             builder.number_of_channels = val.parse::<i32>().ok();
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-enable-partial-results-stabilization") {
             builder.enable_partial_results_stabilization = val.parse::<bool>().ok();
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-partial-results-stability") {
             builder.partial_results_stability = Some(crate::types::PartialResultsStability::from(val));
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-content-identification-type") {
             builder.content_identification_type = Some(crate::types::ContentIdentificationType::from(val));
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-content-redaction-type") {
             builder.content_redaction_type = Some(crate::types::ContentRedactionType::from(val));
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-pii-entity-types") {
             builder.pii_entity_types = Some(val.to_string());
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-language-model-name") {
             builder.language_model_name = Some(val.to_string());
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-identify-language") {
             builder.identify_language = val.parse::<bool>().ok();
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-language-options") {
             builder.language_options = Some(val.to_string());
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-preferred-language") {
             builder.preferred_language = Some(crate::types::LanguageCode::from(val));
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-identify-multiple-languages") {
             builder.identify_multiple_languages = val.parse::<bool>().ok();
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-vocabulary-names") {
             builder.vocabulary_names = Some(val.to_string());
-+
+        }
         if let Some(val) = headers.get("x-amzn-transcribe-vocabulary-filter-names") {
             builder.vocabulary_filter_names = Some(val.to_string());
-+
+        }
         if let Some(val) = headers.get("x-amzn-requestid") {
             builder._request_id = Some(val.to_string());
-+
+        }
         #[allow(
             unused_variables,
             unreachable_code,
             clippy::single_match,
             clippy::match_single_binding,
             clippy::diverging_sub_expression
         )]
         deserializer.read_struct(&STARTSTREAMTRANSCRIPTIONOUTPUT_SCHEMA, &mut |member, deser| {
             match member.member_index() {
                 Some(0) => { /* read from headers above */ }
                 Some(1) => { /* read from headers above */ }
                 Some(2) => { /* read from headers above */ }
                 Some(3) => { /* read from headers above */ }
                 Some(4) => { /* read from headers above */ }
                 Some(5) => { /* read from headers above */ }
                 Some(6) => {
                     builder.transcript_result_stream = Some({
                         let _ = member;
                         todo!("deserialize streaming union")
                     });
-+
+                }
                 Some(7) => { /* read from headers above */ }
                 Some(8) => { /* read from headers above */ }
                 Some(9) => { /* read from headers above */ }
                 Some(10) => { /* read from headers above */ }
                 Some(11) => { /* read from headers above */ }
                 Some(12) => { /* read from headers above */ }
                 Some(13) => { /* read from headers above */ }
                 Some(14) => { /* read from headers above */ }
                 Some(15) => { /* read from headers above */ }
                 Some(16) => { /* read from headers above */ }
                 Some(17) => { /* read from headers above */ }
                 Some(18) => { /* read from headers above */ }
                 Some(19) => { /* read from headers above */ }
                 Some(20) => { /* read from headers above */ }
                 Some(21) => { /* read from headers above */ }
                 Some(22) => { /* read from headers above */ }
                 Some(23) => { /* read from headers above */ }
                 _ => {}
-778
+            }
             Ok(())
         })?;
         builder
             .build()
             .map_err(|e| aws_smithy_schema::serde::SerdeError::Custom { message: e.to_string() })
-784
+    }
-785
+}
 impl ::aws_types::request_id::RequestId for StartStreamTranscriptionOutput {

↧ Expand context

     fn request_id(&self) -> Option<&str> {
         self._request_id.as_deref()
-789
+    }
-790
+}
 impl StartStreamTranscriptionOutput {
     /// Creates a new builder-style object to manufacture [`StartStreamTranscriptionOutput`](crate::operation::start_stream_transcription::StartStreamTranscriptionOutput).
     pub fn builder() -> crate::operation::start_stream_transcription::builders::StartStreamTranscriptionOutputBuilder {
         crate::operation::start_stream_transcription::builders::StartStreamTranscriptionOutputBuilder::default()
-795
+    }
-796
+}
-797
 /// A builder for [`StartStreamTranscriptionOutput`](crate::operation::start_stream_transcription::StartStreamTranscriptionOutput).
 #[derive(::std::default::Default, ::std::fmt::Debug)]
 #[non_exhaustive]
 pub struct StartStreamTranscriptionOutputBuilder {
     pub(crate) request_id: ::std::option::Option<::std::string::String>,
     pub(crate) language_code: ::std::option::Option<crate::types::LanguageCode>,
     pub(crate) media_sample_rate_hertz: ::std::option::Option<i32>,
     pub(crate) media_encoding: ::std::option::Option<crate::types::MediaEncoding>,
     pub(crate) vocabulary_name: ::std::option::Option<::std::string::String>,

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

@@ -1,1 +143,129 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub fn parse_http_error_metadata(
     _response_status: u16,
     response_headers: &::aws_smithy_runtime_api::http::Headers,
     response_body: &[u8],
 ) -> ::std::result::Result<::aws_smithy_types::error::metadata::Builder, ::aws_smithy_json::deserialize::error::DeserializeError> {
     crate::json_errors::parse_error_metadata(response_body, response_headers)
-+
+}
-+
 pub(crate) fn type_erase_result<O, E>(
     result: ::std::result::Result<O, E>,
 ) -> ::std::result::Result<
     ::aws_smithy_runtime_api::client::interceptors::context::Output,
     ::aws_smithy_runtime_api::client::orchestrator::OrchestratorError<::aws_smithy_runtime_api::client::interceptors::context::Error>,
-15
+>
 where
     O: ::std::fmt::Debug + ::std::marker::Send + ::std::marker::Sync + 'static,
     E: ::std::error::Error + std::fmt::Debug + ::std::marker::Send + ::std::marker::Sync + 'static,
-19
+{
     result
         .map(|output| ::aws_smithy_runtime_api::client::interceptors::context::Output::erase(output))
         .map_err(|error| ::aws_smithy_runtime_api::client::interceptors::context::Error::erase(error))
         .map_err(::std::convert::Into::into)
-24
+}
-25
 pub fn parse_http_error_metadata(
     _response_status: u16,
     response_headers: &::aws_smithy_runtime_api::http::Headers,
     response_body: &[u8],
 ) -> ::std::result::Result<::aws_smithy_types::error::metadata::Builder, ::aws_smithy_json::deserialize::error::DeserializeError> {
     crate::json_errors::parse_error_metadata(response_body, response_headers)
--
+}
--
 pub(crate) mod shape_get_medical_scribe_stream;
--
 pub(crate) mod shape_start_call_analytics_stream_transcription;
-27
 pub(crate) mod shape_start_medical_scribe_stream;
-29
 pub(crate) mod shape_start_medical_stream_transcription;
-31
 pub(crate) mod shape_start_stream_transcription;
-33
 pub(crate) mod shape_audio_stream;
-35
 pub(crate) fn or_empty_doc(data: &[u8]) -> &[u8] {
     if data.is_empty() {
         b"{}"
     } else {
         data
--
+    }
--
+}
--
 pub(crate) mod shape_bad_request_exception;
--
 pub(crate) mod shape_conflict_exception;
--
 pub(crate) mod shape_internal_failure_exception;
--
 pub(crate) mod shape_limit_exceeded_exception;
--
 pub(crate) mod shape_medical_scribe_input_stream;
-37
 pub(crate) mod shape_resource_not_found_exception;
--
 pub(crate) mod shape_service_unavailable_exception;
--
 pub(crate) mod shape_start_call_analytics_stream_transcription_output;
-39
 pub(crate) mod shape_start_medical_scribe_stream_output;
-41
 pub(crate) mod shape_start_medical_stream_transcription_output;
-43
 pub(crate) mod shape_start_stream_transcription_output;
-45
 pub fn parse_event_stream_error_metadata(
     payload: &::bytes::Bytes,
 ) -> ::std::result::Result<::aws_smithy_types::error::metadata::Builder, ::aws_smithy_json::deserialize::error::DeserializeError> {
     crate::json_errors::parse_error_metadata(payload, &::aws_smithy_runtime_api::http::Headers::new())
-50
+}
-51
 pub(crate) mod shape_configuration_event;
-53
 pub(crate) mod shape_medical_scribe_configuration_event;
-55
 pub(crate) mod shape_medical_scribe_session_control_event;
-57
 pub(crate) mod shape_medical_scribe_stream_details;
 pub(crate) fn or_empty_doc(data: &[u8]) -> &[u8] {
     if data.is_empty() {
         b"{}"
     } else {
         data
-+
+    }
-+
+}
-+
 pub(crate) mod shape_bad_request_exception;
-67
 pub(crate) mod shape_category_event;
-69
 pub(crate) mod shape_channel_definition;
-71
 pub(crate) mod shape_medical_scribe_channel_definition;
 pub(crate) mod shape_conflict_exception;
-+
 pub(crate) mod shape_internal_failure_exception;
-+
 pub(crate) mod shape_limit_exceeded_exception;
-77
 pub(crate) mod shape_medical_scribe_channel_definitions;
 pub(crate) mod shape_medical_scribe_channel_definition;
-79
 pub(crate) mod shape_medical_scribe_context;
-81
 pub(crate) mod shape_medical_scribe_encryption_settings;
-83
 pub(crate) mod shape_medical_scribe_post_stream_analytics_result;
--
 pub(crate) mod shape_medical_scribe_post_stream_analytics_settings;
-85
 pub(crate) mod shape_medical_scribe_transcript_event;
-87
 pub(crate) mod shape_medical_transcript_event;
-89
 pub(crate) mod shape_post_call_analytics_settings;
-91
 pub(crate) mod shape_service_unavailable_exception;
-+
 pub(crate) mod shape_transcript_event;
-95
 pub(crate) mod shape_utterance_event;
-97
 pub(crate) mod shape_clinical_note_generation_result;
--
 pub(crate) mod shape_clinical_note_generation_settings;
-99
 pub(crate) mod shape_kms_encryption_context_map;
--
 pub(crate) mod shape_medical_scribe_patient_context;
-101
 pub(crate) mod shape_call_analytics_entity_list;
-103
 pub(crate) mod shape_call_analytics_item_list;
-105
 pub(crate) mod shape_call_analytics_language_identification;
-107
 pub(crate) mod shape_issues_detected;
-109

↧ Expand context

 pub(crate) mod shape_matched_category_details;
-111
 pub(crate) mod shape_medical_scribe_transcript_segment;
-113
 pub(crate) mod shape_medical_transcript;
-115
 pub(crate) mod shape_string_list;
-117
 pub(crate) mod shape_transcript;
-119
 pub(crate) mod shape_call_analytics_entity;
-121
 pub(crate) mod shape_call_analytics_item;
-123
 pub(crate) mod shape_call_analytics_language_with_score;
-125
 pub(crate) mod shape_issue_detected;
-127
 pub(crate) mod shape_medical_result_list;
-129

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

@@ -1,0 +61,0 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub(crate) fn de_clinical_note_generation_result<'a, I>(
     tokens: &mut ::std::iter::Peekable<I>,
     _value: &'a [u8],
 ) -> ::std::result::Result<Option<crate::types::ClinicalNoteGenerationResult>, ::aws_smithy_json::deserialize::error::DeserializeError>
 where
     I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
--
+{
     match tokens.next().transpose()? {
         Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
         Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
             #[allow(unused_mut)]
             let mut builder = crate::types::builders::ClinicalNoteGenerationResultBuilder::default();
             loop {
                 match tokens.next().transpose()? {
                     Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
                     Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
                         "ClinicalNoteOutputLocation" => {
                             builder = builder.set_clinical_note_output_location(
                                 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                                     .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                                     .transpose()?,
                             );
--
+                        }
                         "TranscriptOutputLocation" => {
                             builder = builder.set_transcript_output_location(
                                 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                                     .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                                     .transpose()?,
                             );
--
+                        }
                         "Status" => {
                             builder = builder.set_status(
                                 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                                     .map(|s| s.to_unescaped().map(|u| crate::types::ClinicalNoteGenerationStatus::from(u.as_ref())))
                                     .transpose()?,
                             );
--
+                        }
                         "FailureReason" => {
                             builder = builder.set_failure_reason(
                                 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                                     .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                                     .transpose()?,
                             );
--
+                        }
                         _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
                     },
                     other => {
                         return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
                             "expected object key or end object, found: {other:?}"
                         )))
--
+                    }
--
+                }
--
+            }
             Ok(Some(builder.build()))
--
+        }
         _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
             "expected start object or null",
         )),
--
+    }
--
+}

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

@@ -1,1 +64,0 @@

↥ Expand context

1 1	`// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.`
2 2	`pub fn ser_clinical_note_generation_settings(`
3 3	`object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,`

     input: &crate::types::ClinicalNoteGenerationSettings,
 ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
-6
+    {
         object.key("OutputBucketName").string(input.output_bucket_name.as_str());
-8
+    }
     if let Some(var_1) = &input.note_template {
         object.key("NoteTemplate").string(var_1.as_str());
-11
+    }
     Ok(())
-13
+}
--
 pub(crate) fn de_clinical_note_generation_settings<'a, I>(
     tokens: &mut ::std::iter::Peekable<I>,
     _value: &'a [u8],
 ) -> ::std::result::Result<Option<crate::types::ClinicalNoteGenerationSettings>, ::aws_smithy_json::deserialize::error::DeserializeError>
 where
     I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
--
+{
     match tokens.next().transpose()? {
         Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
         Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
             #[allow(unused_mut)]
             let mut builder = crate::types::builders::ClinicalNoteGenerationSettingsBuilder::default();
             loop {
                 match tokens.next().transpose()? {
                     Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
                     Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
                         "OutputBucketName" => {
                             builder = builder.set_output_bucket_name(
                                 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                                     .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                                     .transpose()?,
                             );
--
+                        }
                         "NoteTemplate" => {
                             builder = builder.set_note_template(
                                 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                                     .map(|s| s.to_unescaped().map(|u| crate::types::MedicalScribeNoteTemplate::from(u.as_ref())))
                                     .transpose()?,
                             );
--
+                        }
                         _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
                     },
                     other => {
                         return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
                             "expected object key or end object, found: {other:?}"
                         )))
--
+                    }
--
+                }
--
+            }
             Ok(Some(
                 crate::serde_util::clinical_note_generation_settings_correct_errors(builder)
                     .build()
                     .map_err(|err| ::aws_smithy_json::deserialize::error::DeserializeError::custom_source("Response was invalid", err))?,
             ))
--
+        }
         _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
             "expected start object or null",
         )),
--
+    }
--
+}

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

@@ -1,0 +144,0 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub fn de_get_medical_scribe_stream_http_error(
     _response_status: u16,
     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<
     crate::operation::get_medical_scribe_stream::GetMedicalScribeStreamOutput,
     crate::operation::get_medical_scribe_stream::GetMedicalScribeStreamError,
 > {
     #[allow(unused_mut)]
     let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
         .map_err(crate::operation::get_medical_scribe_stream::GetMedicalScribeStreamError::unhandled)?;
     generic_builder = ::aws_types::request_id::apply_request_id(generic_builder, _response_headers);
     let generic = generic_builder.build();
     let error_code = match generic.code() {
         Some(code) => code,
         None => {
             return Err(crate::operation::get_medical_scribe_stream::GetMedicalScribeStreamError::unhandled(
                 generic,
             ))
--
+        }
     };
--
     let _error_message = generic.message().map(|msg| msg.to_owned());
     Err(match error_code {
         "BadRequestException" => crate::operation::get_medical_scribe_stream::GetMedicalScribeStreamError::BadRequestException({
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::BadRequestExceptionBuilder::default();
                 output = crate::protocol_serde::shape_bad_request_exception::de_bad_request_exception_json_err(_response_body, output)
                     .map_err(crate::operation::get_medical_scribe_stream::GetMedicalScribeStreamError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             if tmp.message.is_none() {
                 tmp.message = _error_message;
--
+            }
             tmp
         }),
         "InternalFailureException" => crate::operation::get_medical_scribe_stream::GetMedicalScribeStreamError::InternalFailureException({
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::InternalFailureExceptionBuilder::default();
                 output = crate::protocol_serde::shape_internal_failure_exception::de_internal_failure_exception_json_err(_response_body, output)
                     .map_err(crate::operation::get_medical_scribe_stream::GetMedicalScribeStreamError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             if tmp.message.is_none() {
                 tmp.message = _error_message;
--
+            }
             tmp
         }),
         "LimitExceededException" => crate::operation::get_medical_scribe_stream::GetMedicalScribeStreamError::LimitExceededException({
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::LimitExceededExceptionBuilder::default();
                 output = crate::protocol_serde::shape_limit_exceeded_exception::de_limit_exceeded_exception_json_err(_response_body, output)
                     .map_err(crate::operation::get_medical_scribe_stream::GetMedicalScribeStreamError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             if tmp.message.is_none() {
                 tmp.message = _error_message;
--
+            }
             tmp
         }),
         "ResourceNotFoundException" => crate::operation::get_medical_scribe_stream::GetMedicalScribeStreamError::ResourceNotFoundException({
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::ResourceNotFoundExceptionBuilder::default();
                 output = crate::protocol_serde::shape_resource_not_found_exception::de_resource_not_found_exception_json_err(_response_body, output)
                     .map_err(crate::operation::get_medical_scribe_stream::GetMedicalScribeStreamError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             if tmp.message.is_none() {
                 tmp.message = _error_message;
--
+            }
             tmp
         }),
         _ => crate::operation::get_medical_scribe_stream::GetMedicalScribeStreamError::generic(generic),
     })
--
+}
--
 #[allow(clippy::unnecessary_wraps)]
 pub fn de_get_medical_scribe_stream_http_response(
     _response_status: u16,
     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<
     crate::operation::get_medical_scribe_stream::GetMedicalScribeStreamOutput,
     crate::operation::get_medical_scribe_stream::GetMedicalScribeStreamError,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut output = crate::operation::get_medical_scribe_stream::builders::GetMedicalScribeStreamOutputBuilder::default();
         output = crate::protocol_serde::shape_get_medical_scribe_stream::de_get_medical_scribe_stream(_response_body, output)
             .map_err(crate::operation::get_medical_scribe_stream::GetMedicalScribeStreamError::unhandled)?;
         output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
         output.build()
     })
--
+}
--
 pub(crate) fn de_get_medical_scribe_stream(
     _value: &[u8],
     mut builder: crate::operation::get_medical_scribe_stream::builders::GetMedicalScribeStreamOutputBuilder,
 ) -> ::std::result::Result<
     crate::operation::get_medical_scribe_stream::builders::GetMedicalScribeStreamOutputBuilder,
     ::aws_smithy_json::deserialize::error::DeserializeError,
 > {
     let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(_value)).peekable();
     let tokens = &mut tokens_owned;
     ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
     loop {
         match tokens.next().transpose()? {
             Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
             Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
                 "MedicalScribeStreamDetails" => {
                     builder = builder.set_medical_scribe_stream_details(
                         crate::protocol_serde::shape_medical_scribe_stream_details::de_medical_scribe_stream_details(tokens, _value)?,
                     );
--
+                }
                 _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
             },
             other => {
                 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
                     "expected object key or end object, found: {other:?}"
                 )))
--
+            }
--
+        }
--
+    }
     if tokens.next().is_some() {
         return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
             "found more JSON tokens after completing parsing",
         ));
--
+    }
     Ok(builder)
--
+}

AWS SDK

Files changed:

tmp-codegen-diff/aws-sdk/sdk/transcribestreaming/src/operation/start_stream_transcription.rs

tmp-codegen-diff/aws-sdk/sdk/transcribestreaming/src/operation/start_stream_transcription/_start_stream_transcription_input.rs

tmp-codegen-diff/aws-sdk/sdk/transcribestreaming/src/operation/start_stream_transcription/_start_stream_transcription_output.rs

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

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

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

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

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

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

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub fn ser_medical_scribe_channel_definition(
     object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
     input: &crate::types::MedicalScribeChannelDefinition,
 ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
-6
+    {