Client Test

rev. 7254d43655ed63111c94f599437f2b0d3f55446e (ignoring whitespace)

Files changed:

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/operation/unit_input_and_output/builders.rs

@@ -1,1 +35,35 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub use crate::operation::unit_input_and_output::_unit_input_and_output_output::UnitInputAndOutputOutputBuilder;
--
 pub use crate::operation::unit_input_and_output::_unit_input_and_output_input::UnitInputAndOutputInputBuilder;
-3
 pub use crate::operation::unit_input_and_output::_unit_input_and_output_output::UnitInputAndOutputOutputBuilder;
-+
 impl crate::operation::unit_input_and_output::builders::UnitInputAndOutputInputBuilder {
     /// Sends a request with this input using the given client.
     pub async fn send_with(
         self,
         client: &crate::Client,
     ) -> ::std::result::Result<
         crate::operation::unit_input_and_output::UnitInputAndOutputOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::unit_input_and_output::UnitInputAndOutputError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,

↧ Expand context

         >,
     > {
         let mut fluent_builder = client.unit_input_and_output();
         fluent_builder.inner = self;
         fluent_builder.send().await
-21
+    }
-22
+}
 /// Fluent builder constructing a request to `UnitInputAndOutput`.
 ///
 /// This test is similar to NoInputAndNoOutput, but uses explicit Unit types.
 #[derive(::std::clone::Clone, ::std::fmt::Debug)]
 pub struct UnitInputAndOutputFluentBuilder {
     handle: ::std::sync::Arc<crate::client::Handle>,
     inner: crate::operation::unit_input_and_output::builders::UnitInputAndOutputInputBuilder,
     config_override: ::std::option::Option<crate::config::Builder>,
-31
+}
 impl
     crate::client::customize::internal::CustomizableSend<
         crate::operation::unit_input_and_output::UnitInputAndOutputOutput,
         crate::operation::unit_input_and_output::UnitInputAndOutputError,

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/primitives/event_stream.rs

@@ -1,1 +0,6 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub use crate::event_receiver::EventReceiver;
 pub use ::aws_smithy_types::event_stream::Header;
 pub use ::aws_smithy_types::event_stream::HeaderValue;
 pub use ::aws_smithy_types::event_stream::Message;
 pub use ::aws_smithy_types::str_bytes::StrBytes;

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

@@ -20,20 +147,159 @@

↥ Expand context

     response_headers: &::aws_smithy_runtime_api::http::Headers,
     response_body: &[u8],
 ) -> ::std::result::Result<::aws_smithy_types::error::metadata::Builder, ::aws_smithy_json::deserialize::error::DeserializeError> {
     crate::json_errors::parse_error_metadata(response_body, response_headers)
-24
+}
-25
 pub(crate) mod shape_all_query_string_types;
-27
 pub(crate) mod shape_constant_and_variable_query_string;
-29
 pub(crate) mod shape_constant_query_string;
-31
 pub(crate) mod shape_content_type_parameters;
-33
 pub(crate) mod shape_datetime_offsets;
-35
 pub(crate) mod shape_document_type;
-37
 pub(crate) mod shape_document_type_as_map_value;
-39

 pub(crate) mod shape_document_type_as_payload;
-41
 pub fn serialize_document(input: &::aws_smithy_types::Document) -> ::std::vec::Vec<u8> {
     let mut out = String::new();
     ::aws_smithy_json::serialize::JsonValueWriter::new(&mut out).document(input);
     out.into_bytes()
-46
+}
-47
 pub(crate) mod shape_document_type_as_payload_input;
-49
 pub(crate) mod shape_duplex_stream;
-+
 pub(crate) mod shape_duplex_stream_with_distinct_streams;
-+
 pub(crate) mod shape_duplex_stream_with_initial_messages;
-+
 pub(crate) mod shape_empty_input_and_empty_output;
-57
 pub(crate) mod shape_endpoint_operation;
-59
 pub(crate) mod shape_endpoint_with_host_label_operation;
-61
 pub(crate) mod shape_fractional_seconds;
-63
 pub(crate) mod shape_greeting_with_errors;
-65
 pub(crate) mod shape_host_with_path_operation;
-67
 pub(crate) mod shape_http_checksum_required;
-69
 pub(crate) mod shape_http_empty_prefix_headers;
-71
 pub(crate) mod shape_http_enum_payload;
-73
 pub(crate) mod shape_http_enum_payload_input;
-75
 pub(crate) mod shape_http_payload_traits;
-77
 pub(crate) mod shape_http_payload_traits_input;
-79
 pub(crate) mod shape_http_payload_traits_with_media_type;
-81
 pub(crate) mod shape_http_payload_traits_with_media_type_input;
-83
 pub(crate) mod shape_http_payload_with_structure;
-85
 pub fn rest_json_unset_struct_payload() -> ::std::vec::Vec<u8> {
     b"{}"[..].into()
-88
+}
-89
 pub(crate) mod shape_http_payload_with_structure_input;
-91
 pub(crate) mod shape_http_payload_with_union;
-93
 pub fn rest_json_unset_union_payload() -> ::std::vec::Vec<u8> {
     ::std::vec::Vec::new()
-96
+}
-97
 pub(crate) mod shape_http_payload_with_union_input;
-99
 pub(crate) mod shape_http_prefix_headers;
-101
 pub(crate) mod shape_http_prefix_headers_in_response;
-103
 pub(crate) mod shape_http_query_params_only_operation;
-+
 pub(crate) mod shape_http_request_with_float_labels;
-107
 pub(crate) mod shape_http_request_with_greedy_label_in_path;
-109
 pub(crate) mod shape_http_request_with_labels;
-111
 pub(crate) mod shape_http_request_with_labels_and_timestamp_format;
-113
 pub(crate) mod shape_http_request_with_regex_literal;
-115
 pub(crate) mod shape_http_response_code;
-117
 pub(crate) mod shape_http_string_payload;
-119
 pub(crate) mod shape_http_string_payload_input;
-121
 pub(crate) mod shape_ignore_query_params_in_response;
-123
 pub(crate) mod shape_input_and_output_with_headers;
-125
 pub(crate) mod shape_input_stream;
-+
 pub(crate) mod shape_input_stream_with_initial_request;
-+
 pub(crate) mod shape_json_blobs;
-131
 pub(crate) mod shape_json_enums;
-133
 pub(crate) mod shape_json_int_enums;
-135
 pub(crate) mod shape_json_lists;
-137
 pub(crate) mod shape_json_maps;
-139

↧ Expand context

 pub(crate) mod shape_json_timestamps;
-141
 pub(crate) mod shape_json_unions;
-143
 pub(crate) mod shape_malformed_accept_with_body;
-145
 pub(crate) mod shape_malformed_accept_with_generic_string;
-147
 pub(crate) mod shape_malformed_accept_with_payload;
-149
 pub(crate) mod shape_malformed_blob;
-151
 pub(crate) mod shape_malformed_boolean;
-153
 pub(crate) mod shape_malformed_byte;
-155
 pub(crate) mod shape_malformed_content_type_with_body;
-157
 pub(crate) mod shape_malformed_content_type_with_generic_string;
-159

@@ -190,202 +249,265 @@

↥ Expand context

 pub(crate) mod shape_malformed_timestamp_path_epoch;
-203
 pub(crate) mod shape_malformed_timestamp_path_http_date;
-205
 pub(crate) mod shape_malformed_timestamp_query_default;
-207
 pub(crate) mod shape_malformed_timestamp_query_epoch;
-209
 pub(crate) mod shape_malformed_timestamp_query_http_date;
-211
 pub(crate) mod shape_malformed_union;
-213
 pub(crate) mod shape_media_type_header;
-215
 pub(crate) mod shape_no_input_and_no_output;
-217
 pub(crate) mod shape_no_input_and_output;
-219
 pub(crate) mod shape_null_and_empty_headers_client;
-221

 pub(crate) mod shape_null_and_empty_headers_server;
-223
 pub(crate) mod shape_omits_null_serializes_empty_string;
-225
 pub(crate) mod shape_omits_serializing_empty_lists;
-227
 pub(crate) mod shape_operation_with_defaults;
-229
 pub(crate) mod shape_operation_with_nested_structure;
-231
 pub(crate) mod shape_output_stream;
-+
 pub(crate) mod shape_output_stream_with_initial_response;
-+
 pub(crate) mod shape_post_player_action;
-237
 pub(crate) mod shape_post_union_with_json_name;
-239
 pub(crate) mod shape_put_with_content_encoding;
-241
 pub(crate) mod shape_query_idempotency_token_auto_fill;
-243
 pub(crate) mod shape_query_params_as_string_list_map;
-245

↧ Expand context

 pub(crate) mod shape_query_precedence;
-247
 pub(crate) mod shape_recursive_shapes;
-249
 pub(crate) mod shape_response_code_http_fallback;
-251
 pub(crate) mod shape_response_code_required;
-253
 pub(crate) mod shape_simple_scalar_properties;
-255
 pub(crate) mod shape_sparse_json_lists;
-257
 pub(crate) mod shape_sparse_json_maps;
-259
 pub(crate) mod shape_streaming_traits;
-261
 pub(crate) mod shape_streaming_traits_input;
-263
 pub(crate) mod shape_streaming_traits_require_length;
-265

@@ -266,282 +331,357 @@

↥ Expand context

 pub(crate) mod shape_test_payload_structure;
-283
 pub(crate) mod shape_test_payload_structure_input;
-285
 pub(crate) mod shape_test_post_no_input_no_payload;
-287
 pub(crate) mod shape_test_post_no_payload;
-289
 pub(crate) mod shape_timestamp_format_headers;
-291
 pub(crate) mod shape_unit_input_and_output;
-293
 pub(crate) fn or_empty_doc(data: &[u8]) -> &[u8] {
     if data.is_empty() {
         b"{}"
     } else {
         data
-299
+    }
-300
+}
-301

 pub(crate) mod shape_complex_error;
-303
 pub(crate) mod shape_content_type_parameters_input;
-305
 pub(crate) mod shape_document_type_as_map_value_input;
-307
 pub(crate) mod shape_document_type_as_payload_output;
-309
 pub(crate) mod shape_document_type_input;
-311
 pub(crate) mod shape_duplex_stream_output;
-+
 pub(crate) mod shape_duplex_stream_with_distinct_streams_output;
-+
 pub(crate) mod shape_duplex_stream_with_initial_messages_output;
-+
 pub(crate) mod shape_endpoint_with_host_label_operation_input;
-319
 pub(crate) mod shape_error_event;
-+
 pub(crate) mod shape_foo_error;
-323
 pub(crate) mod shape_greeting_with_errors_output;
-325
 pub(crate) mod shape_headers_and_explicit_payload_event;
-+
 pub(crate) mod shape_http_checksum_required_input;
-329
 pub(crate) mod shape_http_empty_prefix_headers_output;
-331
 pub(crate) mod shape_http_enum_payload_output;
-333
 pub(crate) mod shape_http_payload_traits_output;
-335
 pub(crate) mod shape_http_payload_traits_with_media_type_output;
-337

↧ Expand context

 pub(crate) mod shape_http_payload_with_structure_output;
-339
 pub(crate) mod shape_http_payload_with_union_output;
-341
 pub(crate) mod shape_http_prefix_headers_in_response_output;
-343
 pub(crate) mod shape_http_prefix_headers_output;
-345
 pub(crate) mod shape_http_string_payload_output;
-347
 pub(crate) mod shape_input_and_output_with_headers_output;
-349
 pub(crate) mod shape_invalid_greeting;
-351
 pub(crate) mod shape_json_blobs_input;
-353
 pub(crate) mod shape_json_enums_input;
-355
 pub(crate) mod shape_json_int_enums_input;
-357

@@ -356,382 +0,576 @@

↥ Expand context

 pub(crate) mod shape_malformed_integer_input;
-383
 pub(crate) mod shape_malformed_list_input;
-385
 pub(crate) mod shape_malformed_long_input;
-387
 pub(crate) mod shape_malformed_map_input;
-389
 pub(crate) mod shape_malformed_request_body_input;
-391
 pub(crate) mod shape_malformed_short_input;
-393
 pub(crate) mod shape_malformed_timestamp_body_date_time_input;
-395
 pub(crate) mod shape_malformed_timestamp_body_default_input;
-397
 pub(crate) mod shape_malformed_timestamp_body_http_date_input;
-399
 pub(crate) mod shape_malformed_union_input;
-401

 pub(crate) mod shape_media_type_header_output;
-403
 pub(crate) mod shape_null_and_empty_headers_client_output;
-405
 pub(crate) mod shape_null_and_empty_headers_server_output;
-407
 pub(crate) mod shape_operation_with_defaults_input;
-409
 pub(crate) mod shape_operation_with_nested_structure_input;
-411
 pub(crate) mod shape_output_stream_output;
-+
 pub(crate) mod shape_output_stream_with_initial_response_output;
-+
 pub(crate) mod shape_post_player_action_input;
-417
 pub(crate) mod shape_post_union_with_json_name_input;
-419
 pub(crate) mod shape_put_with_content_encoding_input;
-421
 pub(crate) mod shape_recursive_shapes_input;
-423
 pub(crate) mod shape_service_unavailable_error;
-+
 pub(crate) mod shape_simple_scalar_properties_input;
-427
 pub(crate) mod shape_simple_scalar_properties_output;
-429
 pub(crate) mod shape_sparse_json_lists_input;
-431
 pub(crate) mod shape_sparse_json_maps_input;
-433
 pub(crate) mod shape_streaming_traits_output;
-435
 pub(crate) mod shape_streaming_traits_with_media_type_output;
-437
 pub(crate) mod shape_structure_payload_event;
-+
 pub(crate) mod shape_test_body_structure_input;
-441
 pub(crate) mod shape_test_body_structure_output;
-443
 pub(crate) mod shape_test_get_no_input_no_payload_output;
-445
 pub(crate) mod shape_test_get_no_payload_output;
-447
 pub(crate) mod shape_test_payload_blob_output;
-449
 pub(crate) mod shape_test_payload_structure_output;
-451
 pub(crate) mod shape_test_post_no_input_no_payload_output;
-453
 pub(crate) mod shape_test_post_no_payload_output;
-455
 pub(crate) mod shape_timestamp_format_headers_output;
-457
 pub(crate) mod shape_union_payload_event;
-+
 pub fn parse_event_stream_error_metadata(
     payload: &::bytes::Bytes,
 ) -> ::std::result::Result<::aws_smithy_types::error::metadata::Builder, ::aws_smithy_json::deserialize::error::DeserializeError> {
     crate::json_errors::parse_error_metadata(payload, &::aws_smithy_runtime_api::http::Headers::new())
-+
+}
-+
 pub(crate) mod shape_boolean_list;
-467
 pub(crate) mod shape_client_optional_defaults;
-469
 pub(crate) mod shape_complex_nested_error_data;
-471
 pub(crate) mod shape_defaults;
-473
 pub(crate) mod shape_dense_boolean_map;
-475
 pub(crate) mod shape_dense_number_map;
-477
 pub(crate) mod shape_dense_set_map;
-479
 pub(crate) mod shape_dense_string_map;
-481
 pub(crate) mod shape_dense_struct_map;
-483
 pub(crate) mod shape_dialog;
-485
 pub(crate) mod shape_dialog_list;
-487
 pub(crate) mod shape_dialog_map;
-489
 pub(crate) mod shape_document;
-491
 pub(crate) mod shape_document_valued_map;
-493
 pub(crate) mod shape_foo_enum_list;
-495
 pub(crate) mod shape_foo_enum_map;
-497
 pub(crate) mod shape_foo_enum_set;
-499
 pub(crate) mod shape_greeting_struct;
-501
 pub(crate) mod shape_integer_enum_list;
-503
 pub(crate) mod shape_integer_enum_map;
-505
 pub(crate) mod shape_integer_enum_set;
-507
 pub(crate) mod shape_integer_list;
-509
 pub(crate) mod shape_my_union;
-511
 pub(crate) mod shape_nested_payload;
-513
 pub(crate) mod shape_nested_string_list;
-515
 pub(crate) mod shape_payload_config;
-517
 pub(crate) mod shape_payload_structure;
-+
 pub(crate) mod shape_payload_union;
-+
 pub(crate) mod shape_player_action;
-523
 pub(crate) mod shape_recursive_shapes_input_output_nested1;
-525
 pub(crate) mod shape_simple_union;
-527
 pub(crate) mod shape_singleton_event_stream;
-+
 pub(crate) mod shape_sparse_boolean_map;
-531
 pub(crate) mod shape_sparse_number_map;
-533
 pub(crate) mod shape_sparse_set_map;
-535
 pub(crate) mod shape_sparse_short_list;
-537
 pub(crate) mod shape_sparse_string_list;
-539
 pub(crate) mod shape_sparse_string_map;
-541
 pub(crate) mod shape_sparse_struct_map;
-543
 pub(crate) mod shape_string_list;
-545
 pub(crate) mod shape_string_set;
-547
 pub(crate) mod shape_structure_list;
-549
 pub(crate) mod shape_structure_list_member;
-551
 pub(crate) mod shape_test_config;
-553
 pub(crate) mod shape_test_string_list;
-555
 pub(crate) mod shape_test_string_map;
-557
 pub(crate) mod shape_timestamp_list;
-559
 pub(crate) mod shape_top_level;
-561
 pub(crate) mod shape_union_payload;
-563
 pub(crate) mod shape_union_with_json_name;
-565
 pub(crate) mod shape_farewell;
-567
 pub(crate) mod shape_headers_and_implicit_payload_event;
-+
 pub(crate) mod shape_recursive_shapes_input_output_nested2;
-571
 pub(crate) mod shape_renamed_greeting;
-573
 pub(crate) mod shape_string_map;
-+
 pub(crate) mod shape_singleton_event;

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/protocol_serde/shape_duplex_stream.rs

@@ -0,1 +0,56 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub fn de_duplex_stream_http_response(
     response: &mut ::aws_smithy_runtime_api::http::Response,
 ) -> std::result::Result<crate::operation::duplex_stream::DuplexStreamOutput, crate::operation::duplex_stream::DuplexStreamError> {
     let mut _response_body = ::aws_smithy_types::body::SdkBody::taken();
     std::mem::swap(&mut _response_body, response.body_mut());
     let _response_body = &mut _response_body;
-+
     let _response_status = response.status().as_u16();
     let _response_headers = response.headers();
     Ok({
         #[allow(unused_mut)]
         let mut output = crate::operation::duplex_stream::builders::DuplexStreamOutputBuilder::default();
         output = output.set_stream(Some(crate::protocol_serde::shape_duplex_stream_output::de_stream_payload(
             _response_body,
         )?));
         output.build().map_err(crate::operation::duplex_stream::DuplexStreamError::unhandled)?
     })
-+
+}
-+
 #[allow(clippy::unnecessary_wraps)]
 pub fn de_duplex_stream_http_error(
     _response_status: u16,
     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<crate::operation::duplex_stream::DuplexStreamOutput, crate::operation::duplex_stream::DuplexStreamError> {
     #[allow(unused_mut)]
     let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
         .map_err(crate::operation::duplex_stream::DuplexStreamError::unhandled)?;
     let generic = generic_builder.build();
     let error_code = match generic.code() {
         Some(code) => code,
         None => return Err(crate::operation::duplex_stream::DuplexStreamError::unhandled(generic)),
     };
-+
     let _error_message = generic.message().map(|msg| msg.to_owned());
     Err(match error_code {
         "ErrorEvent" => crate::operation::duplex_stream::DuplexStreamError::ErrorEvent({
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::ErrorEventBuilder::default();
                 output = crate::protocol_serde::shape_error_event::de_error_event_json_err(_response_body, output)
                     .map_err(crate::operation::duplex_stream::DuplexStreamError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             if tmp.message.is_none() {
                 tmp.message = _error_message;
-+
+            }
             tmp
         }),
         _ => crate::operation::duplex_stream::DuplexStreamError::generic(generic),
     })
-+
+}

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/protocol_serde/shape_duplex_stream_output.rs

@@ -0,1 +0,12 @@

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

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/protocol_serde/shape_duplex_stream_with_distinct_streams.rs

@@ -0,1 +0,56 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub fn de_duplex_stream_with_distinct_streams_http_error(
     _response_status: u16,
     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<
     crate::operation::duplex_stream_with_distinct_streams::DuplexStreamWithDistinctStreamsOutput,
     crate::operation::duplex_stream_with_distinct_streams::DuplexStreamWithDistinctStreamsError,
 > {
     #[allow(unused_mut)]
     let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
         .map_err(crate::operation::duplex_stream_with_distinct_streams::DuplexStreamWithDistinctStreamsError::unhandled)?;
     let generic = generic_builder.build();
     let error_code = match generic.code() {
         Some(code) => code,
         None => return Err(crate::operation::duplex_stream_with_distinct_streams::DuplexStreamWithDistinctStreamsError::unhandled(generic)),
     };
-+
     let _error_message = generic.message().map(|msg| msg.to_owned());
     Err(match error_code {
         "ErrorEvent" => crate::operation::duplex_stream_with_distinct_streams::DuplexStreamWithDistinctStreamsError::ErrorEvent({
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::ErrorEventBuilder::default();
                 output = crate::protocol_serde::shape_error_event::de_error_event_json_err(_response_body, output)
                     .map_err(crate::operation::duplex_stream_with_distinct_streams::DuplexStreamWithDistinctStreamsError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             if tmp.message.is_none() {
                 tmp.message = _error_message;
-+
+            }
             tmp
         }),
         _ => crate::operation::duplex_stream_with_distinct_streams::DuplexStreamWithDistinctStreamsError::generic(generic),
     })
-+
+}
-+
 #[allow(clippy::unnecessary_wraps)]
 pub fn de_duplex_stream_with_distinct_streams_http_response(
     _response_status: u16,
     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<
     crate::operation::duplex_stream_with_distinct_streams::DuplexStreamWithDistinctStreamsOutput,
     crate::operation::duplex_stream_with_distinct_streams::DuplexStreamWithDistinctStreamsError,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut output = crate::operation::duplex_stream_with_distinct_streams::builders::DuplexStreamWithDistinctStreamsOutputBuilder::default();
         output = output.set_stream(crate::protocol_serde::shape_duplex_stream_with_distinct_streams_output::de_stream_payload(_response_body)?);
         output.build()
     })
-+
+}

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/protocol_serde/shape_duplex_stream_with_distinct_streams_output.rs

@@ -0,1 +0,14 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub(crate) fn de_stream_payload(
     body: &[u8],
 ) -> std::result::Result<
     ::std::option::Option<crate::types::SingletonEventStream>,
     crate::operation::duplex_stream_with_distinct_streams::DuplexStreamWithDistinctStreamsError,
 > {
     (!body.is_empty())
         .then(|| {
             crate::protocol_serde::shape_singleton_event_stream::de_singleton_event_stream_payload(body)
                 .map_err(crate::operation::duplex_stream_with_distinct_streams::DuplexStreamWithDistinctStreamsError::unhandled)
         })
         .transpose()
-+
+}

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/protocol_serde/shape_duplex_stream_with_initial_messages.rs

@@ -0,1 +0,108 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub fn de_duplex_stream_with_initial_messages_http_response(
     response: &mut ::aws_smithy_runtime_api::http::Response,
 ) -> std::result::Result<
     crate::operation::duplex_stream_with_initial_messages::DuplexStreamWithInitialMessagesOutput,
     crate::operation::duplex_stream_with_initial_messages::DuplexStreamWithInitialMessagesError,
 > {
     let mut _response_body = ::aws_smithy_types::body::SdkBody::taken();
     std::mem::swap(&mut _response_body, response.body_mut());
     let _response_body = &mut _response_body;
-+
     let _response_status = response.status().as_u16();
     let _response_headers = response.headers();
     Ok({
         #[allow(unused_mut)]
         let mut output = crate::operation::duplex_stream_with_initial_messages::builders::DuplexStreamWithInitialMessagesOutputBuilder::default();
         output = output.set_initial_response_member(
             crate::protocol_serde::shape_duplex_stream_with_initial_messages_output::de_initial_response_member_header(_response_headers).map_err(
                 |_| {
                     crate::operation::duplex_stream_with_initial_messages::DuplexStreamWithInitialMessagesError::unhandled(
                         "Failed to parse initialResponseMember from header `initial-response-member",
-+
+                    )
                 },
             )?,
         );
         output = output.set_stream(Some(
             crate::protocol_serde::shape_duplex_stream_with_initial_messages_output::de_stream_payload(_response_body)?,
         ));
         crate::serde_util::duplex_stream_with_initial_messages_output_output_correct_errors(output)
             .build()
             .map_err(crate::operation::duplex_stream_with_initial_messages::DuplexStreamWithInitialMessagesError::unhandled)?
     })
-+
+}
-+
 #[allow(clippy::unnecessary_wraps)]
 pub fn de_duplex_stream_with_initial_messages_http_error(
     _response_status: u16,
     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<
     crate::operation::duplex_stream_with_initial_messages::DuplexStreamWithInitialMessagesOutput,
     crate::operation::duplex_stream_with_initial_messages::DuplexStreamWithInitialMessagesError,
 > {
     #[allow(unused_mut)]
     let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
         .map_err(crate::operation::duplex_stream_with_initial_messages::DuplexStreamWithInitialMessagesError::unhandled)?;
     let generic = generic_builder.build();
     let error_code = match generic.code() {
         Some(code) => code,
         None => return Err(crate::operation::duplex_stream_with_initial_messages::DuplexStreamWithInitialMessagesError::unhandled(generic)),
     };
-+
     let _error_message = generic.message().map(|msg| msg.to_owned());
     Err(match error_code {
         "ServiceUnavailableError" => {
             crate::operation::duplex_stream_with_initial_messages::DuplexStreamWithInitialMessagesError::ServiceUnavailableError({
                 #[allow(unused_mut)]
                 let mut tmp = {
                     #[allow(unused_mut)]
                     let mut output = crate::types::error::builders::ServiceUnavailableErrorBuilder::default();
                     output = crate::protocol_serde::shape_service_unavailable_error::de_service_unavailable_error_json_err(_response_body, output)
                         .map_err(crate::operation::duplex_stream_with_initial_messages::DuplexStreamWithInitialMessagesError::unhandled)?;
                     let output = output.meta(generic);
                     output.build()
                 };
                 if tmp.message.is_none() {
                     tmp.message = _error_message;
-+
+                }
                 tmp
             })
-+
+        }
         "ErrorEvent" => crate::operation::duplex_stream_with_initial_messages::DuplexStreamWithInitialMessagesError::ErrorEvent({
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::ErrorEventBuilder::default();
                 output = crate::protocol_serde::shape_error_event::de_error_event_json_err(_response_body, output)
                     .map_err(crate::operation::duplex_stream_with_initial_messages::DuplexStreamWithInitialMessagesError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             if tmp.message.is_none() {
                 tmp.message = _error_message;
-+
+            }
             tmp
         }),
         _ => crate::operation::duplex_stream_with_initial_messages::DuplexStreamWithInitialMessagesError::generic(generic),
     })
-+
+}
-+
 pub fn ser_duplex_stream_with_initial_messages_headers(
     input: &crate::operation::duplex_stream_with_initial_messages::DuplexStreamWithInitialMessagesInput,
     mut builder: ::http_1x::request::Builder,
 ) -> std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
     if let ::std::option::Option::Some(inner_1) = &input.initial_request_member {
         let formatted_2 = inner_1.as_str();
         let header_value = formatted_2;
         let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
             ::aws_smithy_types::error::operation::BuildError::invalid_field(
                 "initial_request_member",
                 format!("`{}` cannot be used as a header value: {}", &header_value, err),
-+
+            )
         })?;
         builder = builder.header("initial-request-member", header_value);
-+
+    }
     Ok(builder)
-+
+}

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/protocol_serde/shape_duplex_stream_with_initial_messages_output.rs

@@ -0,1 +0,19 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub(crate) fn de_initial_response_member_header(
     header_map: &::aws_smithy_runtime_api::http::Headers,
 ) -> ::std::result::Result<::std::option::Option<::std::string::String>, ::aws_smithy_http::header::ParseError> {
     let headers = header_map.get_all("initial-response-member");
     ::aws_smithy_http::header::one_or_none(headers)
-+
+}
-+
 pub fn de_stream_payload(
     body: &mut ::aws_smithy_types::body::SdkBody,
 ) -> std::result::Result<
     crate::event_receiver::EventReceiver<crate::types::EventStream, crate::types::error::EventStreamError>,
     crate::operation::duplex_stream_with_initial_messages::DuplexStreamWithInitialMessagesError,
 > {
     let unmarshaller = crate::event_stream_serde::EventStreamUnmarshaller::new();
     let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
     let receiver = crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(unmarshaller, body));
     Ok(receiver)
-+
+}

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/protocol_serde/shape_error_event.rs

@@ -0,1 +0,55 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub fn ser_error_event_error(
     value: &crate::types::error::ErrorEvent,
 ) -> ::std::result::Result<String, ::aws_smithy_types::error::operation::SerializationError> {
     let mut out = ::std::string::String::new();
     let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
     crate::protocol_serde::shape_error_event::ser_error_event(&mut object, value)?;
     object.finish();
     Ok(out)
-+
+}
-+
 pub(crate) fn de_error_event_json_err(
     _value: &[u8],
     mut builder: crate::types::error::builders::ErrorEventBuilder,
 ) -> ::std::result::Result<crate::types::error::builders::ErrorEventBuilder, ::aws_smithy_json::deserialize::error::DeserializeError> {
     let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(_value)).peekable();
     let tokens = &mut tokens_owned;
     ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
     loop {
         match tokens.next().transpose()? {
             Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
             Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
                 "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()?,
                     );
-+
+                }
                 _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
             },
             other => {
                 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
                     "expected object key or end object, found: {other:?}"
                 )))
-+
+            }
-+
+        }
-+
+    }
     if tokens.next().is_some() {
         return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
             "found more JSON tokens after completing parsing",
         ));
-+
+    }
     Ok(builder)
-+
+}
-+
 pub fn ser_error_event(
     object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
     input: &crate::types::error::ErrorEvent,
 ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
     if let Some(var_1) = &input.message {
         object.key("message").string(var_1.as_str());
-+
+    }
     Ok(())
-+
+}

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/protocol_serde/shape_headers_and_explicit_payload_event.rs

@@ -0,1 +0,10 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub fn ser_payload_payload(
     input: &crate::types::PayloadStructure,
 ) -> std::result::Result<::std::vec::Vec<u8>, ::aws_smithy_types::error::operation::SerializationError> {
     let mut out = String::new();
     let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
     crate::protocol_serde::shape_payload_structure::ser_payload_structure(&mut object, input)?;
     object.finish();
     Ok(out.into_bytes())
-+
+}

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/protocol_serde/shape_headers_and_implicit_payload_event.rs

@@ -0,1 +0,42 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub(crate) fn de_headers_and_implicit_payload_event_json_err(
     _value: &[u8],
     mut builder: crate::types::builders::HeadersAndImplicitPayloadEventBuilder,
 ) -> ::std::result::Result<crate::types::builders::HeadersAndImplicitPayloadEventBuilder, ::aws_smithy_json::deserialize::error::DeserializeError> {
     let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(_value)).peekable();
     let tokens = &mut tokens_owned;
     ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
     loop {
         match tokens.next().transpose()? {
             Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
             Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
                 "header" => {
                     builder = builder.set_header(
                         ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                             .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                             .transpose()?,
                     );
-+
+                }
                 "payload" => {
                     builder = builder.set_payload(
                         ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
                             .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                             .transpose()?,
                     );
-+
+                }
                 _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
             },
             other => {
                 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
                     "expected object key or end object, found: {other:?}"
                 )))
-+
+            }
-+
+        }
-+
+    }
     if tokens.next().is_some() {
         return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
             "found more JSON tokens after completing parsing",
         ));
-+
+    }
     Ok(builder)
-+
+}

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/protocol_serde/shape_http_query_params_only_operation.rs

Renamed from tmp-codegen-diff/codegen-client-test/rest_json_extras/rust-client-codegen/src/protocol_serde/shape_http_query_params_only_operation.rs

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

↥ Expand context

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub fn de_http_query_params_only_operation_http_error(
     _response_status: u16,

     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<
     crate::operation::http_query_params_only_operation::HttpQueryParamsOnlyOperationOutput,
     crate::operation::http_query_params_only_operation::HttpQueryParamsOnlyOperationError,
 > {
     #[allow(unused_mut)]
     let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
         .map_err(crate::operation::http_query_params_only_operation::HttpQueryParamsOnlyOperationError::unhandled)?;
     let generic = generic_builder.build();
     let error_code = match generic.code() {
         Some(code) => code,
         None => return Err(crate::operation::http_query_params_only_operation::HttpQueryParamsOnlyOperationError::unhandled(generic)),
     };
--
     let _error_message = generic.message().map(|msg| msg.to_owned());
     Err(match error_code {
         "ExtraError" => crate::operation::http_query_params_only_operation::HttpQueryParamsOnlyOperationError::ExtraError({
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::ExtraErrorBuilder::default();
                 output = crate::protocol_serde::shape_extra_error::de_extra_error_json_err(_response_body, output)
                     .map_err(crate::operation::http_query_params_only_operation::HttpQueryParamsOnlyOperationError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             if tmp.message.is_none() {
                 tmp.message = _error_message;
--
+            }
             tmp
         }),
         _ => crate::operation::http_query_params_only_operation::HttpQueryParamsOnlyOperationError::generic(generic),
     })
     Err(crate::operation::http_query_params_only_operation::HttpQueryParamsOnlyOperationError::generic(generic))
-16
+}
-17
 #[allow(clippy::unnecessary_wraps)]
 pub fn de_http_query_params_only_operation_http_response(
     _response_status: u16,
     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<
     crate::operation::http_query_params_only_operation::HttpQueryParamsOnlyOperationOutput,
     crate::operation::http_query_params_only_operation::HttpQueryParamsOnlyOperationError,

↧ Expand context

 > {
     Ok({
         #[allow(unused_mut)]
         let mut output = crate::operation::http_query_params_only_operation::builders::HttpQueryParamsOnlyOperationOutputBuilder::default();
         output.build()
     })
-32
+}

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/protocol_serde/shape_input_stream.rs

@@ -0,1 +0,49 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub fn de_input_stream_http_error(
     _response_status: u16,
     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<crate::operation::input_stream::InputStreamOutput, crate::operation::input_stream::InputStreamError> {
     #[allow(unused_mut)]
     let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
         .map_err(crate::operation::input_stream::InputStreamError::unhandled)?;
     let generic = generic_builder.build();
     let error_code = match generic.code() {
         Some(code) => code,
         None => return Err(crate::operation::input_stream::InputStreamError::unhandled(generic)),
     };
-+
     let _error_message = generic.message().map(|msg| msg.to_owned());
     Err(match error_code {
         "ErrorEvent" => crate::operation::input_stream::InputStreamError::ErrorEvent({
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::ErrorEventBuilder::default();
                 output = crate::protocol_serde::shape_error_event::de_error_event_json_err(_response_body, output)
                     .map_err(crate::operation::input_stream::InputStreamError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             if tmp.message.is_none() {
                 tmp.message = _error_message;
-+
+            }
             tmp
         }),
         _ => crate::operation::input_stream::InputStreamError::generic(generic),
     })
-+
+}
-+
 #[allow(clippy::unnecessary_wraps)]
 pub fn de_input_stream_http_response(
     _response_status: u16,
     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<crate::operation::input_stream::InputStreamOutput, crate::operation::input_stream::InputStreamError> {
     Ok({
         #[allow(unused_mut)]
         let mut output = crate::operation::input_stream::builders::InputStreamOutputBuilder::default();
         output.build()
     })
-+
+}

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/protocol_serde/shape_input_stream_with_initial_request.rs

@@ -0,1 +0,73 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub fn de_input_stream_with_initial_request_http_error(
     _response_status: u16,
     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<
     crate::operation::input_stream_with_initial_request::InputStreamWithInitialRequestOutput,
     crate::operation::input_stream_with_initial_request::InputStreamWithInitialRequestError,
 > {
     #[allow(unused_mut)]
     let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
         .map_err(crate::operation::input_stream_with_initial_request::InputStreamWithInitialRequestError::unhandled)?;
     let generic = generic_builder.build();
     let error_code = match generic.code() {
         Some(code) => code,
         None => return Err(crate::operation::input_stream_with_initial_request::InputStreamWithInitialRequestError::unhandled(generic)),
     };
-+
     let _error_message = generic.message().map(|msg| msg.to_owned());
     Err(match error_code {
         "ErrorEvent" => crate::operation::input_stream_with_initial_request::InputStreamWithInitialRequestError::ErrorEvent({
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::ErrorEventBuilder::default();
                 output = crate::protocol_serde::shape_error_event::de_error_event_json_err(_response_body, output)
                     .map_err(crate::operation::input_stream_with_initial_request::InputStreamWithInitialRequestError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             if tmp.message.is_none() {
                 tmp.message = _error_message;
-+
+            }
             tmp
         }),
         _ => crate::operation::input_stream_with_initial_request::InputStreamWithInitialRequestError::generic(generic),
     })
-+
+}
-+
 #[allow(clippy::unnecessary_wraps)]
 pub fn de_input_stream_with_initial_request_http_response(
     _response_status: u16,
     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<
     crate::operation::input_stream_with_initial_request::InputStreamWithInitialRequestOutput,
     crate::operation::input_stream_with_initial_request::InputStreamWithInitialRequestError,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut output = crate::operation::input_stream_with_initial_request::builders::InputStreamWithInitialRequestOutputBuilder::default();
         output.build()
     })
-+
+}
-+
 pub fn ser_input_stream_with_initial_request_headers(
     input: &crate::operation::input_stream_with_initial_request::InputStreamWithInitialRequestInput,
     mut builder: ::http_1x::request::Builder,
 ) -> std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
     if let ::std::option::Option::Some(inner_1) = &input.initial_request_member {
         let formatted_2 = inner_1.as_str();
         let header_value = formatted_2;
         let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
             ::aws_smithy_types::error::operation::BuildError::invalid_field(
                 "initial_request_member",
                 format!("`{}` cannot be used as a header value: {}", &header_value, err),
-+
+            )
         })?;
         builder = builder.header("initial-request-member", header_value);
-+
+    }
     Ok(builder)
-+
+}

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/protocol_serde/shape_output_stream.rs

@@ -0,1 +0,71 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub fn de_output_stream_http_response(
     response: &mut ::aws_smithy_runtime_api::http::Response,
 ) -> std::result::Result<crate::operation::output_stream::OutputStreamOutput, crate::operation::output_stream::OutputStreamError> {
     let mut _response_body = ::aws_smithy_types::body::SdkBody::taken();
     std::mem::swap(&mut _response_body, response.body_mut());
     let _response_body = &mut _response_body;
-+
     let _response_status = response.status().as_u16();
     let _response_headers = response.headers();
     Ok({
         #[allow(unused_mut)]
         let mut output = crate::operation::output_stream::builders::OutputStreamOutputBuilder::default();
         output = output.set_stream(Some(crate::protocol_serde::shape_output_stream_output::de_stream_payload(
             _response_body,
         )?));
         output.build().map_err(crate::operation::output_stream::OutputStreamError::unhandled)?
     })
-+
+}
-+
 #[allow(clippy::unnecessary_wraps)]
 pub fn de_output_stream_http_error(
     _response_status: u16,
     _response_headers: &::aws_smithy_runtime_api::http::Headers,
     _response_body: &[u8],
 ) -> std::result::Result<crate::operation::output_stream::OutputStreamOutput, crate::operation::output_stream::OutputStreamError> {
     #[allow(unused_mut)]
     let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
         .map_err(crate::operation::output_stream::OutputStreamError::unhandled)?;
     let generic = generic_builder.build();
     let error_code = match generic.code() {
         Some(code) => code,
         None => return Err(crate::operation::output_stream::OutputStreamError::unhandled(generic)),
     };
-+
     let _error_message = generic.message().map(|msg| msg.to_owned());
     Err(match error_code {
         "ServiceUnavailableError" => crate::operation::output_stream::OutputStreamError::ServiceUnavailableError({
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::ServiceUnavailableErrorBuilder::default();
                 output = crate::protocol_serde::shape_service_unavailable_error::de_service_unavailable_error_json_err(_response_body, output)
                     .map_err(crate::operation::output_stream::OutputStreamError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             if tmp.message.is_none() {
                 tmp.message = _error_message;
-+
+            }
             tmp
         }),
         "ErrorEvent" => crate::operation::output_stream::OutputStreamError::ErrorEvent({
             #[allow(unused_mut)]
             let mut tmp = {
                 #[allow(unused_mut)]
                 let mut output = crate::types::error::builders::ErrorEventBuilder::default();
                 output = crate::protocol_serde::shape_error_event::de_error_event_json_err(_response_body, output)
                     .map_err(crate::operation::output_stream::OutputStreamError::unhandled)?;
                 let output = output.meta(generic);
                 output.build()
             };
             if tmp.message.is_none() {
                 tmp.message = _error_message;
-+
+            }
             tmp
         }),
         _ => crate::operation::output_stream::OutputStreamError::generic(generic),
     })
-+
+}

Pages: 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62