Server Test

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

@@ -64,64 +110,110 @@

     })
     /* ServerHttpBoundProtocolGenerator.kt:412 */
-66
+}
-67
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:449 */
 pub fn ser_query_precedence_http_response(
     #[allow(unused_variables)] output: crate::output::QueryPrecedenceOutput,
 ) -> 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:233 */""
             /* HttpBoundProtocolPayloadGenerator.kt:238 */""
         /* 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);

↧ Expand context

         /* ServerHttpBoundProtocolGenerator.kt:625 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:461 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:449 */
-110
+}

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

@@ -47,47 +107,107 @@

↥ Expand context

     })
     /* ServerHttpBoundProtocolGenerator.kt:412 */
-49
+}
-50
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:449 */
 pub fn ser_recursive_shapes_http_response(
     #[allow(unused_variables)] output: crate::output::RecursiveShapesOutput,
 ) -> 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:235 */crate::protocol_serde::shape_recursive_shapes_output::ser_recursive_shapes_output_output_output(&output)?
             /* HttpBoundProtocolPayloadGenerator.kt:240 */crate::protocol_serde::shape_recursive_shapes_output::ser_recursive_shapes_output_output_output(&output)?
         /* 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);

↧ Expand context

         /* ServerHttpBoundProtocolGenerator.kt:625 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:461 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:449 */
-93
+}
-94
 /* JsonParserGenerator.kt:151 */
 pub(crate) fn de_recursive_shapes(
     _value: &[u8],
     mut builder: crate::input::recursive_shapes_input::Builder,
 ) -> ::std::result::Result<
     crate::input::recursive_shapes_input::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),
-106
+    )
     .peekable();

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

@@ -32,32 +78,78 @@

↥ Expand context

     })
     /* ServerHttpBoundProtocolGenerator.kt:412 */
-34
+}
-35
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:449 */
 pub fn ser_response_code_http_fallback_http_response(
     #[allow(unused_variables)] output: crate::output::ResponseCodeHttpFallbackOutput,
 ) -> 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 = 201;
         builder = builder.status(http_status);
         /* ServerHttpBoundProtocolGenerator.kt:611 */
         let payload =
             /* HttpBoundProtocolPayloadGenerator.kt:235 */crate::protocol_serde::shape_response_code_http_fallback_output::ser_response_code_http_fallback_output_output_output(&output)?
             /* HttpBoundProtocolPayloadGenerator.kt:240 */crate::protocol_serde::shape_response_code_http_fallback_output::ser_response_code_http_fallback_output_output_output(&output)?
         /* 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);

↧ Expand context

         /* ServerHttpBoundProtocolGenerator.kt:625 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:461 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:449 */
-78
+}

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

@@ -39,39 +85,85 @@

↥ Expand context

-39
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:449 */
 pub fn ser_response_code_required_http_response(
     #[allow(unused_variables)] output: crate::output::ResponseCodeRequiredOutput,
 ) -> 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:751 */
         let status = output.response_code
         /* ServerHttpBoundProtocolGenerator.kt:751 */;
         /* ServerHttpBoundProtocolGenerator.kt:756 */
         let http_status: u16 = status.try_into().map_err(::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::ResponseRejection::InvalidHttpStatusCode)?;
         builder = builder.status(http_status);
         /* ServerHttpBoundProtocolGenerator.kt:611 */
         let payload =
             /* HttpBoundProtocolPayloadGenerator.kt:235 */crate::protocol_serde::shape_response_code_required_output::ser_response_code_required_output_output_output(&output)?
             /* HttpBoundProtocolPayloadGenerator.kt:240 */crate::protocol_serde::shape_response_code_required_output::ser_response_code_required_output_output_output(&output)?
         /* 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);

↧ Expand context

         /* ServerHttpBoundProtocolGenerator.kt:625 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:461 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:449 */
-85
+}

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

@@ -56,56 +116,116 @@

↥ Expand context

-56
+}
-57
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:449 */
 pub fn ser_simple_scalar_properties_http_response(
     #[allow(unused_variables)] output: crate::output::SimpleScalarPropertiesOutput,
 ) -> 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_simple_scalar_properties::ser_simple_scalar_properties_headers(&output, 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:235 */crate::protocol_serde::shape_simple_scalar_properties_output::ser_simple_scalar_properties_output_output_output(&output)?
             /* HttpBoundProtocolPayloadGenerator.kt:240 */crate::protocol_serde::shape_simple_scalar_properties_output::ser_simple_scalar_properties_output_output_output(&output)?
         /* 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);

↧ Expand context

         /* ServerHttpBoundProtocolGenerator.kt:625 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:461 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:449 */
-102
+}
-103
 /* JsonParserGenerator.kt:151 */
 pub(crate) fn de_simple_scalar_properties(
     _value: &[u8],
     mut builder: crate::input::simple_scalar_properties_input::Builder,
 ) -> ::std::result::Result<
     crate::input::simple_scalar_properties_input::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),
-115
+    )
     .peekable();

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

@@ -47,47 +107,107 @@

↥ Expand context

     })
     /* ServerHttpBoundProtocolGenerator.kt:412 */
-49
+}
-50
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:449 */
 pub fn ser_sparse_json_lists_http_response(
     #[allow(unused_variables)] output: crate::output::SparseJsonListsOutput,
 ) -> 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:235 */crate::protocol_serde::shape_sparse_json_lists_output::ser_sparse_json_lists_output_output_output(&output)?
             /* HttpBoundProtocolPayloadGenerator.kt:240 */crate::protocol_serde::shape_sparse_json_lists_output::ser_sparse_json_lists_output_output_output(&output)?
         /* 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);

↧ Expand context

         /* ServerHttpBoundProtocolGenerator.kt:625 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:461 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:449 */
-93
+}
-94
 /* JsonParserGenerator.kt:151 */
 pub(crate) fn de_sparse_json_lists(
     _value: &[u8],
     mut builder: crate::input::sparse_json_lists_input::Builder,
 ) -> ::std::result::Result<
     crate::input::sparse_json_lists_input::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),
-106
+    )
     .peekable();

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

@@ -47,47 +107,107 @@

↥ Expand context

     })
     /* ServerHttpBoundProtocolGenerator.kt:412 */
-49
+}
-50
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:449 */
 pub fn ser_sparse_json_maps_http_response(
     #[allow(unused_variables)] output: crate::output::SparseJsonMapsOutput,
 ) -> 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:235 */crate::protocol_serde::shape_sparse_json_maps_output::ser_sparse_json_maps_output_output_output(&output)?
             /* HttpBoundProtocolPayloadGenerator.kt:240 */crate::protocol_serde::shape_sparse_json_maps_output::ser_sparse_json_maps_output_output_output(&output)?
         /* 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);

↧ Expand context

         /* ServerHttpBoundProtocolGenerator.kt:625 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:461 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:449 */
-93
+}
-94
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:475 */
 pub fn ser_sparse_json_maps_http_error(
     error: &crate::error::SparseJsonMapsError,
 ) -> 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 {

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

@@ -54,54 +114,114 @@

↥ Expand context

 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:449 */
 pub fn ser_streaming_traits_http_response(
     #[allow(unused_variables)] output: crate::output::StreamingTraitsOutput,
 ) -> 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_streaming_traits::ser_streaming_traits_headers(
             &output, builder,
         )?;
         /* ServerHttpBoundProtocolGenerator.kt:647 */
         builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(

             builder,
             ::http::header::CONTENT_TYPE,
             "application/octet-stream",
         );
         /* 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(
             /* ServerProtocolLoader.kt:42 */::aws_smithy_legacy_http::futures_stream_adapter::FuturesStreamCompatByteStream::new(
                 /* HttpBoundProtocolPayloadGenerator.kt:348 */crate::protocol_serde::shape_streaming_traits_output::ser_blob_http_payload( output.blob)?
                 /* HttpBoundProtocolPayloadGenerator.kt:353 */crate::protocol_serde::shape_streaming_traits_output::ser_blob_http_payload( output.blob)?
             /* ServerProtocolLoader.kt:42 */)
         /* ServerHttpBoundProtocolGenerator.kt:589 */));
         /* ServerHttpBoundProtocolGenerator.kt:625 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:461 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:449 */
-92
+}
-93
 /* HttpBindingGenerator.kt:565 */

↧ Expand context

 pub fn ser_streaming_traits_headers(
     input: &crate::output::StreamingTraitsOutput,
     mut builder: ::http::response::Builder,
 ) -> std::result::Result<::http::response::Builder, ::aws_smithy_types::error::operation::BuildError>
-99
+{
     /* HttpBindingGenerator.kt:615 */
     if let ::std::option::Option::Some(inner_1) = &input.foo {
         /* HttpBindingGenerator.kt:727 */
         let formatted_2 = inner_1.as_str();
         /* HttpBindingGenerator.kt:728 */
         if !formatted_2.is_empty() {
             /* HttpBindingGenerator.kt:729 */
             let header_value = formatted_2;
             let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
                 ::aws_smithy_types::error::operation::BuildError::invalid_field(
                     "foo",
                     format!(
                         "`{}` cannot be used as a header value: {}",
                         &header_value, err
                     ),

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

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

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* HttpBoundProtocolPayloadGenerator.kt:309 */
 /* HttpBoundProtocolPayloadGenerator.kt:314 */
 pub fn ser_blob_http_payload(
     payload: ::aws_smithy_types::byte_stream::ByteStream,
 ) -> ::std::result::Result<
     ::aws_smithy_types::byte_stream::ByteStream,
     ::aws_smithy_types::error::operation::BuildError,
 > {
     /* HttpBoundProtocolPayloadGenerator.kt:343 */
     /* HttpBoundProtocolPayloadGenerator.kt:348 */
     Ok(
         /* HttpBoundProtocolPayloadGenerator.kt:372 */
         payload, /* HttpBoundProtocolPayloadGenerator.kt:343 */
         /* HttpBoundProtocolPayloadGenerator.kt:377 */
         payload, /* HttpBoundProtocolPayloadGenerator.kt:348 */
-13
+    )
     /* HttpBoundProtocolPayloadGenerator.kt:309 */
     /* HttpBoundProtocolPayloadGenerator.kt:314 */
-15
+}

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

@@ -47,47 +93,93 @@

↥ Expand context

     })
     /* ServerHttpBoundProtocolGenerator.kt:412 */
-49
+}
-50
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:449 */
 pub fn ser_streaming_traits_require_length_http_response(
     #[allow(unused_variables)] output: crate::output::StreamingTraitsRequireLengthOutput,
 ) -> 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:233 */""
             /* HttpBoundProtocolPayloadGenerator.kt:238 */""
         /* 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);

↧ Expand context

         /* ServerHttpBoundProtocolGenerator.kt:625 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:461 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:449 */
-93
+}

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

@@ -50,50 +110,110 @@

↥ Expand context

-50
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:449 */
 pub fn ser_streaming_traits_with_media_type_http_response(
     #[allow(unused_variables)] output: crate::output::StreamingTraitsWithMediaTypeOutput,
 ) -> 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_streaming_traits_with_media_type::ser_streaming_traits_with_media_type_headers(&output, builder)?;
         /* ServerHttpBoundProtocolGenerator.kt:647 */
         builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(

             builder,
             ::http::header::CONTENT_TYPE,
             "text/plain",
         );
         /* 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(
             /* ServerProtocolLoader.kt:42 */::aws_smithy_legacy_http::futures_stream_adapter::FuturesStreamCompatByteStream::new(
                 /* HttpBoundProtocolPayloadGenerator.kt:348 */crate::protocol_serde::shape_streaming_traits_with_media_type_output::ser_blob_http_payload( output.blob)?
                 /* HttpBoundProtocolPayloadGenerator.kt:353 */crate::protocol_serde::shape_streaming_traits_with_media_type_output::ser_blob_http_payload( output.blob)?
             /* ServerProtocolLoader.kt:42 */)
         /* ServerHttpBoundProtocolGenerator.kt:589 */));
         /* ServerHttpBoundProtocolGenerator.kt:625 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:461 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:449 */
-88
+}
-89
 /* HttpBindingGenerator.kt:565 */

↧ Expand context

 pub fn ser_streaming_traits_with_media_type_headers(
     input: &crate::output::StreamingTraitsWithMediaTypeOutput,
     mut builder: ::http::response::Builder,
 ) -> std::result::Result<::http::response::Builder, ::aws_smithy_types::error::operation::BuildError>
-95
+{
     /* HttpBindingGenerator.kt:615 */
     if let ::std::option::Option::Some(inner_1) = &input.foo {
         /* HttpBindingGenerator.kt:727 */
         let formatted_2 = inner_1.as_str();
         /* HttpBindingGenerator.kt:728 */
         if !formatted_2.is_empty() {
             /* HttpBindingGenerator.kt:729 */
             let header_value = formatted_2;
             let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
                 ::aws_smithy_types::error::operation::BuildError::invalid_field(
                     "foo",
                     format!(
                         "`{}` cannot be used as a header value: {}",
                         &header_value, err
                     ),

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

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

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* HttpBoundProtocolPayloadGenerator.kt:309 */
 /* HttpBoundProtocolPayloadGenerator.kt:314 */
 pub fn ser_blob_http_payload(
     payload: ::aws_smithy_types::byte_stream::ByteStream,
 ) -> ::std::result::Result<
     ::aws_smithy_types::byte_stream::ByteStream,
     ::aws_smithy_types::error::operation::BuildError,
 > {
     /* HttpBoundProtocolPayloadGenerator.kt:343 */
     /* HttpBoundProtocolPayloadGenerator.kt:348 */
     Ok(
         /* HttpBoundProtocolPayloadGenerator.kt:372 */
         payload, /* HttpBoundProtocolPayloadGenerator.kt:343 */
         /* HttpBoundProtocolPayloadGenerator.kt:377 */
         payload, /* HttpBoundProtocolPayloadGenerator.kt:348 */
-13
+    )
     /* HttpBoundProtocolPayloadGenerator.kt:309 */
     /* HttpBoundProtocolPayloadGenerator.kt:314 */
-15
+}

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

@@ -58,58 +118,118 @@

↥ Expand context

 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:449 */
 pub fn ser_test_body_structure_http_response(
     #[allow(unused_variables)] output: crate::output::TestBodyStructureOutput,
 ) -> 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_test_body_structure::ser_test_body_structure_headers(
                 &output, 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:235 */crate::protocol_serde::shape_test_body_structure_output::ser_test_body_structure_output_output_output(&output)?
             /* HttpBoundProtocolPayloadGenerator.kt:240 */crate::protocol_serde::shape_test_body_structure_output::ser_test_body_structure_output_output_output(&output)?
         /* 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);

↧ Expand context

         /* ServerHttpBoundProtocolGenerator.kt:625 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:461 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:449 */
-104
+}
-105
 /* JsonParserGenerator.kt:151 */
 pub(crate) fn de_test_body_structure(
     _value: &[u8],
     mut builder: crate::input::test_body_structure_input::Builder,
 ) -> ::std::result::Result<
     crate::input::test_body_structure_input::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),
-117
+    )
     .peekable();

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

@@ -38,38 +98,98 @@

↥ Expand context

-38
+}
-39
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:449 */
 pub fn ser_test_get_no_input_no_payload_http_response(
     #[allow(unused_variables)] output: crate::output::TestGetNoInputNoPayloadOutput,
 ) -> 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_test_get_no_input_no_payload::ser_test_get_no_input_no_payload_headers(&output, 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:235 */crate::protocol_serde::shape_test_get_no_input_no_payload_output::ser_test_get_no_input_no_payload_output_output_output(&output)?
             /* HttpBoundProtocolPayloadGenerator.kt:240 */crate::protocol_serde::shape_test_get_no_input_no_payload_output::ser_test_get_no_input_no_payload_output_output_output(&output)?
         /* 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);

↧ Expand context

         /* ServerHttpBoundProtocolGenerator.kt:625 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:461 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:449 */
-84
+}
-85
 /* HttpBindingGenerator.kt:565 */
 pub fn ser_test_get_no_input_no_payload_headers(
     input: &crate::output::TestGetNoInputNoPayloadOutput,
     mut builder: ::http::response::Builder,
 ) -> std::result::Result<::http::response::Builder, ::aws_smithy_types::error::operation::BuildError>
-91
+{
     /* HttpBindingGenerator.kt:615 */
     if let ::std::option::Option::Some(inner_1) = &input.test_id {
         /* HttpBindingGenerator.kt:727 */
         let formatted_2 = inner_1.as_str();
         /* HttpBindingGenerator.kt:728 */
         if !formatted_2.is_empty() {
             /* HttpBindingGenerator.kt:729 */

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

@@ -43,43 +103,103 @@

↥ Expand context

 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:449 */
 pub fn ser_test_get_no_payload_http_response(
     #[allow(unused_variables)] output: crate::output::TestGetNoPayloadOutput,
 ) -> 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_test_get_no_payload::ser_test_get_no_payload_headers(
                 &output, 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:235 */crate::protocol_serde::shape_test_get_no_payload_output::ser_test_get_no_payload_output_output_output(&output)?
             /* HttpBoundProtocolPayloadGenerator.kt:240 */crate::protocol_serde::shape_test_get_no_payload_output::ser_test_get_no_payload_output_output_output(&output)?
         /* 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);

↧ Expand context

         /* ServerHttpBoundProtocolGenerator.kt:625 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:461 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:449 */
-89
+}
-90
 /* HttpBindingGenerator.kt:565 */
 pub fn ser_test_get_no_payload_headers(
     input: &crate::output::TestGetNoPayloadOutput,
     mut builder: ::http::response::Builder,
 ) -> std::result::Result<::http::response::Builder, ::aws_smithy_types::error::operation::BuildError>
-96
+{
     /* HttpBindingGenerator.kt:615 */
     if let ::std::option::Option::Some(inner_1) = &input.test_id {
         /* HttpBindingGenerator.kt:727 */
         let formatted_2 = inner_1.as_str();
         /* HttpBindingGenerator.kt:728 */
         if !formatted_2.is_empty() {
             /* HttpBindingGenerator.kt:729 */

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

@@ -44,44 +104,104 @@

↥ Expand context

         input.build()
         /* ServerHttpBoundProtocolGenerator.kt:428 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:412 */
-48
+}
-49
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:449 */
 pub fn ser_test_payload_blob_http_response(
     #[allow(unused_variables)] output: crate::output::TestPayloadBlobOutput,
 ) -> 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_test_payload_blob::ser_test_payload_blob_headers(
             &output, builder,
         )?;
         /* ServerHttpBoundProtocolGenerator.kt:732 */
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         /* ServerHttpBoundProtocolGenerator.kt:611 */
         let payload =
             /* HttpBoundProtocolPayloadGenerator.kt:348 */crate::protocol_serde::shape_test_payload_blob_output::ser_data_http_payload( output.data)?
             /* HttpBoundProtocolPayloadGenerator.kt:353 */crate::protocol_serde::shape_test_payload_blob_output::ser_data_http_payload( output.data)?
         /* 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);

↧ Expand context

         /* ServerHttpBoundProtocolGenerator.kt:625 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:461 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:449 */
-90
+}
-91
 /* HttpBindingGenerator.kt:565 */
 pub fn ser_test_payload_blob_headers(
     input: &crate::output::TestPayloadBlobOutput,
     mut builder: ::http::response::Builder,
 ) -> std::result::Result<::http::response::Builder, ::aws_smithy_types::error::operation::BuildError>
-97
+{
     /* HttpBindingGenerator.kt:615 */
     if let ::std::option::Option::Some(inner_1) = &input.content_type {
         /* HttpBindingGenerator.kt:727 */
         let formatted_2 = inner_1.as_str();
         /* HttpBindingGenerator.kt:728 */
         if !formatted_2.is_empty() {
             /* HttpBindingGenerator.kt:729 */

Server Test

Files changed: