Client Test

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/protocol_serde/shape_describe_time_to_live.rs

@@ -1,1 +134,196 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* RustType.kt:516 */
 #[allow(clippy::unnecessary_wraps)]
 /* ProtocolParserGenerator.kt:99 */
 pub fn de_describe_time_to_live_http_error(
     _response_status: u16,
     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<
     crate::operation::describe_time_to_live::DescribeTimeToLiveOutput,
     crate::operation::describe_time_to_live::DescribeTimeToLiveError,
 > {
     /* RustType.kt:516 */
     #[allow(unused_mut)]
     /* ProtocolParserGenerator.kt:106 */
     let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
         .map_err(crate::operation::describe_time_to_live::DescribeTimeToLiveError::unhandled)?;
     /* ProtocolParserGenerator.kt:120 */
     let generic = generic_builder.build();
     /* ProtocolParserGenerator.kt:122 */
     let error_code = match generic.code() {
         Some(code) => code,
         None => return Err(crate::operation::describe_time_to_live::DescribeTimeToLiveError::unhandled(generic)),
     };
-25
     let _error_message = generic.message().map(|msg| msg.to_owned());
     /* ProtocolParserGenerator.kt:133 */
     Err(match error_code {
         /* ProtocolParserGenerator.kt:139 */
         "InternalServerError" => crate::operation::describe_time_to_live::DescribeTimeToLiveError::InternalServerError({
             /* RustType.kt:516 */
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::InternalServerErrorBuilder::default();
                 output = crate::protocol_serde::shape_internal_server_error::de_internal_server_error_json_err(_response_body, output)
                     .map_err(crate::operation::describe_time_to_live::DescribeTimeToLiveError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             /* ProtocolParserGenerator.kt:145 */let mut tmp =
                 /* ProtocolParserGenerator.kt:146 */ {
                     /* RustType.kt:516 */#[allow(unused_mut)]
                     /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::InternalServerErrorBuilder::default();
                     /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_internal_server_error::de_internal_server_error_json_err(_response_body, output).map_err(crate::operation::describe_time_to_live::DescribeTimeToLiveError::unhandled)?;
                     /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
                     /* ClientBuilderInstantiator.kt:56 */output.build()
                 /* ProtocolParserGenerator.kt:146 */}
             /* ProtocolParserGenerator.kt:145 */;
             /* ProtocolParserGenerator.kt:170 */
             if tmp.message.is_none() {
                 tmp.message = _error_message;
-45
+            }
             /* ProtocolParserGenerator.kt:179 */
             tmp
             /* ProtocolParserGenerator.kt:139 */
         }),
         /* ProtocolParserGenerator.kt:139 */
         "InvalidEndpointException" => crate::operation::describe_time_to_live::DescribeTimeToLiveError::InvalidEndpointError({
             /* RustType.kt:516 */
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::InvalidEndpointErrorBuilder::default();
                 output = crate::protocol_serde::shape_invalid_endpoint_exception::de_invalid_endpoint_exception_json_err(_response_body, output)
                     .map_err(crate::operation::describe_time_to_live::DescribeTimeToLiveError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             /* ProtocolParserGenerator.kt:145 */let mut tmp =
                 /* ProtocolParserGenerator.kt:146 */ {
                     /* RustType.kt:516 */#[allow(unused_mut)]
                     /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::InvalidEndpointErrorBuilder::default();
                     /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_invalid_endpoint_exception::de_invalid_endpoint_exception_json_err(_response_body, output).map_err(crate::operation::describe_time_to_live::DescribeTimeToLiveError::unhandled)?;
                     /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
                     /* ClientBuilderInstantiator.kt:56 */output.build()
                 /* ProtocolParserGenerator.kt:146 */}
             /* ProtocolParserGenerator.kt:145 */;
             /* ProtocolParserGenerator.kt:170 */
             if tmp.message.is_none() {
                 tmp.message = _error_message;
-66
+            }
             /* ProtocolParserGenerator.kt:179 */
             tmp
             /* ProtocolParserGenerator.kt:139 */
         }),
         /* ProtocolParserGenerator.kt:139 */
         "ResourceNotFoundException" => crate::operation::describe_time_to_live::DescribeTimeToLiveError::ResourceNotFoundError({
             /* RustType.kt:516 */
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::ResourceNotFoundErrorBuilder::default();
                 output = crate::protocol_serde::shape_resource_not_found_exception::de_resource_not_found_exception_json_err(_response_body, output)
                     .map_err(crate::operation::describe_time_to_live::DescribeTimeToLiveError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             /* ProtocolParserGenerator.kt:145 */let mut tmp =
                 /* ProtocolParserGenerator.kt:146 */ {
                     /* RustType.kt:516 */#[allow(unused_mut)]
                     /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::ResourceNotFoundErrorBuilder::default();
                     /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_resource_not_found_exception::de_resource_not_found_exception_json_err(_response_body, output).map_err(crate::operation::describe_time_to_live::DescribeTimeToLiveError::unhandled)?;
                     /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
                     /* ClientBuilderInstantiator.kt:56 */output.build()
                 /* ProtocolParserGenerator.kt:146 */}
             /* ProtocolParserGenerator.kt:145 */;
             /* ProtocolParserGenerator.kt:170 */
             if tmp.message.is_none() {
                 tmp.message = _error_message;
-87
+            }
             /* ProtocolParserGenerator.kt:179 */
             tmp
             /* ProtocolParserGenerator.kt:139 */
         }),
         _ => crate::operation::describe_time_to_live::DescribeTimeToLiveError::generic(generic),
         /* ProtocolParserGenerator.kt:182 */
         _ => crate::operation::describe_time_to_live::DescribeTimeToLiveError::generic(generic), /* ProtocolParserGenerator.kt:133 */
     })
     /* ProtocolParserGenerator.kt:99 */
-96
+}
-97
 /* RustType.kt:516 */
 #[allow(clippy::unnecessary_wraps)]
 /* ProtocolParserGenerator.kt:71 */
 pub fn de_describe_time_to_live_http_response(
     _response_status: u16,
     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<
     crate::operation::describe_time_to_live::DescribeTimeToLiveOutput,
     crate::operation::describe_time_to_live::DescribeTimeToLiveError,
 > {
     /* ProtocolParserGenerator.kt:77 */
     Ok({
         /* RustType.kt:516 */
         #[allow(unused_mut)]
         /* ProtocolParserGenerator.kt:240 */
         let mut output = crate::operation::describe_time_to_live::builders::DescribeTimeToLiveOutputBuilder::default();
         /* ProtocolParserGenerator.kt:247 */
         output = crate::protocol_serde::shape_describe_time_to_live::de_describe_time_to_live(_response_body, output)
             .map_err(crate::operation::describe_time_to_live::DescribeTimeToLiveError::unhandled)?;
         /* ClientBuilderInstantiator.kt:56 */
         output.build()
         /* ProtocolParserGenerator.kt:77 */
     })
     /* ProtocolParserGenerator.kt:71 */
-123
+}
-124
 /* JsonSerializerGenerator.kt:287 */
 pub fn ser_describe_time_to_live_input(
     input: &crate::operation::describe_time_to_live::DescribeTimeToLiveInput,
 ) -> ::std::result::Result<::aws_smithy_types::body::SdkBody, ::aws_smithy_types::error::operation::SerializationError> {
     /* JsonSerializerGenerator.kt:291 */
     let mut out = String::new();
     /* JsonSerializerGenerator.kt:292 */
     let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
     /* JsonSerializerGenerator.kt:375 */
     crate::protocol_serde::shape_describe_time_to_live_input::ser_describe_time_to_live_input_input(&mut object, input)?;
     /* JsonSerializerGenerator.kt:295 */
     object.finish();
     /* JsonSerializerGenerator.kt:296 */
     Ok(::aws_smithy_types::body::SdkBody::from(out))
     /* JsonSerializerGenerator.kt:287 */
-140
+}
-141
 /* JsonParserGenerator.kt:148 */
 pub(crate) fn de_describe_time_to_live(
     value: &[u8],
     mut builder: crate::operation::describe_time_to_live::builders::DescribeTimeToLiveOutputBuilder,
 ) -> ::std::result::Result<
     crate::operation::describe_time_to_live::builders::DescribeTimeToLiveOutputBuilder,
     ::aws_smithy_json::deserialize::error::DeserializeError,
 > {
     /* JsonParserGenerator.kt:153 */
     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())?;
     /* JsonParserGenerator.kt:684 */
     loop {
         /* JsonParserGenerator.kt:685 */
         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() {
                 "TimeToLiveDescription" => {
                     builder = builder.set_time_to_live_description(
                         crate::protocol_serde::shape_time_to_live_description::de_time_to_live_description(tokens)?,
                     );
             /* JsonParserGenerator.kt:686 */ Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
             Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
                 /* JsonParserGenerator.kt:260 */
                 match key.to_unescaped()?.as_ref() {
                     /* JsonParserGenerator.kt:262 */
                     "TimeToLiveDescription" => {
                         /* JsonParserGenerator.kt:265 */
                         builder = builder.set_time_to_live_description(
                             /* JsonParserGenerator.kt:544 */crate::protocol_serde::shape_time_to_live_description::de_time_to_live_description(tokens)?
                         /* JsonParserGenerator.kt:265 */);
                         /* JsonParserGenerator.kt:262 */
-+
+                    }
                     /* JsonParserGenerator.kt:290 */
                     _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?, /* JsonParserGenerator.kt:260 */
-172
+                }
                 _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
             },
                 /* JsonParserGenerator.kt:686 */
-+
+            }
             /* JsonParserGenerator.kt:695 */
             other => {
                 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
                     "expected object key or end object, found: {:?}",
                     other
                 )))
--
+            }
             } /* JsonParserGenerator.kt:685 */
-182
+        }
         /* JsonParserGenerator.kt:684 */
-184
+    }
     /* JsonParserGenerator.kt:250 */
     if tokens.next().is_some() {
         /* JsonParserGenerator.kt:251 */
         return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
             "found more JSON tokens after completing parsing",
         ));
         /* JsonParserGenerator.kt:250 */
-192
+    }
     /* JsonParserGenerator.kt:163 */
     Ok(builder)
     /* JsonParserGenerator.kt:148 */
-196
+}

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/protocol_serde/shape_describe_time_to_live_input.rs

@@ -1,1 +10,16 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonSerializerGenerator.kt:358 */
 pub fn ser_describe_time_to_live_input_input(
     object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
     input: &crate::operation::describe_time_to_live::DescribeTimeToLiveInput,
 ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
     /* JsonSerializerGenerator.kt:382 */
     if let Some(var_1) = &input.table_name {
         /* JsonSerializerGenerator.kt:423 */
         object.key("TableName").string(var_1.as_str());
         /* JsonSerializerGenerator.kt:382 */
-12
+    }
     /* JsonSerializerGenerator.kt:372 */
     Ok(())
     /* JsonSerializerGenerator.kt:358 */
-16
+}

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/protocol_serde/shape_disable_kinesis_streaming_destination.rs

@@ -1,1 +195,286 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* RustType.kt:516 */
 #[allow(clippy::unnecessary_wraps)]
 /* ProtocolParserGenerator.kt:99 */
 pub fn de_disable_kinesis_streaming_destination_http_error(
     _response_status: u16,
     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<
     crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationOutput,
     crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError,
 > {
     /* RustType.kt:516 */
     #[allow(unused_mut)]
     /* ProtocolParserGenerator.kt:106 */
     let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
         .map_err(crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError::unhandled)?;
     /* ProtocolParserGenerator.kt:120 */
     let generic = generic_builder.build();
     /* ProtocolParserGenerator.kt:122 */
     let error_code = match generic.code() {
         Some(code) => code,
         None => return Err(crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError::unhandled(generic)),
     };
-25
     let _error_message = generic.message().map(|msg| msg.to_owned());
     /* ProtocolParserGenerator.kt:133 */
     Err(match error_code {
         /* ProtocolParserGenerator.kt:139 */
         "InternalServerError" => {
             crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError::InternalServerError({
                 /* RustType.kt:516 */
                 #[allow(unused_mut)]
                 let mut tmp = {
                     #[allow(unused_mut)]
                     let mut output = crate::types::error::builders::InternalServerErrorBuilder::default();
                     output = crate::protocol_serde::shape_internal_server_error::de_internal_server_error_json_err(_response_body, output)
                         .map_err(crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError::unhandled)?;
                     let output = output.meta(generic);
                     output.build()
                 };
             /* ProtocolParserGenerator.kt:145 */let mut tmp =
                 /* ProtocolParserGenerator.kt:146 */ {
                     /* RustType.kt:516 */#[allow(unused_mut)]
                     /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::InternalServerErrorBuilder::default();
                     /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_internal_server_error::de_internal_server_error_json_err(_response_body, output).map_err(crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError::unhandled)?;
                     /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
                     /* ClientBuilderInstantiator.kt:56 */output.build()
                 /* ProtocolParserGenerator.kt:146 */}
             /* ProtocolParserGenerator.kt:145 */;
                 /* ProtocolParserGenerator.kt:170 */
                 if tmp.message.is_none() {
                     tmp.message = _error_message;
-46
+                }
                 /* ProtocolParserGenerator.kt:179 */
                 tmp
                 /* ProtocolParserGenerator.kt:139 */
             })
-51
+        }
         /* ProtocolParserGenerator.kt:139 */
         "InvalidEndpointException" => {
             crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError::InvalidEndpointError({
                 /* RustType.kt:516 */
                 #[allow(unused_mut)]
                 let mut tmp = {
                     #[allow(unused_mut)]
                     let mut output = crate::types::error::builders::InvalidEndpointErrorBuilder::default();
                     output = crate::protocol_serde::shape_invalid_endpoint_exception::de_invalid_endpoint_exception_json_err(_response_body, output)
                         .map_err(crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError::unhandled)?;
                     let output = output.meta(generic);
                     output.build()
                 };
             /* ProtocolParserGenerator.kt:145 */let mut tmp =
                 /* ProtocolParserGenerator.kt:146 */ {
                     /* RustType.kt:516 */#[allow(unused_mut)]
                     /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::InvalidEndpointErrorBuilder::default();
                     /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_invalid_endpoint_exception::de_invalid_endpoint_exception_json_err(_response_body, output).map_err(crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError::unhandled)?;
                     /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
                     /* ClientBuilderInstantiator.kt:56 */output.build()
                 /* ProtocolParserGenerator.kt:146 */}
             /* ProtocolParserGenerator.kt:145 */;
                 /* ProtocolParserGenerator.kt:170 */
                 if tmp.message.is_none() {
                     tmp.message = _error_message;
-69
+                }
                 /* ProtocolParserGenerator.kt:179 */
                 tmp
                 /* ProtocolParserGenerator.kt:139 */
             })
-74
+        }
         /* ProtocolParserGenerator.kt:139 */
         "LimitExceededException" => {
             crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError::LimitExceededError({
                 /* RustType.kt:516 */
                 #[allow(unused_mut)]
                 let mut tmp = {
                     #[allow(unused_mut)]
                     let mut output = crate::types::error::builders::LimitExceededErrorBuilder::default();
                     output = crate::protocol_serde::shape_limit_exceeded_exception::de_limit_exceeded_exception_json_err(_response_body, output)
                         .map_err(crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError::unhandled)?;
                     let output = output.meta(generic);
                     output.build()
                 };
             /* ProtocolParserGenerator.kt:145 */let mut tmp =
                 /* ProtocolParserGenerator.kt:146 */ {
                     /* RustType.kt:516 */#[allow(unused_mut)]
                     /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::LimitExceededErrorBuilder::default();
                     /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_limit_exceeded_exception::de_limit_exceeded_exception_json_err(_response_body, output).map_err(crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError::unhandled)?;
                     /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
                     /* ClientBuilderInstantiator.kt:56 */output.build()
                 /* ProtocolParserGenerator.kt:146 */}
             /* ProtocolParserGenerator.kt:145 */;
                 /* ProtocolParserGenerator.kt:170 */
                 if tmp.message.is_none() {
                     tmp.message = _error_message;
-92
+                }
                 /* ProtocolParserGenerator.kt:179 */
                 tmp
                 /* ProtocolParserGenerator.kt:139 */
             })
-97
+        }
         /* ProtocolParserGenerator.kt:139 */
         "ResourceInUseException" => {
             crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError::ResourceInUseError({
                 /* RustType.kt:516 */
                 #[allow(unused_mut)]
                 let mut tmp = {
                     #[allow(unused_mut)]
                     let mut output = crate::types::error::builders::ResourceInUseErrorBuilder::default();
                     output = crate::protocol_serde::shape_resource_in_use_exception::de_resource_in_use_exception_json_err(_response_body, output)
                         .map_err(crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError::unhandled)?;
                     let output = output.meta(generic);
                     output.build()
                 };
             /* ProtocolParserGenerator.kt:145 */let mut tmp =
                 /* ProtocolParserGenerator.kt:146 */ {
                     /* RustType.kt:516 */#[allow(unused_mut)]
                     /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::ResourceInUseErrorBuilder::default();
                     /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_resource_in_use_exception::de_resource_in_use_exception_json_err(_response_body, output).map_err(crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError::unhandled)?;
                     /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
                     /* ClientBuilderInstantiator.kt:56 */output.build()
                 /* ProtocolParserGenerator.kt:146 */}
             /* ProtocolParserGenerator.kt:145 */;
                 /* ProtocolParserGenerator.kt:170 */
                 if tmp.message.is_none() {
                     tmp.message = _error_message;
-115
+                }
                 /* ProtocolParserGenerator.kt:179 */
                 tmp
                 /* ProtocolParserGenerator.kt:139 */
             })
-120
+        }
         /* ProtocolParserGenerator.kt:139 */
         "ResourceNotFoundException" => {
             crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError::ResourceNotFoundError({
                 /* RustType.kt:516 */
                 #[allow(unused_mut)]
                 let mut tmp = {
                     #[allow(unused_mut)]
                     let mut output = crate::types::error::builders::ResourceNotFoundErrorBuilder::default();
                     output =
                         crate::protocol_serde::shape_resource_not_found_exception::de_resource_not_found_exception_json_err(_response_body, output)
                             .map_err(crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError::unhandled)?;
                     let output = output.meta(generic);
                     output.build()
                 };
             /* ProtocolParserGenerator.kt:145 */let mut tmp =
                 /* ProtocolParserGenerator.kt:146 */ {
                     /* RustType.kt:516 */#[allow(unused_mut)]
                     /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::ResourceNotFoundErrorBuilder::default();
                     /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_resource_not_found_exception::de_resource_not_found_exception_json_err(_response_body, output).map_err(crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError::unhandled)?;
                     /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
                     /* ClientBuilderInstantiator.kt:56 */output.build()
                 /* ProtocolParserGenerator.kt:146 */}
             /* ProtocolParserGenerator.kt:145 */;
                 /* ProtocolParserGenerator.kt:170 */
                 if tmp.message.is_none() {
                     tmp.message = _error_message;
-138
+                }
                 /* ProtocolParserGenerator.kt:179 */
                 tmp
                 /* ProtocolParserGenerator.kt:139 */
             })
-143
+        }
         _ => crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError::generic(generic),
         /* ProtocolParserGenerator.kt:182 */
         _ => crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError::generic(generic), /* ProtocolParserGenerator.kt:133 */
     })
     /* ProtocolParserGenerator.kt:99 */
-148
+}
-149
 /* RustType.kt:516 */
 #[allow(clippy::unnecessary_wraps)]
 /* ProtocolParserGenerator.kt:71 */
 pub fn de_disable_kinesis_streaming_destination_http_response(
     _response_status: u16,
     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<
     crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationOutput,
     crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError,
 > {
     /* ProtocolParserGenerator.kt:77 */
     Ok({
         /* RustType.kt:516 */
         #[allow(unused_mut)]
         /* ProtocolParserGenerator.kt:240 */
         let mut output =
             crate::operation::disable_kinesis_streaming_destination::builders::DisableKinesisStreamingDestinationOutputBuilder::default();
         /* ProtocolParserGenerator.kt:247 */
         output = crate::protocol_serde::shape_disable_kinesis_streaming_destination::de_disable_kinesis_streaming_destination(_response_body, output)
             .map_err(crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError::unhandled)?;
         /* ClientBuilderInstantiator.kt:56 */
         output.build()
         /* ProtocolParserGenerator.kt:77 */
     })
     /* ProtocolParserGenerator.kt:71 */
-176
+}
-177
 /* JsonSerializerGenerator.kt:287 */
 pub fn ser_disable_kinesis_streaming_destination_input(
     input: &crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationInput,
 ) -> ::std::result::Result<::aws_smithy_types::body::SdkBody, ::aws_smithy_types::error::operation::SerializationError> {
     /* JsonSerializerGenerator.kt:291 */
     let mut out = String::new();
     /* JsonSerializerGenerator.kt:292 */
     let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
     /* JsonSerializerGenerator.kt:375 */
     crate::protocol_serde::shape_disable_kinesis_streaming_destination_input::ser_disable_kinesis_streaming_destination_input_input(
         &mut object,
         input,
     )?;
     /* JsonSerializerGenerator.kt:295 */
     object.finish();
     /* JsonSerializerGenerator.kt:296 */
     Ok(::aws_smithy_types::body::SdkBody::from(out))
     /* JsonSerializerGenerator.kt:287 */
-196
+}
-197
 /* JsonParserGenerator.kt:148 */
 pub(crate) fn de_disable_kinesis_streaming_destination(
     value: &[u8],
     mut builder: crate::operation::disable_kinesis_streaming_destination::builders::DisableKinesisStreamingDestinationOutputBuilder,
 ) -> ::std::result::Result<
     crate::operation::disable_kinesis_streaming_destination::builders::DisableKinesisStreamingDestinationOutputBuilder,
     ::aws_smithy_json::deserialize::error::DeserializeError,
 > {
     /* JsonParserGenerator.kt:153 */
     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())?;
     /* JsonParserGenerator.kt:684 */
     loop {
         /* JsonParserGenerator.kt:685 */
         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() {
                 "TableName" => {
                     builder = builder.set_table_name(
                         ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                             .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                             .transpose()?,
                     );
             /* JsonParserGenerator.kt:686 */ Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
             Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
                 /* JsonParserGenerator.kt:260 */
                 match key.to_unescaped()?.as_ref() {
                     /* JsonParserGenerator.kt:262 */
                     "TableName" => {
                         /* JsonParserGenerator.kt:265 */
                         builder = builder.set_table_name(
                             /* JsonParserGenerator.kt:354 */
                             ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                                 .map(|s|
                                 /* JsonParserGenerator.kt:339 */s.to_unescaped().map(|u|
                                     /* JsonParserGenerator.kt:348 */u.into_owned()
                                 /* JsonParserGenerator.kt:339 */) /* JsonParserGenerator.kt:354 */)
                                 .transpose()?, /* JsonParserGenerator.kt:265 */
                         );
                         /* JsonParserGenerator.kt:262 */
-+
+                    }
                     /* JsonParserGenerator.kt:262 */
                     "StreamArn" => {
                         /* JsonParserGenerator.kt:265 */
                         builder = builder.set_stream_arn(
                             /* JsonParserGenerator.kt:354 */
                             ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                                 .map(|s|
                                 /* JsonParserGenerator.kt:339 */s.to_unescaped().map(|u|
                                     /* JsonParserGenerator.kt:348 */u.into_owned()
                                 /* JsonParserGenerator.kt:339 */) /* JsonParserGenerator.kt:354 */)
                                 .transpose()?, /* JsonParserGenerator.kt:265 */
                         );
                         /* JsonParserGenerator.kt:262 */
-+
+                    }
                     /* JsonParserGenerator.kt:262 */
                     "DestinationStatus" => {
                         /* JsonParserGenerator.kt:265 */
                         builder = builder.set_destination_status(
                             /* JsonParserGenerator.kt:354 */
                             ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                                 .map(|s|
                                 /* JsonParserGenerator.kt:339 */s.to_unescaped().map(|u|
                                     /* JsonParserGenerator.kt:345 */crate::types::DestinationStatus::from(u.as_ref())
                                 /* JsonParserGenerator.kt:339 */) /* JsonParserGenerator.kt:354 */)
                                 .transpose()?, /* JsonParserGenerator.kt:265 */
                         );
                         /* JsonParserGenerator.kt:262 */
-+
+                    }
                     /* JsonParserGenerator.kt:290 */
                     _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?, /* JsonParserGenerator.kt:260 */
-262
+                }
                 "StreamArn" => {
                     builder = builder.set_stream_arn(
                         ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                             .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                             .transpose()?,
                     );
--
+                }
                 "DestinationStatus" => {
                     builder = builder.set_destination_status(
                         ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                             .map(|s| s.to_unescaped().map(|u| crate::types::DestinationStatus::from(u.as_ref())))
                             .transpose()?,
                     );
--
+                }
                 _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
             },
                 /* JsonParserGenerator.kt:686 */
-+
+            }
             /* JsonParserGenerator.kt:695 */
             other => {
                 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
                     "expected object key or end object, found: {:?}",
                     other
                 )))
--
+            }
             } /* JsonParserGenerator.kt:685 */
-272
+        }
         /* JsonParserGenerator.kt:684 */
-274
+    }
     /* JsonParserGenerator.kt:250 */
     if tokens.next().is_some() {
         /* JsonParserGenerator.kt:251 */
         return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
             "found more JSON tokens after completing parsing",
         ));
         /* JsonParserGenerator.kt:250 */
-282
+    }
     /* JsonParserGenerator.kt:163 */
     Ok(builder)
     /* JsonParserGenerator.kt:148 */
-286
+}

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/protocol_serde/shape_disable_kinesis_streaming_destination_input.rs

@@ -1,1 +13,22 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonSerializerGenerator.kt:358 */
 pub fn ser_disable_kinesis_streaming_destination_input_input(
     object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
     input: &crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationInput,
 ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
     /* JsonSerializerGenerator.kt:382 */
     if let Some(var_1) = &input.table_name {
         /* JsonSerializerGenerator.kt:423 */
         object.key("TableName").string(var_1.as_str());
         /* JsonSerializerGenerator.kt:382 */
-12
+    }
     /* JsonSerializerGenerator.kt:382 */
     if let Some(var_2) = &input.stream_arn {
         /* JsonSerializerGenerator.kt:423 */
         object.key("StreamArn").string(var_2.as_str());
         /* JsonSerializerGenerator.kt:382 */
-18
+    }
     /* JsonSerializerGenerator.kt:372 */
     Ok(())
     /* JsonSerializerGenerator.kt:358 */
-22
+}

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/protocol_serde/shape_duplicate_item_exception.rs

@@ -1,1 +36,59 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonParserGenerator.kt:148 */
 pub(crate) fn de_duplicate_item_exception_json_err(
     value: &[u8],
     mut builder: crate::types::error::builders::DuplicateItemErrorBuilder,
 ) -> ::std::result::Result<crate::types::error::builders::DuplicateItemErrorBuilder, ::aws_smithy_json::deserialize::error::DeserializeError> {
     /* JsonParserGenerator.kt:153 */
     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())?;
     /* JsonParserGenerator.kt:684 */
     loop {
         /* JsonParserGenerator.kt:685 */
         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() {
                 "message" => {
                     builder = builder.set_message(
                         ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                             .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                             .transpose()?,
                     );
             /* JsonParserGenerator.kt:686 */ Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
             Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
                 /* JsonParserGenerator.kt:260 */
                 match key.to_unescaped()?.as_ref() {
                     /* JsonParserGenerator.kt:262 */
                     "message" => {
                         /* JsonParserGenerator.kt:265 */
                         builder = builder.set_message(
                             /* JsonParserGenerator.kt:354 */
                             ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                                 .map(|s|
                                 /* JsonParserGenerator.kt:339 */s.to_unescaped().map(|u|
                                     /* JsonParserGenerator.kt:348 */u.into_owned()
                                 /* JsonParserGenerator.kt:339 */) /* JsonParserGenerator.kt:354 */)
                                 .transpose()?, /* JsonParserGenerator.kt:265 */
                         );
                         /* JsonParserGenerator.kt:262 */
-+
+                    }
                     /* JsonParserGenerator.kt:290 */
                     _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?, /* JsonParserGenerator.kt:260 */
-35
+                }
                 _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
             },
                 /* JsonParserGenerator.kt:686 */
-+
+            }
             /* JsonParserGenerator.kt:695 */
             other => {
                 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
                     "expected object key or end object, found: {:?}",
                     other
                 )))
--
+            }
             } /* JsonParserGenerator.kt:685 */
-45
+        }
         /* JsonParserGenerator.kt:684 */
-47
+    }
     /* JsonParserGenerator.kt:250 */
     if tokens.next().is_some() {
         /* JsonParserGenerator.kt:251 */
         return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
             "found more JSON tokens after completing parsing",
         ));
         /* JsonParserGenerator.kt:250 */
-55
+    }
     /* JsonParserGenerator.kt:163 */
     Ok(builder)
     /* JsonParserGenerator.kt:148 */
-59
+}

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/protocol_serde/shape_enable_kinesis_streaming_destination.rs

@@ -1,1 +194,285 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* RustType.kt:516 */
 #[allow(clippy::unnecessary_wraps)]
 /* ProtocolParserGenerator.kt:99 */
 pub fn de_enable_kinesis_streaming_destination_http_error(
     _response_status: u16,
     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<
     crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationOutput,
     crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError,
 > {
     /* RustType.kt:516 */
     #[allow(unused_mut)]
     /* ProtocolParserGenerator.kt:106 */
     let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
         .map_err(crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError::unhandled)?;
     /* ProtocolParserGenerator.kt:120 */
     let generic = generic_builder.build();
     /* ProtocolParserGenerator.kt:122 */
     let error_code = match generic.code() {
         Some(code) => code,
         None => return Err(crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError::unhandled(generic)),
     };
-25
     let _error_message = generic.message().map(|msg| msg.to_owned());
     /* ProtocolParserGenerator.kt:133 */
     Err(match error_code {
         /* ProtocolParserGenerator.kt:139 */
         "InternalServerError" => {
             crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError::InternalServerError({
                 /* RustType.kt:516 */
                 #[allow(unused_mut)]
                 let mut tmp = {
                     #[allow(unused_mut)]
                     let mut output = crate::types::error::builders::InternalServerErrorBuilder::default();
                     output = crate::protocol_serde::shape_internal_server_error::de_internal_server_error_json_err(_response_body, output)
                         .map_err(crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError::unhandled)?;
                     let output = output.meta(generic);
                     output.build()
                 };
             /* ProtocolParserGenerator.kt:145 */let mut tmp =
                 /* ProtocolParserGenerator.kt:146 */ {
                     /* RustType.kt:516 */#[allow(unused_mut)]
                     /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::InternalServerErrorBuilder::default();
                     /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_internal_server_error::de_internal_server_error_json_err(_response_body, output).map_err(crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError::unhandled)?;
                     /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
                     /* ClientBuilderInstantiator.kt:56 */output.build()
                 /* ProtocolParserGenerator.kt:146 */}
             /* ProtocolParserGenerator.kt:145 */;
                 /* ProtocolParserGenerator.kt:170 */
                 if tmp.message.is_none() {
                     tmp.message = _error_message;
-46
+                }
                 /* ProtocolParserGenerator.kt:179 */
                 tmp
                 /* ProtocolParserGenerator.kt:139 */
             })
-51
+        }
         /* ProtocolParserGenerator.kt:139 */
         "InvalidEndpointException" => {
             crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError::InvalidEndpointError({
                 /* RustType.kt:516 */
                 #[allow(unused_mut)]
                 let mut tmp = {
                     #[allow(unused_mut)]
                     let mut output = crate::types::error::builders::InvalidEndpointErrorBuilder::default();
                     output = crate::protocol_serde::shape_invalid_endpoint_exception::de_invalid_endpoint_exception_json_err(_response_body, output)
                         .map_err(crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError::unhandled)?;
                     let output = output.meta(generic);
                     output.build()
                 };
             /* ProtocolParserGenerator.kt:145 */let mut tmp =
                 /* ProtocolParserGenerator.kt:146 */ {
                     /* RustType.kt:516 */#[allow(unused_mut)]
                     /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::InvalidEndpointErrorBuilder::default();
                     /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_invalid_endpoint_exception::de_invalid_endpoint_exception_json_err(_response_body, output).map_err(crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError::unhandled)?;
                     /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
                     /* ClientBuilderInstantiator.kt:56 */output.build()
                 /* ProtocolParserGenerator.kt:146 */}
             /* ProtocolParserGenerator.kt:145 */;
                 /* ProtocolParserGenerator.kt:170 */
                 if tmp.message.is_none() {
                     tmp.message = _error_message;
-69
+                }
                 /* ProtocolParserGenerator.kt:179 */
                 tmp
                 /* ProtocolParserGenerator.kt:139 */
             })
-74
+        }
         /* ProtocolParserGenerator.kt:139 */
         "LimitExceededException" => {
             crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError::LimitExceededError({
                 /* RustType.kt:516 */
                 #[allow(unused_mut)]
                 let mut tmp = {
                     #[allow(unused_mut)]
                     let mut output = crate::types::error::builders::LimitExceededErrorBuilder::default();
                     output = crate::protocol_serde::shape_limit_exceeded_exception::de_limit_exceeded_exception_json_err(_response_body, output)
                         .map_err(crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError::unhandled)?;
                     let output = output.meta(generic);
                     output.build()
                 };
             /* ProtocolParserGenerator.kt:145 */let mut tmp =
                 /* ProtocolParserGenerator.kt:146 */ {
                     /* RustType.kt:516 */#[allow(unused_mut)]
                     /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::LimitExceededErrorBuilder::default();
                     /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_limit_exceeded_exception::de_limit_exceeded_exception_json_err(_response_body, output).map_err(crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError::unhandled)?;
                     /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
                     /* ClientBuilderInstantiator.kt:56 */output.build()
                 /* ProtocolParserGenerator.kt:146 */}
             /* ProtocolParserGenerator.kt:145 */;
                 /* ProtocolParserGenerator.kt:170 */
                 if tmp.message.is_none() {
                     tmp.message = _error_message;
-92
+                }
                 /* ProtocolParserGenerator.kt:179 */
                 tmp
                 /* ProtocolParserGenerator.kt:139 */
             })
-97
+        }
         /* ProtocolParserGenerator.kt:139 */
         "ResourceInUseException" => {
             crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError::ResourceInUseError({
                 /* RustType.kt:516 */
                 #[allow(unused_mut)]
                 let mut tmp = {
                     #[allow(unused_mut)]
                     let mut output = crate::types::error::builders::ResourceInUseErrorBuilder::default();
                     output = crate::protocol_serde::shape_resource_in_use_exception::de_resource_in_use_exception_json_err(_response_body, output)
                         .map_err(crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError::unhandled)?;
                     let output = output.meta(generic);
                     output.build()
                 };
             /* ProtocolParserGenerator.kt:145 */let mut tmp =
                 /* ProtocolParserGenerator.kt:146 */ {
                     /* RustType.kt:516 */#[allow(unused_mut)]
                     /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::ResourceInUseErrorBuilder::default();
                     /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_resource_in_use_exception::de_resource_in_use_exception_json_err(_response_body, output).map_err(crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError::unhandled)?;
                     /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
                     /* ClientBuilderInstantiator.kt:56 */output.build()
                 /* ProtocolParserGenerator.kt:146 */}
             /* ProtocolParserGenerator.kt:145 */;
                 /* ProtocolParserGenerator.kt:170 */
                 if tmp.message.is_none() {
                     tmp.message = _error_message;
-115
+                }
                 /* ProtocolParserGenerator.kt:179 */
                 tmp
                 /* ProtocolParserGenerator.kt:139 */
             })
-120
+        }
         /* ProtocolParserGenerator.kt:139 */
         "ResourceNotFoundException" => {
             crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError::ResourceNotFoundError({
                 /* RustType.kt:516 */
                 #[allow(unused_mut)]
                 let mut tmp = {
                     #[allow(unused_mut)]
                     let mut output = crate::types::error::builders::ResourceNotFoundErrorBuilder::default();
                     output =
                         crate::protocol_serde::shape_resource_not_found_exception::de_resource_not_found_exception_json_err(_response_body, output)
                             .map_err(crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError::unhandled)?;
                     let output = output.meta(generic);
                     output.build()
                 };
             /* ProtocolParserGenerator.kt:145 */let mut tmp =
                 /* ProtocolParserGenerator.kt:146 */ {
                     /* RustType.kt:516 */#[allow(unused_mut)]
                     /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::ResourceNotFoundErrorBuilder::default();
                     /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_resource_not_found_exception::de_resource_not_found_exception_json_err(_response_body, output).map_err(crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError::unhandled)?;
                     /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
                     /* ClientBuilderInstantiator.kt:56 */output.build()
                 /* ProtocolParserGenerator.kt:146 */}
             /* ProtocolParserGenerator.kt:145 */;
                 /* ProtocolParserGenerator.kt:170 */
                 if tmp.message.is_none() {
                     tmp.message = _error_message;
-138
+                }
                 /* ProtocolParserGenerator.kt:179 */
                 tmp
                 /* ProtocolParserGenerator.kt:139 */
             })
-143
+        }
         _ => crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError::generic(generic),
         /* ProtocolParserGenerator.kt:182 */
         _ => crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError::generic(generic), /* ProtocolParserGenerator.kt:133 */
     })
     /* ProtocolParserGenerator.kt:99 */
-148
+}
-149
 /* RustType.kt:516 */
 #[allow(clippy::unnecessary_wraps)]
 /* ProtocolParserGenerator.kt:71 */
 pub fn de_enable_kinesis_streaming_destination_http_response(
     _response_status: u16,
     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<
     crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationOutput,
     crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError,
 > {
     /* ProtocolParserGenerator.kt:77 */
     Ok({
         /* RustType.kt:516 */
         #[allow(unused_mut)]
         /* ProtocolParserGenerator.kt:240 */
         let mut output = crate::operation::enable_kinesis_streaming_destination::builders::EnableKinesisStreamingDestinationOutputBuilder::default();
         /* ProtocolParserGenerator.kt:247 */
         output = crate::protocol_serde::shape_enable_kinesis_streaming_destination::de_enable_kinesis_streaming_destination(_response_body, output)
             .map_err(crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError::unhandled)?;
         /* ClientBuilderInstantiator.kt:56 */
         output.build()
         /* ProtocolParserGenerator.kt:77 */
     })
     /* ProtocolParserGenerator.kt:71 */
-175
+}
-176
 /* JsonSerializerGenerator.kt:287 */
 pub fn ser_enable_kinesis_streaming_destination_input(
     input: &crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationInput,
 ) -> ::std::result::Result<::aws_smithy_types::body::SdkBody, ::aws_smithy_types::error::operation::SerializationError> {
     /* JsonSerializerGenerator.kt:291 */
     let mut out = String::new();
     /* JsonSerializerGenerator.kt:292 */
     let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
     /* JsonSerializerGenerator.kt:375 */
     crate::protocol_serde::shape_enable_kinesis_streaming_destination_input::ser_enable_kinesis_streaming_destination_input_input(
         &mut object,
         input,
     )?;
     /* JsonSerializerGenerator.kt:295 */
     object.finish();
     /* JsonSerializerGenerator.kt:296 */
     Ok(::aws_smithy_types::body::SdkBody::from(out))
     /* JsonSerializerGenerator.kt:287 */
-195
+}
-196
 /* JsonParserGenerator.kt:148 */
 pub(crate) fn de_enable_kinesis_streaming_destination(
     value: &[u8],
     mut builder: crate::operation::enable_kinesis_streaming_destination::builders::EnableKinesisStreamingDestinationOutputBuilder,
 ) -> ::std::result::Result<
     crate::operation::enable_kinesis_streaming_destination::builders::EnableKinesisStreamingDestinationOutputBuilder,
     ::aws_smithy_json::deserialize::error::DeserializeError,
 > {
     /* JsonParserGenerator.kt:153 */
     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())?;
     /* JsonParserGenerator.kt:684 */
     loop {
         /* JsonParserGenerator.kt:685 */
         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() {
                 "TableName" => {
                     builder = builder.set_table_name(
                         ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                             .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                             .transpose()?,
                     );
             /* JsonParserGenerator.kt:686 */ Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
             Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
                 /* JsonParserGenerator.kt:260 */
                 match key.to_unescaped()?.as_ref() {
                     /* JsonParserGenerator.kt:262 */
                     "TableName" => {
                         /* JsonParserGenerator.kt:265 */
                         builder = builder.set_table_name(
                             /* JsonParserGenerator.kt:354 */
                             ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                                 .map(|s|
                                 /* JsonParserGenerator.kt:339 */s.to_unescaped().map(|u|
                                     /* JsonParserGenerator.kt:348 */u.into_owned()
                                 /* JsonParserGenerator.kt:339 */) /* JsonParserGenerator.kt:354 */)
                                 .transpose()?, /* JsonParserGenerator.kt:265 */
                         );
                         /* JsonParserGenerator.kt:262 */
-+
+                    }
                     /* JsonParserGenerator.kt:262 */
                     "StreamArn" => {
                         /* JsonParserGenerator.kt:265 */
                         builder = builder.set_stream_arn(
                             /* JsonParserGenerator.kt:354 */
                             ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                                 .map(|s|
                                 /* JsonParserGenerator.kt:339 */s.to_unescaped().map(|u|
                                     /* JsonParserGenerator.kt:348 */u.into_owned()
                                 /* JsonParserGenerator.kt:339 */) /* JsonParserGenerator.kt:354 */)
                                 .transpose()?, /* JsonParserGenerator.kt:265 */
                         );
                         /* JsonParserGenerator.kt:262 */
-+
+                    }
                     /* JsonParserGenerator.kt:262 */
                     "DestinationStatus" => {
                         /* JsonParserGenerator.kt:265 */
                         builder = builder.set_destination_status(
                             /* JsonParserGenerator.kt:354 */
                             ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                                 .map(|s|
                                 /* JsonParserGenerator.kt:339 */s.to_unescaped().map(|u|
                                     /* JsonParserGenerator.kt:345 */crate::types::DestinationStatus::from(u.as_ref())
                                 /* JsonParserGenerator.kt:339 */) /* JsonParserGenerator.kt:354 */)
                                 .transpose()?, /* JsonParserGenerator.kt:265 */
                         );
                         /* JsonParserGenerator.kt:262 */
-+
+                    }
                     /* JsonParserGenerator.kt:290 */
                     _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?, /* JsonParserGenerator.kt:260 */
-261
+                }
                 "StreamArn" => {
                     builder = builder.set_stream_arn(
                         ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                             .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                             .transpose()?,
                     );
--
+                }
                 "DestinationStatus" => {
                     builder = builder.set_destination_status(
                         ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                             .map(|s| s.to_unescaped().map(|u| crate::types::DestinationStatus::from(u.as_ref())))
                             .transpose()?,
                     );
--
+                }
                 _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
             },
                 /* JsonParserGenerator.kt:686 */
-+
+            }
             /* JsonParserGenerator.kt:695 */
             other => {
                 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
                     "expected object key or end object, found: {:?}",
                     other
                 )))
--
+            }
             } /* JsonParserGenerator.kt:685 */
-271
+        }
         /* JsonParserGenerator.kt:684 */
-273
+    }
     /* JsonParserGenerator.kt:250 */
     if tokens.next().is_some() {
         /* JsonParserGenerator.kt:251 */
         return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
             "found more JSON tokens after completing parsing",
         ));
         /* JsonParserGenerator.kt:250 */
-281
+    }
     /* JsonParserGenerator.kt:163 */
     Ok(builder)
     /* JsonParserGenerator.kt:148 */
-285
+}

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/protocol_serde/shape_enable_kinesis_streaming_destination_input.rs

@@ -1,1 +13,22 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonSerializerGenerator.kt:358 */
 pub fn ser_enable_kinesis_streaming_destination_input_input(
     object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
     input: &crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationInput,
 ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
     /* JsonSerializerGenerator.kt:382 */
     if let Some(var_1) = &input.table_name {
         /* JsonSerializerGenerator.kt:423 */
         object.key("TableName").string(var_1.as_str());
         /* JsonSerializerGenerator.kt:382 */
-12
+    }
     /* JsonSerializerGenerator.kt:382 */
     if let Some(var_2) = &input.stream_arn {
         /* JsonSerializerGenerator.kt:423 */
         object.key("StreamArn").string(var_2.as_str());
         /* JsonSerializerGenerator.kt:382 */
-18
+    }
     /* JsonSerializerGenerator.kt:372 */
     Ok(())
     /* JsonSerializerGenerator.kt:358 */
-22
+}

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/protocol_serde/shape_endpoint.rs

@@ -1,1 +49,81 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonParserGenerator.kt:516 */
 pub(crate) fn de_endpoint<'a, I>(
     tokens: &mut ::std::iter::Peekable<I>,
 ) -> ::std::result::Result<Option<crate::types::Endpoint>, ::aws_smithy_json::deserialize::error::DeserializeError>
 where
     I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
-8
+{
     /* JsonParserGenerator.kt:712 */
     match tokens.next().transpose()? {
         Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
         /* JsonParserGenerator.kt:713 */ Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
         Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
             /* RustType.kt:516 */
             #[allow(unused_mut)]
             /* JsonParserGenerator.kt:526 */
             let mut builder = crate::types::builders::EndpointBuilder::default();
             /* JsonParserGenerator.kt:684 */
             loop {
                 /* JsonParserGenerator.kt:685 */
                 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() {
                         "Address" => {
                             builder = builder.set_address(
                                 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                                     .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                                     .transpose()?,
                             );
                     /* JsonParserGenerator.kt:686 */ Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
                     Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
                         /* JsonParserGenerator.kt:260 */
                         match key.to_unescaped()?.as_ref() {
                             /* JsonParserGenerator.kt:262 */
                             "Address" => {
                                 /* JsonParserGenerator.kt:265 */
                                 builder = builder.set_address(
                                     /* JsonParserGenerator.kt:354 */
                                     ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                                         .map(|s|
                                         /* JsonParserGenerator.kt:339 */s.to_unescaped().map(|u|
                                             /* JsonParserGenerator.kt:348 */u.into_owned()
                                         /* JsonParserGenerator.kt:339 */) /* JsonParserGenerator.kt:354 */)
                                         .transpose()?, /* JsonParserGenerator.kt:265 */
                                 );
                                 /* JsonParserGenerator.kt:262 */
-+
+                            }
                             /* JsonParserGenerator.kt:262 */
                             "CachePeriodInMinutes" => {
                                 /* JsonParserGenerator.kt:265 */
                                 builder = builder.set_cache_period_in_minutes(
                                     /* JsonParserGenerator.kt:365 */
                                     ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
                                         .map(i64::try_from)
                                         .transpose()?, /* JsonParserGenerator.kt:265 */
                                 );
                                 /* JsonParserGenerator.kt:262 */
-+
+                            }
                             /* JsonParserGenerator.kt:290 */
                             _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?, /* JsonParserGenerator.kt:260 */
-52
+                        }
                         "CachePeriodInMinutes" => {
                             builder = builder.set_cache_period_in_minutes(
                                 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
                                     .map(i64::try_from)
                                     .transpose()?,
                             );
--
+                        }
                         _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
                     },
                         /* JsonParserGenerator.kt:686 */
-+
+                    }
                     /* JsonParserGenerator.kt:695 */
                     other => {
                         return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
                             "expected object key or end object, found: {:?}",
                             other
                         )))
--
+                    }
                     } /* JsonParserGenerator.kt:685 */
-62
+                }
                 /* JsonParserGenerator.kt:684 */
-64
+            }
             /* JsonParserGenerator.kt:540 */
             Ok(Some(crate::serde_util::endpoint_correct_errors(builder).build().map_err(|err| {
                 ::aws_smithy_json::deserialize::error::DeserializeError::custom_source("Response was invalid", err)
             })?))
             /* JsonParserGenerator.kt:713 */
-70
+        }
         _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
             "expected start object or null",
         )),
         /* JsonParserGenerator.kt:722 */
         _ => {
             /* JsonParserGenerator.kt:723 */
             Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
                 "expected start object or null",
             ))
             /* JsonParserGenerator.kt:722 */
         } /* JsonParserGenerator.kt:712 */
-79
+    }
     /* JsonParserGenerator.kt:516 */
-81
+}

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/protocol_serde/shape_endpoints.rs

@@ -1,1 +32,55 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonParserGenerator.kt:398 */
 pub(crate) fn de_endpoints<'a, I>(
     tokens: &mut ::std::iter::Peekable<I>,
 ) -> ::std::result::Result<Option<::std::vec::Vec<crate::types::Endpoint>>, ::aws_smithy_json::deserialize::error::DeserializeError>
 where
     I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
-8
+{
     /* JsonParserGenerator.kt:712 */
     match tokens.next().transpose()? {
         Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
         /* JsonParserGenerator.kt:713 */ Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
         Some(::aws_smithy_json::deserialize::Token::StartArray { .. }) => {
             /* JsonParserGenerator.kt:407 */
             let mut items = Vec::new();
             /* JsonParserGenerator.kt:408 */
             loop {
                 /* JsonParserGenerator.kt:409 */
                 match tokens.peek() {
                     /* JsonParserGenerator.kt:410 */
                     Some(Ok(::aws_smithy_json::deserialize::Token::EndArray { .. })) => {
                         /* JsonParserGenerator.kt:411 */
                         tokens.next().transpose().unwrap();
                         break;
                         /* JsonParserGenerator.kt:410 */
-25
+                    }
                     /* JsonParserGenerator.kt:413 */
                     _ => {
                         let value = crate::protocol_serde::shape_endpoint::de_endpoint(tokens)?;
                         /* JsonParserGenerator.kt:419 */
                         let value =
                             /* JsonParserGenerator.kt:544 */crate::protocol_serde::shape_endpoint::de_endpoint(tokens)?
                         /* JsonParserGenerator.kt:419 */;
                         /* JsonParserGenerator.kt:422 */
                         if let Some(value) = value {
                             items.push(value);
-35
+                        }
--
+                    }
                         /* JsonParserGenerator.kt:413 */
                     } /* JsonParserGenerator.kt:409 */
-38
+                }
                 /* JsonParserGenerator.kt:408 */
-40
+            }
             /* JsonParserGenerator.kt:446 */
             Ok(Some(items))
             /* JsonParserGenerator.kt:713 */
-44
+        }
         _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
             "expected start array or null",
         )),
         /* JsonParserGenerator.kt:722 */
         _ => {
             /* JsonParserGenerator.kt:723 */
             Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
                 "expected start array or null",
             ))
             /* JsonParserGenerator.kt:722 */
         } /* JsonParserGenerator.kt:712 */
-53
+    }
     /* JsonParserGenerator.kt:398 */
-55
+}

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/protocol_serde/shape_execute_statement.rs

@@ -1,1 +214,312 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* RustType.kt:516 */
 #[allow(clippy::unnecessary_wraps)]
 /* ProtocolParserGenerator.kt:99 */
 pub fn de_execute_statement_http_error(
     _response_status: u16,
     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<crate::operation::execute_statement::ExecuteStatementOutput, crate::operation::execute_statement::ExecuteStatementError> {
     /* RustType.kt:516 */
     #[allow(unused_mut)]
     /* ProtocolParserGenerator.kt:106 */
     let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
         .map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
     /* ProtocolParserGenerator.kt:120 */
     let generic = generic_builder.build();
     /* ProtocolParserGenerator.kt:122 */
     let error_code = match generic.code() {
         Some(code) => code,
         None => return Err(crate::operation::execute_statement::ExecuteStatementError::unhandled(generic)),
     };
-22
     let _error_message = generic.message().map(|msg| msg.to_owned());
     /* ProtocolParserGenerator.kt:133 */
     Err(match error_code {
         /* ProtocolParserGenerator.kt:139 */
         "ConditionalCheckFailedException" => crate::operation::execute_statement::ExecuteStatementError::ConditionalCheckFailedError({
             /* RustType.kt:516 */
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::ConditionalCheckFailedErrorBuilder::default();
                 output = crate::protocol_serde::shape_conditional_check_failed_exception::de_conditional_check_failed_exception_json_err(
                     _response_body,
                     output,
--
+                )
                 .map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             /* ProtocolParserGenerator.kt:145 */let mut tmp =
                 /* ProtocolParserGenerator.kt:146 */ {
                     /* RustType.kt:516 */#[allow(unused_mut)]
                     /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::ConditionalCheckFailedErrorBuilder::default();
                     /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_conditional_check_failed_exception::de_conditional_check_failed_exception_json_err(_response_body, output).map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
                     /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
                     /* ClientBuilderInstantiator.kt:56 */output.build()
                 /* ProtocolParserGenerator.kt:146 */}
             /* ProtocolParserGenerator.kt:145 */;
             /* ProtocolParserGenerator.kt:170 */
             if tmp.message.is_none() {
                 tmp.message = _error_message;
-42
+            }
             /* ProtocolParserGenerator.kt:179 */
             tmp
             /* ProtocolParserGenerator.kt:139 */
         }),
         /* ProtocolParserGenerator.kt:139 */
         "DuplicateItemException" => crate::operation::execute_statement::ExecuteStatementError::DuplicateItemError({
             /* RustType.kt:516 */
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::DuplicateItemErrorBuilder::default();
                 output = crate::protocol_serde::shape_duplicate_item_exception::de_duplicate_item_exception_json_err(_response_body, output)
                     .map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             /* ProtocolParserGenerator.kt:145 */let mut tmp =
                 /* ProtocolParserGenerator.kt:146 */ {
                     /* RustType.kt:516 */#[allow(unused_mut)]
                     /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::DuplicateItemErrorBuilder::default();
                     /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_duplicate_item_exception::de_duplicate_item_exception_json_err(_response_body, output).map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
                     /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
                     /* ClientBuilderInstantiator.kt:56 */output.build()
                 /* ProtocolParserGenerator.kt:146 */}
             /* ProtocolParserGenerator.kt:145 */;
             /* ProtocolParserGenerator.kt:170 */
             if tmp.message.is_none() {
                 tmp.message = _error_message;
-63
+            }
             /* ProtocolParserGenerator.kt:179 */
             tmp
             /* ProtocolParserGenerator.kt:139 */
         }),
         /* ProtocolParserGenerator.kt:139 */
         "InternalServerError" => crate::operation::execute_statement::ExecuteStatementError::InternalServerError({
             /* RustType.kt:516 */
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::InternalServerErrorBuilder::default();
                 output = crate::protocol_serde::shape_internal_server_error::de_internal_server_error_json_err(_response_body, output)
                     .map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             /* ProtocolParserGenerator.kt:145 */let mut tmp =
                 /* ProtocolParserGenerator.kt:146 */ {
                     /* RustType.kt:516 */#[allow(unused_mut)]
                     /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::InternalServerErrorBuilder::default();
                     /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_internal_server_error::de_internal_server_error_json_err(_response_body, output).map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
                     /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
                     /* ClientBuilderInstantiator.kt:56 */output.build()
                 /* ProtocolParserGenerator.kt:146 */}
             /* ProtocolParserGenerator.kt:145 */;
             /* ProtocolParserGenerator.kt:170 */
             if tmp.message.is_none() {
                 tmp.message = _error_message;
-84
+            }
             /* ProtocolParserGenerator.kt:179 */
             tmp
             /* ProtocolParserGenerator.kt:139 */
         }),
         /* ProtocolParserGenerator.kt:139 */
         "ItemCollectionSizeLimitExceededException" => {
             crate::operation::execute_statement::ExecuteStatementError::ItemCollectionSizeLimitExceededError({
                 /* RustType.kt:516 */
                 #[allow(unused_mut)]
                 let mut tmp = {
                     #[allow(unused_mut)]
                     let mut output = crate::types::error::builders::ItemCollectionSizeLimitExceededErrorBuilder::default();
                     output = crate::protocol_serde::shape_item_collection_size_limit_exceeded_exception::de_item_collection_size_limit_exceeded_exception_json_err(_response_body, output).map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
                     let output = output.meta(generic);
                     output.build()
                 };
                 if tmp.message.is_none() {
                     tmp.message = _error_message;
--
+                }
                 tmp
             })
--
+        }
         "ProvisionedThroughputExceededException" => {
             crate::operation::execute_statement::ExecuteStatementError::ProvisionedThroughputExceededError({
                 #[allow(unused_mut)]
                 let mut tmp = {
                     #[allow(unused_mut)]
                     let mut output = crate::types::error::builders::ProvisionedThroughputExceededErrorBuilder::default();
                     output = crate::protocol_serde::shape_provisioned_throughput_exceeded_exception::de_provisioned_throughput_exceeded_exception_json_err(_response_body, output).map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
                     let output = output.meta(generic);
                     output.build()
                 };
             /* ProtocolParserGenerator.kt:145 */let mut tmp =
                 /* ProtocolParserGenerator.kt:146 */ {
                     /* RustType.kt:516 */#[allow(unused_mut)]
                     /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::ItemCollectionSizeLimitExceededErrorBuilder::default();
                     /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_item_collection_size_limit_exceeded_exception::de_item_collection_size_limit_exceeded_exception_json_err(_response_body, output).map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
                     /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
                     /* ClientBuilderInstantiator.kt:56 */output.build()
                 /* ProtocolParserGenerator.kt:146 */}
             /* ProtocolParserGenerator.kt:145 */;
                 /* ProtocolParserGenerator.kt:170 */
                 if tmp.message.is_none() {
                     tmp.message = _error_message;
-106
+                }
                 /* ProtocolParserGenerator.kt:179 */
                 tmp
                 /* ProtocolParserGenerator.kt:139 */
             })
-111
+        }
         /* ProtocolParserGenerator.kt:139 */
         "ProvisionedThroughputExceededException" => crate::operation::execute_statement::ExecuteStatementError::ProvisionedThroughputExceededError({
             /* RustType.kt:516 */
             #[allow(unused_mut)]
             /* ProtocolParserGenerator.kt:145 */let mut tmp =
                 /* ProtocolParserGenerator.kt:146 */ {
                     /* RustType.kt:516 */#[allow(unused_mut)]
                     /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::ProvisionedThroughputExceededErrorBuilder::default();
                     /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_provisioned_throughput_exceeded_exception::de_provisioned_throughput_exceeded_exception_json_err(_response_body, output).map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
                     /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
                     /* ClientBuilderInstantiator.kt:56 */output.build()
                 /* ProtocolParserGenerator.kt:146 */}
             /* ProtocolParserGenerator.kt:145 */;
             /* ProtocolParserGenerator.kt:170 */
             if tmp.message.is_none() {
                 tmp.message = _error_message;
-+
+            }
             /* ProtocolParserGenerator.kt:179 */
             tmp
             /* ProtocolParserGenerator.kt:139 */
         }),
         /* ProtocolParserGenerator.kt:139 */
         "RequestLimitExceeded" => crate::operation::execute_statement::ExecuteStatementError::RequestLimitExceeded({
             /* RustType.kt:516 */
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::RequestLimitExceededBuilder::default();
                 output = crate::protocol_serde::shape_request_limit_exceeded::de_request_limit_exceeded_json_err(_response_body, output)
                     .map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             /* ProtocolParserGenerator.kt:145 */let mut tmp =
                 /* ProtocolParserGenerator.kt:146 */ {
                     /* RustType.kt:516 */#[allow(unused_mut)]
                     /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::RequestLimitExceededBuilder::default();
                     /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_request_limit_exceeded::de_request_limit_exceeded_json_err(_response_body, output).map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
                     /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
                     /* ClientBuilderInstantiator.kt:56 */output.build()
                 /* ProtocolParserGenerator.kt:146 */}
             /* ProtocolParserGenerator.kt:145 */;
             /* ProtocolParserGenerator.kt:170 */
             if tmp.message.is_none() {
                 tmp.message = _error_message;
-149
+            }
             /* ProtocolParserGenerator.kt:179 */
             tmp
             /* ProtocolParserGenerator.kt:139 */
         }),
         /* ProtocolParserGenerator.kt:139 */
         "ResourceNotFoundException" => crate::operation::execute_statement::ExecuteStatementError::ResourceNotFoundError({
             /* RustType.kt:516 */
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::ResourceNotFoundErrorBuilder::default();
                 output = crate::protocol_serde::shape_resource_not_found_exception::de_resource_not_found_exception_json_err(_response_body, output)
                     .map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             /* ProtocolParserGenerator.kt:145 */let mut tmp =
                 /* ProtocolParserGenerator.kt:146 */ {
                     /* RustType.kt:516 */#[allow(unused_mut)]
                     /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::ResourceNotFoundErrorBuilder::default();
                     /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_resource_not_found_exception::de_resource_not_found_exception_json_err(_response_body, output).map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
                     /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
                     /* ClientBuilderInstantiator.kt:56 */output.build()
                 /* ProtocolParserGenerator.kt:146 */}
             /* ProtocolParserGenerator.kt:145 */;
             /* ProtocolParserGenerator.kt:170 */
             if tmp.message.is_none() {
                 tmp.message = _error_message;
-170
+            }
             /* ProtocolParserGenerator.kt:179 */
             tmp
             /* ProtocolParserGenerator.kt:139 */
         }),
         /* ProtocolParserGenerator.kt:139 */
         "TransactionConflictException" => crate::operation::execute_statement::ExecuteStatementError::TransactionConflictError({
             /* RustType.kt:516 */
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::TransactionConflictErrorBuilder::default();
                 output =
                     crate::protocol_serde::shape_transaction_conflict_exception::de_transaction_conflict_exception_json_err(_response_body, output)
                         .map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             /* ProtocolParserGenerator.kt:145 */let mut tmp =
                 /* ProtocolParserGenerator.kt:146 */ {
                     /* RustType.kt:516 */#[allow(unused_mut)]
                     /* ProtocolParserGenerator.kt:240 */let mut output = crate::types::error::builders::TransactionConflictErrorBuilder::default();
                     /* ProtocolParserGenerator.kt:257 */output = crate::protocol_serde::shape_transaction_conflict_exception::de_transaction_conflict_exception_json_err(_response_body, output).map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
                     /* ProtocolParserGenerator.kt:157 */let output = output.meta(generic);
                     /* ClientBuilderInstantiator.kt:56 */output.build()
                 /* ProtocolParserGenerator.kt:146 */}
             /* ProtocolParserGenerator.kt:145 */;
             /* ProtocolParserGenerator.kt:170 */
             if tmp.message.is_none() {
                 tmp.message = _error_message;
-191
+            }
             /* ProtocolParserGenerator.kt:179 */
             tmp
             /* ProtocolParserGenerator.kt:139 */
         }),
         _ => crate::operation::execute_statement::ExecuteStatementError::generic(generic),
         /* ProtocolParserGenerator.kt:182 */
         _ => crate::operation::execute_statement::ExecuteStatementError::generic(generic), /* ProtocolParserGenerator.kt:133 */
     })
     /* ProtocolParserGenerator.kt:99 */
-200
+}
-201
 /* RustType.kt:516 */
 #[allow(clippy::unnecessary_wraps)]
 /* ProtocolParserGenerator.kt:71 */
 pub fn de_execute_statement_http_response(
     _response_status: u16,
     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<crate::operation::execute_statement::ExecuteStatementOutput, crate::operation::execute_statement::ExecuteStatementError> {
     /* ProtocolParserGenerator.kt:77 */
     Ok({
         /* RustType.kt:516 */
         #[allow(unused_mut)]
         /* ProtocolParserGenerator.kt:240 */
         let mut output = crate::operation::execute_statement::builders::ExecuteStatementOutputBuilder::default();
         /* ProtocolParserGenerator.kt:247 */
         output = crate::protocol_serde::shape_execute_statement::de_execute_statement(_response_body, output)
             .map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
         /* ClientBuilderInstantiator.kt:56 */
         output.build()
         /* ProtocolParserGenerator.kt:77 */
     })
     /* ProtocolParserGenerator.kt:71 */
-224
+}
-225
 /* JsonSerializerGenerator.kt:287 */
 pub fn ser_execute_statement_input(
     input: &crate::operation::execute_statement::ExecuteStatementInput,
 ) -> ::std::result::Result<::aws_smithy_types::body::SdkBody, ::aws_smithy_types::error::operation::SerializationError> {
     /* JsonSerializerGenerator.kt:291 */
     let mut out = String::new();
     /* JsonSerializerGenerator.kt:292 */
     let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
     /* JsonSerializerGenerator.kt:375 */
     crate::protocol_serde::shape_execute_statement_input::ser_execute_statement_input_input(&mut object, input)?;
     /* JsonSerializerGenerator.kt:295 */
     object.finish();
     /* JsonSerializerGenerator.kt:296 */
     Ok(::aws_smithy_types::body::SdkBody::from(out))
     /* JsonSerializerGenerator.kt:287 */
-241
+}
-242
 /* JsonParserGenerator.kt:148 */
 pub(crate) fn de_execute_statement(
     value: &[u8],
     mut builder: crate::operation::execute_statement::builders::ExecuteStatementOutputBuilder,
 ) -> ::std::result::Result<
     crate::operation::execute_statement::builders::ExecuteStatementOutputBuilder,
     ::aws_smithy_json::deserialize::error::DeserializeError,
 > {
     /* JsonParserGenerator.kt:153 */
     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())?;
     /* JsonParserGenerator.kt:684 */
     loop {
         /* JsonParserGenerator.kt:685 */
         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() {
                 "Items" => {
                     builder = builder.set_items(crate::protocol_serde::shape_item_list::de_item_list(tokens)?);
--
+                }
                 "NextToken" => {
                     builder = builder.set_next_token(
                         ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                             .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                             .transpose()?,
                     );
             /* JsonParserGenerator.kt:686 */ Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
             Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
                 /* JsonParserGenerator.kt:260 */
                 match key.to_unescaped()?.as_ref() {
                     /* JsonParserGenerator.kt:262 */
                     "Items" => {
                         /* JsonParserGenerator.kt:265 */
                         builder = builder.set_items(
                             /* JsonParserGenerator.kt:451 */
                             crate::protocol_serde::shape_item_list::de_item_list(tokens)?, /* JsonParserGenerator.kt:265 */
                         );
                         /* JsonParserGenerator.kt:262 */
-+
+                    }
                     /* JsonParserGenerator.kt:262 */
                     "NextToken" => {
                         /* JsonParserGenerator.kt:265 */
                         builder = builder.set_next_token(
                             /* JsonParserGenerator.kt:354 */
                             ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                                 .map(|s|
                                 /* JsonParserGenerator.kt:339 */s.to_unescaped().map(|u|
                                     /* JsonParserGenerator.kt:348 */u.into_owned()
                                 /* JsonParserGenerator.kt:339 */) /* JsonParserGenerator.kt:354 */)
                                 .transpose()?, /* JsonParserGenerator.kt:265 */
                         );
                         /* JsonParserGenerator.kt:262 */
-+
+                    }
                     /* JsonParserGenerator.kt:290 */
                     _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?, /* JsonParserGenerator.kt:260 */
-288
+                }
                 _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
             },
                 /* JsonParserGenerator.kt:686 */
-+
+            }
             /* JsonParserGenerator.kt:695 */
             other => {
                 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
                     "expected object key or end object, found: {:?}",
                     other
                 )))
--
+            }
             } /* JsonParserGenerator.kt:685 */
-298
+        }
         /* JsonParserGenerator.kt:684 */
-300
+    }
     /* JsonParserGenerator.kt:250 */
     if tokens.next().is_some() {
         /* JsonParserGenerator.kt:251 */
         return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
             "found more JSON tokens after completing parsing",
         ));
         /* JsonParserGenerator.kt:250 */
-308
+    }
     /* JsonParserGenerator.kt:163 */
     Ok(builder)
     /* JsonParserGenerator.kt:148 */
-312
+}

Client Test

Files changed:

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/protocol_serde/shape_describe_table_replica_auto_scaling_input.rs

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/protocol_serde/shape_describe_time_to_live.rs

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/protocol_serde/shape_describe_time_to_live_input.rs

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/protocol_serde/shape_disable_kinesis_streaming_destination.rs

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/protocol_serde/shape_disable_kinesis_streaming_destination_input.rs

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/protocol_serde/shape_duplicate_item_exception.rs

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/protocol_serde/shape_enable_kinesis_streaming_destination.rs

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/protocol_serde/shape_enable_kinesis_streaming_destination_input.rs

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/protocol_serde/shape_endpoint.rs

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/protocol_serde/shape_endpoints.rs

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/protocol_serde/shape_execute_statement.rs