Server Test

rev. d838bf488731ae5e751cce0fe13f339a5b9be858 (ignoring whitespace)

Files changed:

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

@@ -1,1 +95,107 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub(crate) mod shape_all_query_string_types;
-3
 pub(crate) mod shape_constant_and_variable_query_string;
-5
 pub(crate) mod shape_constant_query_string;
-7

 pub(crate) mod shape_content_type_parameters;
-9
 pub(crate) mod shape_datetime_offsets;
-11
 pub(crate) mod shape_document_type;
-13
 pub(crate) mod shape_document_type_as_map_value;
-15
 pub(crate) mod shape_document_type_as_payload;
-17
 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;
-25
 pub(crate) mod shape_endpoint_operation;
-27
 pub(crate) mod shape_endpoint_with_host_label_operation;
-29
 pub(crate) mod shape_fractional_seconds;
-31
 pub(crate) mod shape_greeting_with_errors;
-33
 pub(crate) mod shape_host_with_path_operation;
-35
 pub(crate) mod shape_http_checksum_required;
-37
 pub(crate) mod shape_http_empty_prefix_headers;
-39
 pub(crate) mod shape_http_enum_payload;
-41
 pub(crate) mod shape_http_payload_traits;
-43
 pub(crate) mod shape_http_payload_traits_with_media_type;
-45
 pub(crate) mod shape_http_payload_with_structure;
-47
 pub(crate) mod shape_http_payload_with_union;
-49
 pub(crate) mod shape_http_prefix_headers;
-51
 pub(crate) mod shape_http_prefix_headers_in_response;
-53
 pub(crate) mod shape_http_query_params_only_operation;
-+
 pub(crate) mod shape_http_request_with_float_labels;
-57
 pub(crate) mod shape_http_request_with_greedy_label_in_path;
-59
 pub(crate) mod shape_http_request_with_labels;
-61
 pub(crate) mod shape_http_request_with_labels_and_timestamp_format;
-63
 pub(crate) mod shape_http_request_with_regex_literal;
-65
 pub(crate) mod shape_http_response_code;
-67
 pub(crate) mod shape_http_string_payload;
-69
 pub(crate) mod shape_ignore_query_params_in_response;
-71
 pub(crate) mod shape_input_and_output_with_headers;
-73
 pub(crate) mod shape_input_stream;
-+
 pub(crate) mod shape_input_stream_with_initial_request;
-+
 pub(crate) mod shape_json_blobs;
-79
 pub(crate) mod shape_json_enums;
-81
 pub(crate) mod shape_json_int_enums;
-83
 pub(crate) mod shape_json_lists;
-85
 pub(crate) mod shape_json_maps;
-87

↧ Expand context

 pub(crate) mod shape_json_timestamps;
-89
 pub(crate) mod shape_json_unions;
-91
 pub(crate) mod shape_malformed_accept_with_body;
-93
 pub(crate) mod shape_malformed_accept_with_generic_string;
-95
 pub(crate) mod shape_malformed_accept_with_payload;
-97
 pub(crate) mod shape_malformed_blob;
-99
 pub(crate) mod shape_malformed_boolean;
-101
 pub(crate) mod shape_malformed_byte;
-103
 pub(crate) mod shape_malformed_content_type_with_body;
-105
 pub(crate) mod shape_malformed_content_type_with_generic_string;
-107

@@ -134,146 +193,209 @@

↥ Expand context

 pub(crate) mod shape_malformed_timestamp_path_epoch;
-147
 pub(crate) mod shape_malformed_timestamp_path_http_date;
-149
 pub(crate) mod shape_malformed_timestamp_query_default;
-151
 pub(crate) mod shape_malformed_timestamp_query_epoch;
-153
 pub(crate) mod shape_malformed_timestamp_query_http_date;
-155
 pub(crate) mod shape_malformed_union;
-157
 pub(crate) mod shape_media_type_header;
-159
 pub(crate) mod shape_no_input_and_no_output;
-161
 pub(crate) mod shape_no_input_and_output;
-163
 pub(crate) mod shape_null_and_empty_headers_client;
-165

 pub(crate) mod shape_null_and_empty_headers_server;
-167
 pub(crate) mod shape_omits_null_serializes_empty_string;
-169
 pub(crate) mod shape_omits_serializing_empty_lists;
-171
 pub(crate) mod shape_operation_with_defaults;
-173
 pub(crate) mod shape_operation_with_nested_structure;
-175
 pub(crate) mod shape_output_stream;
-+
 pub(crate) mod shape_output_stream_with_initial_response;
-+
 pub(crate) mod shape_post_player_action;
-181
 pub(crate) mod shape_post_union_with_json_name;
-183
 pub(crate) mod shape_put_with_content_encoding;
-185
 pub(crate) mod shape_query_idempotency_token_auto_fill;
-187
 pub(crate) mod shape_query_params_as_string_list_map;
-189

↧ Expand context

 pub(crate) mod shape_query_precedence;
-191
 pub(crate) mod shape_recursive_shapes;
-193
 pub(crate) mod shape_response_code_http_fallback;
-195
 pub(crate) mod shape_response_code_required;
-197
 pub(crate) mod shape_simple_scalar_properties;
-199
 pub(crate) mod shape_sparse_json_lists;
-201
 pub(crate) mod shape_sparse_json_maps;
-203
 pub(crate) mod shape_streaming_traits;
-205
 pub(crate) mod shape_streaming_traits_require_length;
-207
 pub(crate) mod shape_streaming_traits_with_media_type;
-209

@@ -218,234 +349,379 @@

↥ Expand context

 pub(crate) mod shape_constant_query_string_input;
-235
 /* JsonParserGenerator.kt:232 */
 pub(crate) fn or_empty_doc(data: &[u8]) -> &[u8] {
     if data.is_empty() {
         b"{}"
     } else {
         data
-242
+    }
-243
+}
-244
 pub(crate) mod shape_content_type_parameters_output;
-246
 pub(crate) mod shape_datetime_offsets_output;
-248
 pub(crate) mod shape_document_type_as_map_value_output;
-250
 pub(crate) mod shape_document_type_as_payload_input;
-252
 /* JsonSerializerGenerator.kt:305 */

 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()
-258
+}
-259
 pub(crate) mod shape_document_type_as_payload_output;
-261
 pub(crate) mod shape_document_type_output;
-263
 pub(crate) mod shape_duplex_stream_input;
-+
 pub(crate) mod shape_duplex_stream_with_distinct_streams_input;
-+
 /* JsonSerializerGenerator.kt:274 */
 pub fn rest_json_unset_union_payload() -> ::std::vec::Vec<u8> {
     ::std::vec::Vec::new()
-+
+}
-+
 pub(crate) mod shape_duplex_stream_with_distinct_streams_output;
-+
 pub(crate) mod shape_duplex_stream_with_initial_messages_input;
-+
 pub(crate) mod shape_empty_input_and_empty_output_output;
-278
 pub(crate) mod shape_error_event;
-+
 pub(crate) mod shape_foo_error;
-282
 pub(crate) mod shape_fractional_seconds_output;
-284
 pub(crate) mod shape_greeting_with_errors_output;
-286
 pub(crate) mod shape_http_checksum_required_output;
-288
 pub(crate) mod shape_http_empty_prefix_headers_input;
-290
 pub(crate) mod shape_http_empty_prefix_headers_output;
-292
 pub(crate) mod shape_http_enum_payload_input;
-294
 pub(crate) mod shape_http_enum_payload_output;
-296
 pub(crate) mod shape_http_payload_traits_input;
-298
 pub(crate) mod shape_http_payload_traits_output;
-300
 pub(crate) mod shape_http_payload_traits_with_media_type_input;
-302
 pub(crate) mod shape_http_payload_traits_with_media_type_output;
-304
 pub(crate) mod shape_http_payload_with_structure_input;
-306
 /* JsonSerializerGenerator.kt:262 */
 pub fn rest_json_unset_struct_payload() -> ::std::vec::Vec<u8> {
     b"{}"[..].into()
-310
+}
-311
 pub(crate) mod shape_http_payload_with_structure_output;
-313
 pub(crate) mod shape_http_payload_with_union_input;
-315
 /* JsonSerializerGenerator.kt:274 */
 pub fn rest_json_unset_union_payload() -> ::std::vec::Vec<u8> {
     ::std::vec::Vec::new()
--
+}
--
 pub(crate) mod shape_http_payload_with_union_output;
-317
 pub(crate) mod shape_http_prefix_headers_in_response_output;
-319
 pub(crate) mod shape_http_prefix_headers_input;
-321
 pub(crate) mod shape_http_prefix_headers_output;
-323
 pub(crate) mod shape_http_request_with_float_labels_input;
-325
 pub(crate) mod shape_http_request_with_greedy_label_in_path_input;
-327
 pub(crate) mod shape_http_request_with_labels_and_timestamp_format_input;
-329
 pub(crate) mod shape_http_request_with_labels_input;
-331
 pub(crate) mod shape_http_request_with_regex_literal_input;
-333
 pub(crate) mod shape_http_response_code_output;
-335
 pub(crate) mod shape_http_string_payload_input;
-337
 pub(crate) mod shape_http_string_payload_output;
-339
 pub(crate) mod shape_ignore_query_params_in_response_output;
-341
 pub(crate) mod shape_input_and_output_with_headers_input;
-343
 pub(crate) mod shape_input_and_output_with_headers_output;
-345
 pub(crate) mod shape_input_stream_input;
-+
 pub(crate) mod shape_input_stream_with_initial_request_input;
-+
 pub(crate) mod shape_invalid_greeting;
-351
 pub(crate) mod shape_json_blobs_output;
-353
 pub(crate) mod shape_json_enums_output;
-355
 pub(crate) mod shape_json_int_enums_output;
-357
 pub(crate) mod shape_json_lists_output;
-359

↧ Expand context

 pub(crate) mod shape_json_maps_output;
-361
 pub(crate) mod shape_json_timestamps_output;
-363
 pub(crate) mod shape_json_unions_output;
-365
 pub(crate) mod shape_malformed_accept_with_body_output;
-367
 pub(crate) mod shape_malformed_accept_with_generic_string_output;
-369
 pub(crate) mod shape_malformed_accept_with_payload_output;
-371
 pub(crate) mod shape_malformed_boolean_input;
-373
 pub(crate) mod shape_malformed_byte_input;
-375
 pub(crate) mod shape_malformed_content_type_with_generic_string_input;
-377
 pub(crate) mod shape_malformed_content_type_with_payload_input;
-379

@@ -390,420 +449,481 @@

↥ Expand context

 pub(crate) mod shape_null_and_empty_headers_client_output;
-421
 pub(crate) mod shape_null_and_empty_headers_server_input;
-423
 pub(crate) mod shape_null_and_empty_headers_server_output;
-425
 pub(crate) mod shape_omits_null_serializes_empty_string_input;
-427
 pub(crate) mod shape_operation_with_defaults_output;
-429
 pub(crate) mod shape_operation_with_nested_structure_output;
-431
 pub(crate) mod shape_post_player_action_output;
-433
 pub(crate) mod shape_post_union_with_json_name_output;
-435
 pub(crate) mod shape_put_with_content_encoding_input;
-437
 pub(crate) mod shape_query_idempotency_token_auto_fill_input;
-439

 pub(crate) mod shape_query_params_as_string_list_map_input;
-441
 pub(crate) mod shape_query_precedence_input;
-443
 pub(crate) mod shape_recursive_shapes_output;
-445
 pub(crate) mod shape_response_code_http_fallback_output;
-447
 pub(crate) mod shape_response_code_required_output;
-449
 pub(crate) mod shape_service_unavailable_error;
-+
 pub(crate) mod shape_simple_scalar_properties_input;
-453
 pub(crate) mod shape_simple_scalar_properties_output;
-455
 pub(crate) mod shape_sparse_json_lists_output;
-457
 pub(crate) mod shape_sparse_json_maps_output;
-459
 pub(crate) mod shape_streaming_traits_input;
-461

↧ Expand context

 pub(crate) mod shape_streaming_traits_output;
-463
 pub(crate) mod shape_streaming_traits_require_length_input;
-465
 pub(crate) mod shape_streaming_traits_with_media_type_input;
-467
 pub(crate) mod shape_streaming_traits_with_media_type_output;
-469
 pub(crate) mod shape_test_body_structure_input;
-471
 pub(crate) mod shape_test_body_structure_output;
-473
 pub(crate) mod shape_test_get_no_input_no_payload_output;
-475
 pub(crate) mod shape_test_get_no_payload_input;
-477
 pub(crate) mod shape_test_get_no_payload_output;
-479
 pub(crate) mod shape_test_payload_blob_input;
-481

@@ -464,496 +0,622 @@

↥ Expand context

 pub(crate) mod shape_timestamp_format_headers_output;
-497
 pub(crate) mod shape_validation_exception;
-499
 pub(crate) mod shape_boolean_list;
-501
 pub(crate) mod shape_client_optional_defaults;
-503
 pub(crate) mod shape_defaults;
-505
 pub(crate) mod shape_dense_boolean_map;
-507
 pub(crate) mod shape_dense_number_map;
-509
 pub(crate) mod shape_dense_set_map;
-511
 pub(crate) mod shape_dense_string_map;
-513
 pub(crate) mod shape_dense_struct_map;
-515

 pub(crate) mod shape_document;
-517
 pub(crate) mod shape_document_valued_map;
-519
 pub(crate) mod shape_foo_enum_list;
-521
 pub(crate) mod shape_foo_enum_map;
-523
 pub(crate) mod shape_foo_enum_set;
-525
 pub(crate) mod shape_headers_and_explicit_payload_event;
-+
 pub(crate) mod shape_integer_enum_list;
-529
 pub(crate) mod shape_integer_enum_map;
-531
 pub(crate) mod shape_integer_enum_set;
-533
 pub(crate) mod shape_integer_list;
-535
 pub(crate) mod shape_my_union;
-537
 pub(crate) mod shape_nested_payload;
-539
 pub(crate) mod shape_nested_string_list;
-541
 pub(crate) mod shape_payload_config;
-543
 pub(crate) mod shape_player_action;
-545
 pub(crate) mod shape_recursive_shapes_input_output_nested1;
-547
 pub(crate) mod shape_simple_list;
-549
 pub(crate) mod shape_simple_map;
-551
 pub(crate) mod shape_simple_union;
-553
 pub(crate) mod shape_sparse_boolean_map;
-555
 pub(crate) mod shape_sparse_number_map;
-557
 pub(crate) mod shape_sparse_set_map;
-559
 pub(crate) mod shape_sparse_short_list;
-561
 pub(crate) mod shape_sparse_string_list;
-563
 pub(crate) mod shape_sparse_string_map;
-565
 pub(crate) mod shape_sparse_struct_map;
-567
 pub(crate) mod shape_string_list;
-569
 pub(crate) mod shape_string_set;
-571
 pub(crate) mod shape_structure_list;
-573
 pub(crate) mod shape_structure_payload_event;
-+
 pub(crate) mod shape_test_config;
-577
 pub(crate) mod shape_timestamp_list;
-579
 pub(crate) mod shape_top_level;
-581
 pub(crate) mod shape_union_payload;
-583
 pub(crate) mod shape_union_payload_event;
-+
 pub(crate) mod shape_union_with_json_name;
-587
 pub(crate) mod shape_complex_nested_error_data;
-589
 pub(crate) mod shape_dialog;
-591
 pub(crate) mod shape_dialog_list;
-593
 pub(crate) mod shape_dialog_map;
-595
 pub(crate) mod shape_greeting_struct;
-597
 pub(crate) mod shape_headers_and_implicit_payload_event;
-+
 pub(crate) mod shape_payload_structure;
-+
 pub(crate) mod shape_payload_union;
-+
 pub(crate) mod shape_recursive_shapes_input_output_nested2;
-605
 pub(crate) mod shape_renamed_greeting;
-607
 pub(crate) mod shape_singleton_event_stream;
-+
 pub(crate) mod shape_string_map;
-611
 pub(crate) mod shape_structure_list_member;
-613
 pub(crate) mod shape_test_string_list;
-615
 pub(crate) mod shape_test_string_map;
-617
 pub(crate) mod shape_validation_exception_field;
-619
 pub(crate) mod shape_farewell;
-+
 pub(crate) mod shape_singleton_event;

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

@@ -0,1 +0,187 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:412 */
 pub async fn de_duplex_stream_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::DuplexStreamInput,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-+
+>
 where
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: Into<::aws_smithy_types::byte_stream::ByteStream>,
     B::Data: Send,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-+
+{
     /* ServerHttpBoundProtocolGenerator.kt:428 */
     Ok({
         /* RustType.kt:534 */
         #[allow(unused_mut)]
         /* ServerHttpBoundProtocolGenerator.kt:773 */
         let mut input = crate::input::duplex_stream_input::Builder::default();
         /* RustType.kt:534 */
         #[allow(unused_variables)]
         /* ServerHttpBoundProtocolGenerator.kt:778 */
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         /* ServerHttpBoundProtocolGenerator.kt:870 */
         if let Some(value) = {
             let mut receiver = crate::protocol_serde::shape_duplex_stream_input::de_stream_payload(
                 &mut body.into().into_inner(),
             )?;
             if let Some(_initial_event) = receiver
                                                 .try_recv_initial(::aws_smithy_legacy_http::event_stream::InitialMessageType::Request)
                                                 .await
                                                 .map_err(
                                                     |ev_error| ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection::ConstraintViolation(
                                                         #[allow(clippy::useless_conversion)]
                                                         format!("{ev_error}").into()
-+
+                                                    )
                                                 )? {
-+
-+
+                                            }
             Some(receiver)
         } {
             input = input.set_stream(value)
-+
+        }
         /* ServerHttpBoundProtocolGenerator.kt:910 */
         input.build()?
         /* ServerHttpBoundProtocolGenerator.kt:428 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:412 */
-+
+}
-+
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:449 */
 pub fn ser_duplex_stream_http_response(
     #[allow(unused_variables)] output: crate::output::DuplexStreamOutput,
 ) -> std::result::Result<
     ::aws_smithy_legacy_http_server::response::Response,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     /* ServerHttpBoundProtocolGenerator.kt:461 */
     Ok({
         /* RustType.kt:534 */
         #[allow(unused_mut)]
         /* ServerHttpBoundProtocolGenerator.kt:551 */
         let mut builder = ::http::Response::builder();
         /* ServerHttpBoundProtocolGenerator.kt:647 */
         builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/vnd.amazon.eventstream",
         );
         /* ServerHttpBoundProtocolGenerator.kt:732 */
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         /* ServerHttpBoundProtocolGenerator.kt:589 */
         let body = ::aws_smithy_legacy_http_server::body::boxed(
             ::aws_smithy_legacy_http_server::body::Body::wrap_stream(
                 /* ServerHttpBoundProtocolGenerator.kt:145 */
-+
+                {
                     let error_marshaller =
                         crate::event_stream_serde::EventStreamErrorMarshaller::new();
                     let marshaller = crate::event_stream_serde::EventStreamMarshaller::new();
                     let signer = ::aws_smithy_eventstream::frame::NoOpSigner {};
                     output
                         .stream
                         .into_body_stream(marshaller, error_marshaller, signer)
                 }, /* ServerHttpBoundProtocolGenerator.kt:589 */
             ),
         );
         /* ServerHttpBoundProtocolGenerator.kt:625 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:461 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:449 */
-+
+}
-+
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:475 */
 pub fn ser_duplex_stream_http_error(
     error: &crate::error::DuplexStreamError,
 ) -> std::result::Result<
     ::aws_smithy_legacy_http_server::response::Response,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     /* ServerHttpBoundProtocolGenerator.kt:480 */
     Ok({
         /* ServerHttpBoundProtocolGenerator.kt:496 */
         match error {
             /* ServerHttpBoundProtocolGenerator.kt:504 */
             crate::error::DuplexStreamError::ValidationException(output) => {
                 /* ServerHttpBoundProtocolGenerator.kt:505 */
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 /* RustType.kt:534 */
                 #[allow(unused_mut)]
                 /* ServerHttpBoundProtocolGenerator.kt:515 */
                 let mut builder = ::http::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:647 */
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:647 */
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "ValidationException",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:713 */
                 let content_length = payload.len();
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:532 */
                 builder
                     .status(400)
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
                 /* ServerHttpBoundProtocolGenerator.kt:504 */
-+
+            }
             /* ServerHttpBoundProtocolGenerator.kt:504 */
             crate::error::DuplexStreamError::ErrorEvent(output) => {
                 /* ServerHttpBoundProtocolGenerator.kt:505 */
                 let payload =
                     crate::protocol_serde::shape_error_event::ser_error_event_error(output)?;
                 /* RustType.kt:534 */
                 #[allow(unused_mut)]
                 /* ServerHttpBoundProtocolGenerator.kt:515 */
                 let mut builder = ::http::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:647 */
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:647 */
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "ErrorEvent",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:713 */
                 let content_length = payload.len();
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:532 */
                 builder
                     .status(400)
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
                 /* ServerHttpBoundProtocolGenerator.kt:504 */
             } /* ServerHttpBoundProtocolGenerator.kt:496 */
-+
+        }
         /* ServerHttpBoundProtocolGenerator.kt:480 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:475 */
-+
+}

tmp-codegen-diff/codegen-server-test/rest_json-http0x/rust-server-codegen/src/protocol_serde/shape_duplex_stream_input.rs

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

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* HttpBindingGenerator.kt:236 */
 pub fn de_stream_payload(
     body: &mut ::aws_smithy_types::body::SdkBody,
 ) -> std::result::Result<
     crate::sigv4_event_stream::SigV4Receiver<
         crate::model::EventStream,
         crate::error::EventStreamError,
     >,
     ::aws_smithy_json::deserialize::error::DeserializeError,
 > {
     /* HttpBindingGenerator.kt:278 */
     let unmarshaller = crate::event_stream_serde::EventStreamUnmarshaller::new();
     /* HttpBindingGenerator.kt:296 */
     let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
     let receiver = crate::sigv4_event_stream::SigV4Receiver::new(unmarshaller, body);
     Ok(receiver)
     /* HttpBindingGenerator.kt:236 */
-+
+}

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

@@ -0,1 +0,183 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:412 */
 pub async fn de_duplex_stream_with_distinct_streams_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::DuplexStreamWithDistinctStreamsInput,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-+
+>
 where
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: Into<::aws_smithy_types::byte_stream::ByteStream>,
     B::Data: Send,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-+
+{
     /* ServerHttpBoundProtocolGenerator.kt:428 */
     Ok({
         /* RustType.kt:534 */
         #[allow(unused_mut)]
         /* ServerHttpBoundProtocolGenerator.kt:773 */
         let mut input = crate::input::duplex_stream_with_distinct_streams_input::Builder::default();
         /* RustType.kt:534 */
         #[allow(unused_variables)]
         /* ServerHttpBoundProtocolGenerator.kt:778 */
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         /* ServerHttpBoundProtocolGenerator.kt:870 */
         if let Some(value) = {
             let mut receiver = crate::protocol_serde::shape_duplex_stream_with_distinct_streams_input::de_stream_payload(&mut body.into().into_inner())?;
             if let Some(_initial_event) = receiver
                                                 .try_recv_initial(::aws_smithy_legacy_http::event_stream::InitialMessageType::Request)
                                                 .await
                                                 .map_err(
                                                     |ev_error| ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection::ConstraintViolation(
                                                         #[allow(clippy::useless_conversion)]
                                                         format!("{ev_error}").into()
-+
+                                                    )
                                                 )? {
-+
-+
+                                            }
             Some(receiver)
         } {
             input = input.set_stream(value)
-+
+        }
         /* ServerHttpBoundProtocolGenerator.kt:910 */
         input.build()?
         /* ServerHttpBoundProtocolGenerator.kt:428 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:412 */
-+
+}
-+
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:449 */
 pub fn ser_duplex_stream_with_distinct_streams_http_response(
     #[allow(unused_variables)] output: crate::output::DuplexStreamWithDistinctStreamsOutput,
 ) -> std::result::Result<
     ::aws_smithy_legacy_http_server::response::Response,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     /* ServerHttpBoundProtocolGenerator.kt:461 */
     Ok({
         /* RustType.kt:534 */
         #[allow(unused_mut)]
         /* ServerHttpBoundProtocolGenerator.kt:551 */
         let mut builder = ::http::Response::builder();
         /* ServerHttpBoundProtocolGenerator.kt:647 */
         builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/json",
         );
         /* ServerHttpBoundProtocolGenerator.kt:732 */
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         /* ServerHttpBoundProtocolGenerator.kt:611 */
         let payload =
             /* HttpBoundProtocolPayloadGenerator.kt:353 */crate::protocol_serde::shape_duplex_stream_with_distinct_streams_output::ser_stream_http_payload(& output.stream)?
         /* ServerHttpBoundProtocolGenerator.kt:611 */;
         /* ServerHttpBoundProtocolGenerator.kt:713 */
         let content_length = payload.len();
         builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             content_length,
         );
         /* ServerHttpBoundProtocolGenerator.kt:617 */
         let body = ::aws_smithy_legacy_http_server::body::to_boxed(payload);
         /* ServerHttpBoundProtocolGenerator.kt:625 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:461 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:449 */
-+
+}
-+
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:475 */
 pub fn ser_duplex_stream_with_distinct_streams_http_error(
     error: &crate::error::DuplexStreamWithDistinctStreamsError,
 ) -> std::result::Result<
     ::aws_smithy_legacy_http_server::response::Response,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     /* ServerHttpBoundProtocolGenerator.kt:480 */
     Ok({
         /* ServerHttpBoundProtocolGenerator.kt:496 */
         match error {
             /* ServerHttpBoundProtocolGenerator.kt:504 */
             crate::error::DuplexStreamWithDistinctStreamsError::ValidationException(output) => {
                 /* ServerHttpBoundProtocolGenerator.kt:505 */
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 /* RustType.kt:534 */
                 #[allow(unused_mut)]
                 /* ServerHttpBoundProtocolGenerator.kt:515 */
                 let mut builder = ::http::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:647 */
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/json",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:647 */
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "ValidationException",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:713 */
                 let content_length = payload.len();
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:532 */
                 builder
                     .status(400)
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
                 /* ServerHttpBoundProtocolGenerator.kt:504 */
-+
+            }
             /* ServerHttpBoundProtocolGenerator.kt:504 */
             crate::error::DuplexStreamWithDistinctStreamsError::ErrorEvent(output) => {
                 /* ServerHttpBoundProtocolGenerator.kt:505 */
                 let payload =
                     crate::protocol_serde::shape_error_event::ser_error_event_error(output)?;
                 /* RustType.kt:534 */
                 #[allow(unused_mut)]
                 /* ServerHttpBoundProtocolGenerator.kt:515 */
                 let mut builder = ::http::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:647 */
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/json",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:647 */
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "ErrorEvent",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:713 */
                 let content_length = payload.len();
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:532 */
                 builder
                     .status(400)
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
                 /* ServerHttpBoundProtocolGenerator.kt:504 */
             } /* ServerHttpBoundProtocolGenerator.kt:496 */
-+
+        }
         /* ServerHttpBoundProtocolGenerator.kt:480 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:475 */
-+
+}

tmp-codegen-diff/codegen-server-test/rest_json-http0x/rust-server-codegen/src/protocol_serde/shape_duplex_stream_with_distinct_streams_input.rs

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

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* HttpBindingGenerator.kt:236 */
 pub fn de_stream_payload(
     body: &mut ::aws_smithy_types::body::SdkBody,
 ) -> std::result::Result<
     crate::sigv4_event_stream::SigV4Receiver<
         crate::model::EventStream,
         crate::error::EventStreamError,
     >,
     ::aws_smithy_json::deserialize::error::DeserializeError,
 > {
     /* HttpBindingGenerator.kt:278 */
     let unmarshaller = crate::event_stream_serde::EventStreamUnmarshaller::new();
     /* HttpBindingGenerator.kt:296 */
     let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
     let receiver = crate::sigv4_event_stream::SigV4Receiver::new(unmarshaller, body);
     Ok(receiver)
     /* HttpBindingGenerator.kt:236 */
-+
+}

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

@@ -0,1 +0,44 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* HttpBoundProtocolPayloadGenerator.kt:314 */
 pub fn ser_stream_http_payload(
     payload: &::std::option::Option<crate::model::SingletonEventStream>,
 ) -> ::std::result::Result<::std::vec::Vec<u8>, ::aws_smithy_types::error::operation::BuildError> {
     /* HttpBoundProtocolPayloadGenerator.kt:323 */
     let payload = match payload.as_ref() {
         Some(t) => t,
         None => {
             return Ok(
                 /* HttpBoundProtocolPayloadGenerator.kt:342 */
                 crate::protocol_serde::rest_json_unset_union_payload(), /* HttpBoundProtocolPayloadGenerator.kt:323 */
-+
+            )
-+
+        }
     };
     /* HttpBoundProtocolPayloadGenerator.kt:348 */
     Ok(
         /* HttpBoundProtocolPayloadGenerator.kt:389 */crate::protocol_serde::shape_duplex_stream_with_distinct_streams_output::ser_stream_payload(payload)?
     /* HttpBoundProtocolPayloadGenerator.kt:348 */)
     /* HttpBoundProtocolPayloadGenerator.kt:314 */
-+
+}
-+
 /* JsonSerializerGenerator.kt:242 */
 pub fn ser_stream_payload(
     input: &crate::model::SingletonEventStream,
 ) -> std::result::Result<
     ::std::vec::Vec<u8>,
     ::aws_smithy_types::error::operation::SerializationError,
 > {
     /* JsonSerializerGenerator.kt:247 */
     let mut out = String::new();
     /* JsonSerializerGenerator.kt:248 */
     let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
     /* JsonSerializerGenerator.kt:591 */
     crate::protocol_serde::shape_singleton_event_stream::ser_singleton_event_stream(
         &mut object,
         input,
     )?;
     /* JsonSerializerGenerator.kt:254 */
     object.finish();
     /* JsonSerializerGenerator.kt:255 */
     Ok(out.into_bytes())
     /* JsonSerializerGenerator.kt:242 */
-+
+}

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

@@ -0,1 +0,257 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:412 */
 pub async fn de_duplex_stream_with_initial_messages_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::DuplexStreamWithInitialMessagesInput,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-+
+>
 where
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: Into<::aws_smithy_types::byte_stream::ByteStream>,
     B::Data: Send,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-+
+{
     /* ServerHttpBoundProtocolGenerator.kt:428 */
     Ok({
         /* RustType.kt:534 */
         #[allow(unused_mut)]
         /* ServerHttpBoundProtocolGenerator.kt:773 */
         let mut input = crate::input::duplex_stream_with_initial_messages_input::Builder::default();
         /* RustType.kt:534 */
         #[allow(unused_variables)]
         /* ServerHttpBoundProtocolGenerator.kt:778 */
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         /* ServerHttpBoundProtocolGenerator.kt:870 */
         if let Some(value) = crate::protocol_serde::shape_duplex_stream_with_initial_messages_input::de_initial_request_member_header(&headers)? {
                                 input = input.set_initial_request_member(value)
-+
+                            }
         /* ServerHttpBoundProtocolGenerator.kt:870 */
         if let Some(value) = {
             let mut receiver = crate::protocol_serde::shape_duplex_stream_with_initial_messages_input::de_stream_payload(&mut body.into().into_inner())?;
             if let Some(_initial_event) = receiver
                                                 .try_recv_initial(::aws_smithy_legacy_http::event_stream::InitialMessageType::Request)
                                                 .await
                                                 .map_err(
                                                     |ev_error| ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection::ConstraintViolation(
                                                         #[allow(clippy::useless_conversion)]
                                                         format!("{ev_error}").into()
-+
+                                                    )
                                                 )? {
-+
-+
+                                            }
             Some(receiver)
         } {
             input = input.set_stream(value)
-+
+        }
         /* ServerHttpBoundProtocolGenerator.kt:910 */
         input.build()?
         /* ServerHttpBoundProtocolGenerator.kt:428 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:412 */
-+
+}
-+
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:449 */
 pub fn ser_duplex_stream_with_initial_messages_http_response(
     #[allow(unused_variables)] output: crate::output::DuplexStreamWithInitialMessagesOutput,
 ) -> std::result::Result<
     ::aws_smithy_legacy_http_server::response::Response,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     /* ServerHttpBoundProtocolGenerator.kt:461 */
     Ok({
         /* RustType.kt:534 */
         #[allow(unused_mut)]
         /* ServerHttpBoundProtocolGenerator.kt:551 */
         let mut builder = ::http::Response::builder();
         /* ServerHttpBoundProtocolGenerator.kt:679 */
         builder = crate::protocol_serde::shape_duplex_stream_with_initial_messages::ser_duplex_stream_with_initial_messages_headers(&output, builder)?;
         /* ServerHttpBoundProtocolGenerator.kt:647 */
         builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/vnd.amazon.eventstream",
         );
         /* ServerHttpBoundProtocolGenerator.kt:732 */
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         /* ServerHttpBoundProtocolGenerator.kt:589 */
         let body = ::aws_smithy_legacy_http_server::body::boxed(
             ::aws_smithy_legacy_http_server::body::Body::wrap_stream(
                 /* ServerHttpBoundProtocolGenerator.kt:145 */
-+
+                {
                     let error_marshaller =
                         crate::event_stream_serde::EventStreamErrorMarshaller::new();
                     let marshaller = crate::event_stream_serde::EventStreamMarshaller::new();
                     let signer = ::aws_smithy_eventstream::frame::NoOpSigner {};
                     output
                         .stream
                         .into_body_stream(marshaller, error_marshaller, signer)
                 }, /* ServerHttpBoundProtocolGenerator.kt:589 */
             ),
         );
         /* ServerHttpBoundProtocolGenerator.kt:625 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:461 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:449 */
-+
+}
-+
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:475 */
 pub fn ser_duplex_stream_with_initial_messages_http_error(
     error: &crate::error::DuplexStreamWithInitialMessagesError,
 ) -> std::result::Result<
     ::aws_smithy_legacy_http_server::response::Response,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     /* ServerHttpBoundProtocolGenerator.kt:480 */
     Ok({
         /* ServerHttpBoundProtocolGenerator.kt:496 */
         match error {
             /* ServerHttpBoundProtocolGenerator.kt:504 */
             crate::error::DuplexStreamWithInitialMessagesError::ServiceUnavailableError(output) => {
                 /* ServerHttpBoundProtocolGenerator.kt:505 */
                 let payload = crate::protocol_serde::shape_service_unavailable_error::ser_service_unavailable_error_error(output)?;
                 /* RustType.kt:534 */
                 #[allow(unused_mut)]
                 /* ServerHttpBoundProtocolGenerator.kt:515 */
                 let mut builder = ::http::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:647 */
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:647 */
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "ServiceUnavailableError",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:713 */
                 let content_length = payload.len();
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:532 */
                 builder
                     .status(500)
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
                 /* ServerHttpBoundProtocolGenerator.kt:504 */
-+
+            }
             /* ServerHttpBoundProtocolGenerator.kt:504 */
             crate::error::DuplexStreamWithInitialMessagesError::ValidationException(output) => {
                 /* ServerHttpBoundProtocolGenerator.kt:505 */
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 /* RustType.kt:534 */
                 #[allow(unused_mut)]
                 /* ServerHttpBoundProtocolGenerator.kt:515 */
                 let mut builder = ::http::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:647 */
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:647 */
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "ValidationException",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:713 */
                 let content_length = payload.len();
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:532 */
                 builder
                     .status(400)
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
                 /* ServerHttpBoundProtocolGenerator.kt:504 */
-+
+            }
             /* ServerHttpBoundProtocolGenerator.kt:504 */
             crate::error::DuplexStreamWithInitialMessagesError::ErrorEvent(output) => {
                 /* ServerHttpBoundProtocolGenerator.kt:505 */
                 let payload =
                     crate::protocol_serde::shape_error_event::ser_error_event_error(output)?;
                 /* RustType.kt:534 */
                 #[allow(unused_mut)]
                 /* ServerHttpBoundProtocolGenerator.kt:515 */
                 let mut builder = ::http::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:647 */
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:647 */
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "ErrorEvent",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:713 */
                 let content_length = payload.len();
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:532 */
                 builder
                     .status(400)
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
                 /* ServerHttpBoundProtocolGenerator.kt:504 */
             } /* ServerHttpBoundProtocolGenerator.kt:496 */
-+
+        }
         /* ServerHttpBoundProtocolGenerator.kt:480 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:475 */
-+
+}
-+
 /* HttpBindingGenerator.kt:565 */
 pub fn ser_duplex_stream_with_initial_messages_headers(
     input: &crate::output::DuplexStreamWithInitialMessagesOutput,
     mut builder: ::http::response::Builder,
 ) -> std::result::Result<::http::response::Builder, ::aws_smithy_types::error::operation::BuildError>
-+
+{
     /* SerializerUtil.kt:42 */
-+
+    {
         /* HttpBindingGenerator.kt:727 */
         let formatted_1 = &input.initial_response_member.as_str();
         /* HttpBindingGenerator.kt:728 */
         if !formatted_1.is_empty() {
             /* HttpBindingGenerator.kt:729 */
             let header_value = formatted_1;
             let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
                 ::aws_smithy_types::error::operation::BuildError::invalid_field(
                     "initial_response_member",
                     format!(
                         "`{}` cannot be used as a header value: {}",
                         &header_value, err
                     ),
-+
+                )
             })?;
             builder = builder.header("initial-response-member", header_value);
             /* HttpBindingGenerator.kt:728 */
-+
+        }
         /* SerializerUtil.kt:42 */
-+
+    }
     /* HttpBindingGenerator.kt:578 */
     Ok(builder)
     /* HttpBindingGenerator.kt:565 */
-+
+}

tmp-codegen-diff/codegen-server-test/rest_json-http0x/rust-server-codegen/src/protocol_serde/shape_duplex_stream_with_initial_messages_input.rs

@@ -0,1 +0,33 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* HttpBindingGenerator.kt:159 */
 pub(crate) fn de_initial_request_member_header(
     header_map: &::aws_smithy_runtime_api::http::Headers,
 ) -> ::std::result::Result<
     ::std::option::Option<::std::string::String>,
     ::aws_smithy_legacy_http::header::ParseError,
 > {
     /* HttpBindingGenerator.kt:166 */
     let headers = header_map.get_all("initial-request-member");
     /* HttpBindingGenerator.kt:398 */
     ::aws_smithy_legacy_http::header::one_or_none(headers)
     /* HttpBindingGenerator.kt:159 */
-+
+}
-+
 /* HttpBindingGenerator.kt:236 */
 pub fn de_stream_payload(
     body: &mut ::aws_smithy_types::body::SdkBody,
 ) -> std::result::Result<
     crate::sigv4_event_stream::SigV4Receiver<
         crate::model::EventStream,
         crate::error::EventStreamError,
     >,
     ::aws_smithy_json::deserialize::error::DeserializeError,
 > {
     /* HttpBindingGenerator.kt:278 */
     let unmarshaller = crate::event_stream_serde::EventStreamUnmarshaller::new();
     /* HttpBindingGenerator.kt:296 */
     let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
     let receiver = crate::sigv4_event_stream::SigV4Receiver::new(unmarshaller, body);
     Ok(receiver)
     /* HttpBindingGenerator.kt:236 */
-+
+}

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

@@ -0,1 +0,102 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonSerializerGenerator.kt:215 */
 pub fn ser_error_event_error(
     value: &crate::error::ErrorEvent,
 ) -> ::std::result::Result<String, ::aws_smithy_types::error::operation::SerializationError> {
     /* JsonSerializerGenerator.kt:220 */
     let mut out = ::std::string::String::new();
     let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
     /* JsonSerializerGenerator.kt:377 */
     crate::protocol_serde::shape_error_event::ser_error_event(&mut object, value)?;
     /* JsonSerializerGenerator.kt:229 */
     object.finish();
     Ok(out)
     /* JsonSerializerGenerator.kt:215 */
-+
+}
-+
 /* JsonSerializerGenerator.kt:360 */
 pub fn ser_error_event(
     object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
     input: &crate::error::ErrorEvent,
 ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
     /* JsonSerializerGenerator.kt:384 */
     if let Some(var_1) = &input.message {
         /* JsonSerializerGenerator.kt:425 */
         object.key("message").string(var_1.as_str());
         /* JsonSerializerGenerator.kt:384 */
-+
+    }
     /* JsonSerializerGenerator.kt:374 */
     Ok(())
     /* JsonSerializerGenerator.kt:360 */
-+
+}
-+
 /* JsonParserGenerator.kt:151 */
 pub(crate) fn de_error_event_json_err(
     _value: &[u8],
     mut builder: crate::error::error_event::Builder,
 ) -> ::std::result::Result<
     crate::error::error_event::Builder,
     ::aws_smithy_json::deserialize::error::DeserializeError,
 > {
     /* JsonParserGenerator.kt:158 */
     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:721 */
     loop {
         /* JsonParserGenerator.kt:722 */
         match tokens.next().transpose()? {
             /* JsonParserGenerator.kt:723 */
             Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
             Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
                 /* JsonParserGenerator.kt:265 */
                 match key.to_unescaped()?.as_ref() {
                     /* JsonParserGenerator.kt:267 */
                     "message" => {
                         /* JsonParserGenerator.kt:277 */
                         builder = builder.set_message(
                             /* JsonParserGenerator.kt:361 */
                             ::aws_smithy_json::deserialize::token::expect_string_or_null(
                                 tokens.next(),
                             )?
                             .map(|s|
                                 /* JsonParserGenerator.kt:346 */s.to_unescaped().map(|u|
                                     /* JsonParserGenerator.kt:355 */u.into_owned()
                                 /* JsonParserGenerator.kt:346 */) /* JsonParserGenerator.kt:361 */)
                             .transpose()?, /* JsonParserGenerator.kt:277 */
                         );
                         /* JsonParserGenerator.kt:267 */
-+
+                    }
                     /* JsonParserGenerator.kt:295 */
                     _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?, /* JsonParserGenerator.kt:265 */
-+
+                }
                 /* JsonParserGenerator.kt:723 */
-+
+            }
             /* JsonParserGenerator.kt:732 */
             other => {
                 return Err(
                     ::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
                         "expected object key or end object, found: {other:?}"
                     )),
-+
+                )
             } /* JsonParserGenerator.kt:722 */
-+
+        }
         /* JsonParserGenerator.kt:721 */
-+
+    }
     /* JsonParserGenerator.kt:255 */
     if tokens.next().is_some() {
         /* JsonParserGenerator.kt:256 */
         return Err(
             ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                 "found more JSON tokens after completing parsing",
             ),
         );
         /* JsonParserGenerator.kt:255 */
-+
+    }
     /* JsonParserGenerator.kt:168 */
     Ok(builder)
     /* JsonParserGenerator.kt:151 */
-+
+}

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

@@ -0,1 +0,20 @@

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

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

@@ -0,1 +0,87 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonParserGenerator.kt:151 */
 pub(crate) fn de_headers_and_implicit_payload_event_json_err(
     _value: &[u8],
     mut builder: crate::model::headers_and_implicit_payload_event::Builder,
 ) -> ::std::result::Result<
     crate::model::headers_and_implicit_payload_event::Builder,
     ::aws_smithy_json::deserialize::error::DeserializeError,
 > {
     /* JsonParserGenerator.kt:158 */
     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:721 */
     loop {
         /* JsonParserGenerator.kt:722 */
         match tokens.next().transpose()? {
             /* JsonParserGenerator.kt:723 */
             Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
             Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
                 /* JsonParserGenerator.kt:265 */
                 match key.to_unescaped()?.as_ref() {
                     /* JsonParserGenerator.kt:267 */
                     "header" => {
                         /* JsonParserGenerator.kt:277 */
                         builder = builder.set_header(
                             /* JsonParserGenerator.kt:361 */
                             ::aws_smithy_json::deserialize::token::expect_string_or_null(
                                 tokens.next(),
                             )?
                             .map(|s|
                                 /* JsonParserGenerator.kt:346 */s.to_unescaped().map(|u|
                                     /* JsonParserGenerator.kt:355 */u.into_owned()
                                 /* JsonParserGenerator.kt:346 */) /* JsonParserGenerator.kt:361 */)
                             .transpose()?, /* JsonParserGenerator.kt:277 */
                         );
                         /* JsonParserGenerator.kt:267 */
-+
+                    }
                     /* JsonParserGenerator.kt:267 */
                     "payload" => {
                         /* JsonParserGenerator.kt:277 */
                         builder = builder.set_payload(
                             /* JsonParserGenerator.kt:361 */
                             ::aws_smithy_json::deserialize::token::expect_string_or_null(
                                 tokens.next(),
                             )?
                             .map(|s|
                                 /* JsonParserGenerator.kt:346 */s.to_unescaped().map(|u|
                                     /* JsonParserGenerator.kt:355 */u.into_owned()
                                 /* JsonParserGenerator.kt:346 */) /* JsonParserGenerator.kt:361 */)
                             .transpose()?, /* JsonParserGenerator.kt:277 */
                         );
                         /* JsonParserGenerator.kt:267 */
-+
+                    }
                     /* JsonParserGenerator.kt:295 */
                     _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?, /* JsonParserGenerator.kt:265 */
-+
+                }
                 /* JsonParserGenerator.kt:723 */
-+
+            }
             /* JsonParserGenerator.kt:732 */
             other => {
                 return Err(
                     ::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
                         "expected object key or end object, found: {other:?}"
                     )),
-+
+                )
             } /* JsonParserGenerator.kt:722 */
-+
+        }
         /* JsonParserGenerator.kt:721 */
-+
+    }
     /* JsonParserGenerator.kt:255 */
     if tokens.next().is_some() {
         /* JsonParserGenerator.kt:256 */
         return Err(
             ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                 "found more JSON tokens after completing parsing",
             ),
         );
         /* JsonParserGenerator.kt:255 */
-+
+    }
     /* JsonParserGenerator.kt:168 */
     Ok(builder)
     /* JsonParserGenerator.kt:151 */
-+
+}

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 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122