Server Test

rev. dfb5149b65b7bcc09edd15b8e071ad43b5ac5943 (ignoring whitespace)

Files changed:

tmp-codegen-diff/codegen-server-test/rest_json_validation/rust-server-codegen/src/operation.rs

@@ -1,1 +31,32 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_SENSITIVEVALIDATION: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`SensitiveValidationInput`](crate::input::SensitiveValidationInput) using modelled bindings.
     pub struct SensitiveValidationInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::SensitiveValidationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-9
+    }
-10
+}
-11
 impl std::future::Future for SensitiveValidationInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::SensitiveValidationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-17
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-24
+    }
-25
+}
-26
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::SensitiveValidationInput
 where

@@ -40,41 +195,204 @@

↥ Expand context

     type Future = SensitiveValidationInputFuture;
-42
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_SENSITIVEVALIDATION,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-50
+            }
             crate::protocol_serde::shape_sensitive_validation::de_sensitive_validation_http_request(
                 request,
-53
+            )
             .await
             .map_err(Into::into)
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-63
+                )
             },
         );
         SensitiveValidationInputFuture {
             inner: Box::pin(fut),
-68
+        }
-69
+    }
-70
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::SensitiveValidationOutput
-76
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_sensitive_validation::ser_sensitive_validation_http_response(self) {
                         Ok(response) => response,
                         Err(e) => {
                             ::tracing::error!(error = %e, "failed to serialize response");
                             ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-83
+                        }
-84
+                    }
-85
+    }
-86
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::SensitiveValidationError
-92
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_sensitive_validation::ser_sensitive_validation_http_error(
             &self,
         ) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                 );
                 response
-102
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-106
+            }
-107
+        }
-108
+    }
-109
+}
-110
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod sensitive_validation_test {
-117
     /// When a sensitive member fails validation, the resultant
     /// ValidationException will omit the value of the input.
     /// Test ID: RestJsonMalformedPatternSensitiveString
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn rest_json_malformed_pattern_sensitive_string_malformed_request() {
-124
+        {
             #[allow(unused_mut)]
             let mut http_request = http::Request::builder()
                 .uri("/SensitiveValidation")
                 .method("POST")
                 .header("content-type", "application/json")
                 .body(::aws_smithy_http_server::body::Body::from(
                     ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                         "{ \"string\" : \"ABC\" }".as_bytes(),
                         ::aws_smithy_protocol_test::MediaType::from("unknown"),
                     )),
                 ))
                 .unwrap();
             #[allow(unused_mut)]
             let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
             let config = crate::service::RestJsonValidationConfig::builder().build();
             let service = crate::service::RestJsonValidation::builder::<::hyper::body::Body, _, _, _>(config)
                             .sensitive_validation(move |input: crate::input::SensitiveValidationInput| {
                                 let sender = sender.clone();
                                 async move {
                                     let result = { panic!("request should have been rejected, but we accepted it; we parsed operation input `{:?}`", &input) as Result<crate::output::SensitiveValidationOutput, crate::error::SensitiveValidationError> };
                                     sender.send(()).await.expect("receiver dropped early");
                                     result
-147
+                                }
                             })
                             .build_unchecked();
             let http_response = ::tower::ServiceExt::oneshot(service, http_request)
                 .await
                 .expect("unable to make an HTTP request");
             ::pretty_assertions::assert_eq!(
                 http::StatusCode::from_u16(400).expect("invalid expected HTTP status code"),
                 http_response.status()
             );
             let expected_headers = [("x-amzn-errortype", "ValidationException")];
             ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
                 http_response.headers(),
                 expected_headers,
             ));
             let body = ::hyper::body::to_bytes(http_response.into_body())
                 .await
                 .expect("unable to extract body to bytes");
             ::aws_smithy_protocol_test::assert_ok(
             ::aws_smithy_protocol_test::validate_body(&body, "{ \"message\" : \"1 validation error detected. Value at '/string' failed to satisfy constraint: Member must satisfy regular expression pattern: ^[a-m]+$\",\n  \"fieldList\" : [{\"message\": \"Value at '/string' failed to satisfy constraint: Member must satisfy regular expression pattern: ^[a-m]+$\", \"path\": \"/string\"}]}", ::aws_smithy_protocol_test::MediaType::from("application/json"))
             );
-168
+        }
-169
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-172
+}
-173
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_RECURSIVESTRUCTURES: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`RecursiveStructuresInput`](crate::input::RecursiveStructuresInput) using modelled bindings.
     pub struct RecursiveStructuresInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::RecursiveStructuresInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-181
+    }
-182
+}
-183
 impl std::future::Future for RecursiveStructuresInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::RecursiveStructuresInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-189
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-196
+    }
-197
+}
-198
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::RecursiveStructuresInput
 where

@@ -204,213 +303,317 @@

↥ Expand context

     type Future = RecursiveStructuresInputFuture;
-214
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_RECURSIVESTRUCTURES,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-222
+            }
             crate::protocol_serde::shape_recursive_structures::de_recursive_structures_http_request(
                 request,
-225
+            )
             .await
             .map_err(Into::into)
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-235
+                )
             },
         );
         RecursiveStructuresInputFuture {
             inner: Box::pin(fut),
-240
+        }
-241
+    }
-242
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::RecursiveStructuresOutput
-248
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_recursive_structures::ser_recursive_structures_http_response(self) {
                         Ok(response) => response,
                         Err(e) => {
                             ::tracing::error!(error = %e, "failed to serialize response");
                             ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-255
+                        }
-256
+                    }
-257
+    }
-258
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::RecursiveStructuresError
-264
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_recursive_structures::ser_recursive_structures_http_error(
             &self,
         ) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                 );
                 response
-274
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-278
+            }
-279
+        }
-280
+    }
-281
+}
-282
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod recursive_structures_test {
-289
     /// Validation should work with recursive structures.
     /// Test ID: RestJsonRecursiveStructuresValidate
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn rest_json_recursive_structures_validate_request() {
         #[allow(unused_mut)]
                     let mut http_request = http::Request::builder()
                         .uri("/RecursiveStructures")

↧ Expand context

                         .method("POST")
         .header("content-type", "application/json")
         .body(::aws_smithy_http_server::body::Body::from(
                                 ::bytes::Bytes::copy_from_slice(
                                     &::aws_smithy_protocol_test::decode_body_data("{ \"union\" : {\n    \"union\" : {\n        \"union\" : { \"string\" : \"abc\" }\n    }\n  }\n}".as_bytes(), ::aws_smithy_protocol_test::MediaType::from("application/json"))
-303
+                                )
                                 )).unwrap();
         #[allow(unused_mut)]
         let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
         let config = crate::service::RestJsonValidationConfig::builder().build();
         let service =
             crate::service::RestJsonValidation::builder::<::hyper::body::Body, _, _, _>(config)
                 .recursive_structures(move |input: crate::input::RecursiveStructuresInput| {
                     let sender = sender.clone();
                     async move {
                         let result = {
                             let expected = crate::input::RecursiveStructuresInput {
                                 union: ::std::option::Option::Some(
                                     crate::model::RecursiveUnionOne::Union(::std::boxed::Box::new(
                                         crate::model::RecursiveUnionTwo::Union(

@@ -351,365 +412,429 @@

↥ Expand context

             let service = crate::service::RestJsonValidation::builder::<::hyper::body::Body, _, _, _>(config)
                             .recursive_structures(move |input: crate::input::RecursiveStructuresInput| {
                                 let sender = sender.clone();
                                 async move {
                                     let result = { panic!("request should have been rejected, but we accepted it; we parsed operation input `{:?}`", &input) as Result<crate::output::RecursiveStructuresOutput, crate::error::RecursiveStructuresError> };
                                     sender.send(()).await.expect("receiver dropped early");
                                     result
-372
+                                }
                             })
                             .build_unchecked();
             let http_response = ::tower::ServiceExt::oneshot(service, http_request)
                 .await
                 .expect("unable to make an HTTP request");
             ::pretty_assertions::assert_eq!(
                 http::StatusCode::from_u16(400).expect("invalid expected HTTP status code"),
                 http_response.status()
             );
             let expected_headers = [("x-amzn-errortype", "ValidationException")];
             ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
                 http_response.headers(),

                 expected_headers,
             ));
             let body = ::hyper::body::to_bytes(http_response.into_body())
                 .await
                 .expect("unable to extract body to bytes");
             ::aws_smithy_protocol_test::assert_ok(
             ::aws_smithy_protocol_test::validate_body(&body, "{ \"message\" : \"1 validation error detected. Value at '/union/union/union/string' failed to satisfy constraint: Member must satisfy enum value set: [abc, def]\",\n  \"fieldList\" : [{\"message\": \"Value at '/union/union/union/string' failed to satisfy constraint: Member must satisfy enum value set: [abc, def]\", \"path\": \"/union/union/union/string\"}]}", ::aws_smithy_protocol_test::MediaType::from("application/json"))
             );
-393
+        }
-394
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-397
+}
-398
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_MALFORMEDUNIQUEITEMS: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`MalformedUniqueItemsInput`](crate::input::MalformedUniqueItemsInput) using modelled bindings.
     pub struct MalformedUniqueItemsInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::MalformedUniqueItemsInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-406
+    }
-407
+}
-408
 impl std::future::Future for MalformedUniqueItemsInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::MalformedUniqueItemsInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-414
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-421
+    }
-422
+}
-423
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::MalformedUniqueItemsInput
 where

@@ -419,436 +514,536 @@

↥ Expand context

-436
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = MalformedUniqueItemsInputFuture;
-439
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_MALFORMEDUNIQUEITEMS,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-447
+            }
             crate::protocol_serde::shape_malformed_unique_items::de_malformed_unique_items_http_request(request)
                             .await
                             .map_err(Into::into)
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-458
+                )
             },
         );
         MalformedUniqueItemsInputFuture {
             inner: Box::pin(fut),
-463
+        }
-464
+    }
-465
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::MalformedUniqueItemsOutput
-471
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_malformed_unique_items::ser_malformed_unique_items_http_response(self) {
                         Ok(response) => response,
                         Err(e) => {
                             ::tracing::error!(error = %e, "failed to serialize response");
                             ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-478
+                        }
-479
+                    }
-480
+    }
-481
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::MalformedUniqueItemsError
-487
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_malformed_unique_items::ser_malformed_unique_items_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response
             },
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-497
+            }
-498
+        }
-499
+    }
-500
+}
-501
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod malformed_unique_items_test {
-508
     /// When a blob list contains non-unique values,
     /// the response should be a 400 ValidationException.
     /// Test ID: RestJsonMalformedUniqueItemsBlobList
     #[::tokio::test]
     #[::tracing_test::traced_test]
     #[should_panic]
     async fn rest_json_malformed_unique_items_blob_list_malformed_request() {
-516
+        {

↧ Expand context

             #[allow(unused_mut)]
             let mut http_request = http::Request::builder()
                 .uri("/MalformedUniqueItems")
                 .method("POST")
                 .header("content-type", "application/json")
                 .body(::aws_smithy_http_server::body::Body::from(
                     ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                         "{ \"blobList\" : [\"YQ==\", \"YQ==\"] }".as_bytes(),
                         ::aws_smithy_protocol_test::MediaType::from("unknown"),
                     )),
                 ))
                 .unwrap();
             #[allow(unused_mut)]
             let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
             let config = crate::service::RestJsonValidationConfig::builder().build();
             let service = crate::service::RestJsonValidation::builder::<::hyper::body::Body, _, _, _>(config)
                             .malformed_unique_items(move |input: crate::input::MalformedUniqueItemsInput| {
                                 let sender = sender.clone();
                                 async move {
                                     let result = { panic!("request should have been rejected, but we accepted it; we parsed operation input `{:?}`", &input) as Result<crate::output::MalformedUniqueItemsOutput, crate::error::MalformedUniqueItemsError> };

@@ -1426,1448 +1487,1512 @@

↥ Expand context

             let service = crate::service::RestJsonValidation::builder::<::hyper::body::Body, _, _, _>(config)
                             .malformed_unique_items(move |input: crate::input::MalformedUniqueItemsInput| {
                                 let sender = sender.clone();
                                 async move {
                                     let result = { panic!("request should have been rejected, but we accepted it; we parsed operation input `{:?}`", &input) as Result<crate::output::MalformedUniqueItemsOutput, crate::error::MalformedUniqueItemsError> };
                                     sender.send(()).await.expect("receiver dropped early");
                                     result
-1455
+                                }
                             })
                             .build_unchecked();
             let http_response = ::tower::ServiceExt::oneshot(service, http_request)
                 .await
                 .expect("unable to make an HTTP request");
             ::pretty_assertions::assert_eq!(
                 http::StatusCode::from_u16(400).expect("invalid expected HTTP status code"),
                 http_response.status()
             );
             let expected_headers = [("x-amzn-errortype", "ValidationException")];
             ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
                 http_response.headers(),

                 expected_headers,
             ));
             let body = ::hyper::body::to_bytes(http_response.into_body())
                 .await
                 .expect("unable to extract body to bytes");
             ::aws_smithy_protocol_test::assert_ok(
             ::aws_smithy_protocol_test::validate_body(&body, "{ \"message\" : \"1 validation error detected. Value at '/unionList' failed to satisfy constraint: Member must have unique values\",\n  \"fieldList\" : [{\"message\": \"Value at '/unionList' failed to satisfy constraint: Member must have unique values\", \"path\": \"/unionList\"}]}", ::aws_smithy_protocol_test::MediaType::from("application/json"))
             );
-1476
+        }
-1477
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-1480
+}
-1481
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_MALFORMEDREQUIRED: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`MalformedRequiredInput`](crate::input::MalformedRequiredInput) using modelled bindings.
     pub struct MalformedRequiredInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::MalformedRequiredInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-1489
+    }
-1490
+}
-1491
 impl std::future::Future for MalformedRequiredInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::MalformedRequiredInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-1497
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-1504
+    }
-1505
+}
-1506
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::MalformedRequiredInput
 where

@@ -1496,1521 +1597,1627 @@

↥ Expand context

     type Future = MalformedRequiredInputFuture;
-1522
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_MALFORMEDREQUIRED,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-1530
+            }
             crate::protocol_serde::shape_malformed_required::de_malformed_required_http_request(
                 request,
-1533
+            )
             .await
             .map_err(Into::into)
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-1543
+                )
             },
         );
         MalformedRequiredInputFuture {
             inner: Box::pin(fut),
-1548
+        }
-1549
+    }
-1550
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::MalformedRequiredOutput
-1556
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_malformed_required::ser_malformed_required_http_response(
             self,
         ) {
             Ok(response) => response,
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-1565
+            }
-1566
+        }
-1567
+    }
-1568
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::MalformedRequiredError
-1574
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_malformed_required::ser_malformed_required_http_error(
             &self,
         ) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                 );
                 response
-1584
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-1588
+            }
-1589
+        }
-1590
+    }
-1591
+}
-1592
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod malformed_required_test {
-1599
     /// When a required member is not set in the message body,
     /// the response should be a 400 ValidationException.
     /// Test ID: RestJsonMalformedRequiredBodyUnset
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn rest_json_malformed_required_body_unset_malformed_request() {
-1606
+        {
             #[allow(unused_mut)]

↧ Expand context

             let mut http_request = http::Request::builder()
                 .uri("/MalformedRequired")
                 .method("POST")
                 .header("content-type", "application/json")
                 .header("string-in-headers", "abc")
                 .body(::aws_smithy_http_server::body::Body::from(
                     ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                         "{  }".as_bytes(),
                         ::aws_smithy_protocol_test::MediaType::from("unknown"),
                     )),
                 ))
                 .unwrap();
             *http_request.uri_mut() = "/MalformedRequired?stringInQuery=abc".parse().unwrap();
             #[allow(unused_mut)]
             let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
             let config = crate::service::RestJsonValidationConfig::builder().build();
             let service = crate::service::RestJsonValidation::builder::<::hyper::body::Body, _, _, _>(config)
                             .malformed_required(move |input: crate::input::MalformedRequiredInput| {
                                 let sender = sender.clone();
                                 async move {

@@ -1703,1733 +1764,1797 @@

↥ Expand context

             let service = crate::service::RestJsonValidation::builder::<::hyper::body::Body, _, _, _>(config)
                             .malformed_required(move |input: crate::input::MalformedRequiredInput| {
                                 let sender = sender.clone();
                                 async move {
                                     let result = { panic!("request should have been rejected, but we accepted it; we parsed operation input `{:?}`", &input) as Result<crate::output::MalformedRequiredOutput, crate::error::MalformedRequiredError> };
                                     sender.send(()).await.expect("receiver dropped early");
                                     result
-1740
+                                }
                             })
                             .build_unchecked();
             let http_response = ::tower::ServiceExt::oneshot(service, http_request)
                 .await
                 .expect("unable to make an HTTP request");
             ::pretty_assertions::assert_eq!(
                 http::StatusCode::from_u16(400).expect("invalid expected HTTP status code"),
                 http_response.status()
             );
             let expected_headers = [("x-amzn-errortype", "ValidationException")];
             ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
                 http_response.headers(),

                 expected_headers,
             ));
             let body = ::hyper::body::to_bytes(http_response.into_body())
                 .await
                 .expect("unable to extract body to bytes");
             ::aws_smithy_protocol_test::assert_ok(
             ::aws_smithy_protocol_test::validate_body(&body, "{ \"message\" : \"1 validation error detected. Value at '/stringInHeader' failed to satisfy constraint: Member must not be null\",\n  \"fieldList\" : [{\"message\": \"Value at '/stringInHeader' failed to satisfy constraint: Member must not be null\", \"path\": \"/stringInHeader\"}]}", ::aws_smithy_protocol_test::MediaType::from("application/json"))
             );
-1761
+        }
-1762
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-1765
+}
-1766
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_MALFORMEDRANGEOVERRIDE: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`MalformedRangeOverrideInput`](crate::input::MalformedRangeOverrideInput) using modelled bindings.
     pub struct MalformedRangeOverrideInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::MalformedRangeOverrideInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-1774
+    }
-1775
+}
-1776
 impl std::future::Future for MalformedRangeOverrideInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::MalformedRangeOverrideInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-1782
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-1789
+    }
-1790
+}
-1791
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::MalformedRangeOverrideInput
 where

@@ -1771,1804 +1866,1904 @@

↥ Expand context

-1804
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = MalformedRangeOverrideInputFuture;
-1807
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_MALFORMEDRANGEOVERRIDE,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-1815
+            }
             crate::protocol_serde::shape_malformed_range_override::de_malformed_range_override_http_request(request)
                             .await
                             .map_err(Into::into)
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-1826
+                )
             },
         );
         MalformedRangeOverrideInputFuture {
             inner: Box::pin(fut),
-1831
+        }
-1832
+    }
-1833
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::MalformedRangeOverrideOutput
-1839
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_malformed_range_override::ser_malformed_range_override_http_response(self) {
                         Ok(response) => response,
                         Err(e) => {
                             ::tracing::error!(error = %e, "failed to serialize response");
                             ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-1846
+                        }
-1847
+                    }
-1848
+    }
-1849
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::MalformedRangeOverrideError
-1855
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_malformed_range_override::ser_malformed_range_override_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response
             },
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-1865
+            }
-1866
+        }
-1867
+    }
-1868
+}
-1869
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod malformed_range_override_test {
-1876
     /// When a byte member does not fit within range bounds,
     /// the response should be a 400 ValidationException.
     /// Test ID: RestJsonMalformedRangeByteOverride_case0
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn rest_json_malformed_range_byte_override_case0_malformed_request() {
-1883
+        {
             #[allow(unused_mut)]

↧ Expand context

             let mut http_request = http::Request::builder()
                 .uri("/MalformedRangeOverride")
                 .method("POST")
                 .header("content-type", "application/json")
                 .body(::aws_smithy_http_server::body::Body::from(
                     ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                         "{ \"byte\" : 3 }".as_bytes(),
                         ::aws_smithy_protocol_test::MediaType::from("unknown"),
                     )),
                 ))
                 .unwrap();
             #[allow(unused_mut)]
             let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
             let config = crate::service::RestJsonValidationConfig::builder().build();
             let service = crate::service::RestJsonValidation::builder::<::hyper::body::Body, _, _, _>(config)
                             .malformed_range_override(move |input: crate::input::MalformedRangeOverrideInput| {
                                 let sender = sender.clone();
                                 async move {
                                     let result = { panic!("request should have been rejected, but we accepted it; we parsed operation input `{:?}`", &input) as Result<crate::output::MalformedRangeOverrideOutput, crate::error::MalformedRangeOverrideError> };
                                     sender.send(()).await.expect("receiver dropped early");

@@ -2872,2910 +2933,2974 @@

↥ Expand context

             let service = crate::service::RestJsonValidation::builder::<::hyper::body::Body, _, _, _>(config)
                             .malformed_range_override(move |input: crate::input::MalformedRangeOverrideInput| {
                                 let sender = sender.clone();
                                 async move {
                                     let result = { panic!("request should have been rejected, but we accepted it; we parsed operation input `{:?}`", &input) as Result<crate::output::MalformedRangeOverrideOutput, crate::error::MalformedRangeOverrideError> };
                                     sender.send(()).await.expect("receiver dropped early");
                                     result
-2917
+                                }
                             })
                             .build_unchecked();
             let http_response = ::tower::ServiceExt::oneshot(service, http_request)
                 .await
                 .expect("unable to make an HTTP request");
             ::pretty_assertions::assert_eq!(
                 http::StatusCode::from_u16(400).expect("invalid expected HTTP status code"),
                 http_response.status()
             );
             let expected_headers = [("x-amzn-errortype", "ValidationException")];
             ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
                 http_response.headers(),

                 expected_headers,
             ));
             let body = ::hyper::body::to_bytes(http_response.into_body())
                 .await
                 .expect("unable to extract body to bytes");
             ::aws_smithy_protocol_test::assert_ok(
             ::aws_smithy_protocol_test::validate_body(&body, "{ \"message\" : \"1 validation error detected. Value at '/maxLong' failed to satisfy constraint: Member must be less than or equal to 6\",\n  \"fieldList\" : [{\"message\": \"Value at '/maxLong' failed to satisfy constraint: Member must be less than or equal to 6\", \"path\": \"/maxLong\"}]}", ::aws_smithy_protocol_test::MediaType::from("application/json"))
             );
-2938
+        }
-2939
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-2942
+}
-2943
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_MALFORMEDRANGE: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`MalformedRangeInput`](crate::input::MalformedRangeInput) using modelled bindings.
     pub struct MalformedRangeInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::MalformedRangeInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-2951
+    }
-2952
+}
-2953
 impl std::future::Future for MalformedRangeInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::MalformedRangeInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-2959
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-2966
+    }
-2967
+}
-2968
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::MalformedRangeInput
 where

@@ -2940,2981 +3038,3084 @@

↥ Expand context

-2981
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = MalformedRangeInputFuture;
-2984
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_MALFORMEDRANGE,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-2992
+            }
             crate::protocol_serde::shape_malformed_range::de_malformed_range_http_request(request)
                 .await
                 .map_err(Into::into)
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-3003
+                )
             },
         );
         MalformedRangeInputFuture {
             inner: Box::pin(fut),
-3008
+        }
-3009
+    }
-3010
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::MalformedRangeOutput
-3016
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_malformed_range::ser_malformed_range_http_response(self)
-3019
+        {
             Ok(response) => response,
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-3024
+            }
-3025
+        }
-3026
+    }
-3027
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::MalformedRangeError
-3033
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_malformed_range::ser_malformed_range_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                 );
                 response
-3041
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-3045
+            }
-3046
+        }
-3047
+    }
-3048
+}
-3049
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod malformed_range_test {
-3056
     /// When a byte member does not fit within range bounds,
     /// the response should be a 400 ValidationException.
     /// Test ID: RestJsonMalformedRangeByte_case0
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn rest_json_malformed_range_byte_case0_malformed_request() {
-3063
+        {
             #[allow(unused_mut)]

↧ Expand context

             let mut http_request = http::Request::builder()
                 .uri("/MalformedRange")
                 .method("POST")
                 .header("content-type", "application/json")
                 .body(::aws_smithy_http_server::body::Body::from(
                     ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                         "{ \"byte\" : 1 }".as_bytes(),
                         ::aws_smithy_protocol_test::MediaType::from("unknown"),
                     )),
                 ))
                 .unwrap();
             #[allow(unused_mut)]
             let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
             let config = crate::service::RestJsonValidationConfig::builder().build();
             let service = crate::service::RestJsonValidation::builder::<::hyper::body::Body, _, _, _>(config)
                             .malformed_range(move |input: crate::input::MalformedRangeInput| {
                                 let sender = sender.clone();
                                 async move {
                                     let result = { panic!("request should have been rejected, but we accepted it; we parsed operation input `{:?}`", &input) as Result<crate::output::MalformedRangeOutput, crate::error::MalformedRangeError> };
                                     sender.send(()).await.expect("receiver dropped early");

@@ -4044,4090 +4105,4154 @@

↥ Expand context

             let service = crate::service::RestJsonValidation::builder::<::hyper::body::Body, _, _, _>(config)
                             .malformed_range(move |input: crate::input::MalformedRangeInput| {
                                 let sender = sender.clone();
                                 async move {
                                     let result = { panic!("request should have been rejected, but we accepted it; we parsed operation input `{:?}`", &input) as Result<crate::output::MalformedRangeOutput, crate::error::MalformedRangeError> };
                                     sender.send(()).await.expect("receiver dropped early");
                                     result
-4097
+                                }
                             })
                             .build_unchecked();
             let http_response = ::tower::ServiceExt::oneshot(service, http_request)
                 .await
                 .expect("unable to make an HTTP request");
             ::pretty_assertions::assert_eq!(
                 http::StatusCode::from_u16(400).expect("invalid expected HTTP status code"),
                 http_response.status()
             );
             let expected_headers = [("x-amzn-errortype", "ValidationException")];
             ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
                 http_response.headers(),

                 expected_headers,
             ));
             let body = ::hyper::body::to_bytes(http_response.into_body())
                 .await
                 .expect("unable to extract body to bytes");
             ::aws_smithy_protocol_test::assert_ok(
             ::aws_smithy_protocol_test::validate_body(&body, "{ \"message\" : \"1 validation error detected. Value at '/maxLong' failed to satisfy constraint: Member must be less than or equal to 8\",\n  \"fieldList\" : [{\"message\": \"Value at '/maxLong' failed to satisfy constraint: Member must be less than or equal to 8\", \"path\": \"/maxLong\"}]}", ::aws_smithy_protocol_test::MediaType::from("application/json"))
             );
-4118
+        }
-4119
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-4122
+}
-4123
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_MALFORMEDPATTERNOVERRIDE: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`MalformedPatternOverrideInput`](crate::input::MalformedPatternOverrideInput) using modelled bindings.
     pub struct MalformedPatternOverrideInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::MalformedPatternOverrideInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-4131
+    }
-4132
+}
-4133
 impl std::future::Future for MalformedPatternOverrideInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::MalformedPatternOverrideInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-4139
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-4146
+    }
-4147
+}
-4148
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::MalformedPatternOverrideInput
 where

@@ -4112,4161 +4207,4261 @@

↥ Expand context

-4161
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = MalformedPatternOverrideInputFuture;
-4164
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_MALFORMEDPATTERNOVERRIDE,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-4172
+            }
             crate::protocol_serde::shape_malformed_pattern_override::de_malformed_pattern_override_http_request(request)
                             .await
                             .map_err(Into::into)
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-4183
+                )
             },
         );
         MalformedPatternOverrideInputFuture {
             inner: Box::pin(fut),
-4188
+        }
-4189
+    }
-4190
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::MalformedPatternOverrideOutput
-4196
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_malformed_pattern_override::ser_malformed_pattern_override_http_response(self) {
                         Ok(response) => response,
                         Err(e) => {
                             ::tracing::error!(error = %e, "failed to serialize response");
                             ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-4203
+                        }
-4204
+                    }
-4205
+    }
-4206
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::MalformedPatternOverrideError
-4212
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_malformed_pattern_override::ser_malformed_pattern_override_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response
             },
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-4222
+            }
-4223
+        }
-4224
+    }
-4225
+}
-4226
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod malformed_pattern_override_test {
-4233
     /// When a string member does not match the specified pattern,
     /// the response should be a 400 ValidationException.
     /// Test ID: RestJsonMalformedPatternStringOverride_case0
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn rest_json_malformed_pattern_string_override_case0_malformed_request() {
-4240
+        {
             #[allow(unused_mut)]

↧ Expand context

             let mut http_request = http::Request::builder()
                 .uri("/MalformedPatternOverride")
                 .method("POST")
                 .header("content-type", "application/json")
                 .body(::aws_smithy_http_server::body::Body::from(
                     ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                         "{ \"string\" : \"abc\" }".as_bytes(),
                         ::aws_smithy_protocol_test::MediaType::from("unknown"),
                     )),
                 ))
                 .unwrap();
             #[allow(unused_mut)]
             let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
             let config = crate::service::RestJsonValidationConfig::builder().build();
             let service = crate::service::RestJsonValidation::builder::<::hyper::body::Body, _, _, _>(config)
                             .malformed_pattern_override(move |input: crate::input::MalformedPatternOverrideInput| {
                                 let sender = sender.clone();
                                 async move {
                                     let result = { panic!("request should have been rejected, but we accepted it; we parsed operation input `{:?}`", &input) as Result<crate::output::MalformedPatternOverrideOutput, crate::error::MalformedPatternOverrideError> };
                                     sender.send(()).await.expect("receiver dropped early");

@@ -4679,4733 +4740,4797 @@

↥ Expand context

             let service = crate::service::RestJsonValidation::builder::<::hyper::body::Body, _, _, _>(config)
                             .malformed_pattern_override(move |input: crate::input::MalformedPatternOverrideInput| {
                                 let sender = sender.clone();
                                 async move {
                                     let result = { panic!("request should have been rejected, but we accepted it; we parsed operation input `{:?}`", &input) as Result<crate::output::MalformedPatternOverrideOutput, crate::error::MalformedPatternOverrideError> };
                                     sender.send(()).await.expect("receiver dropped early");
                                     result
-4740
+                                }
                             })
                             .build_unchecked();
             let http_response = ::tower::ServiceExt::oneshot(service, http_request)
                 .await
                 .expect("unable to make an HTTP request");
             ::pretty_assertions::assert_eq!(
                 http::StatusCode::from_u16(400).expect("invalid expected HTTP status code"),
                 http_response.status()
             );
             let expected_headers = [("x-amzn-errortype", "ValidationException")];
             ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
                 http_response.headers(),

                 expected_headers,
             ));
             let body = ::hyper::body::to_bytes(http_response.into_body())
                 .await
                 .expect("unable to extract body to bytes");
             ::aws_smithy_protocol_test::assert_ok(
             ::aws_smithy_protocol_test::validate_body(&body, "{ \"message\" : \"1 validation error detected. Value at '/union/first' failed to satisfy constraint: Member must satisfy regular expression pattern: ^[g-m]+$\",\n  \"fieldList\" : [{\"message\": \"Value at '/union/first' failed to satisfy constraint: Member must satisfy regular expression pattern: ^[g-m]+$\", \"path\": \"/union/first\"}]}", ::aws_smithy_protocol_test::MediaType::from("application/json"))
             );
-4761
+        }
-4762
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-4765
+}
-4766
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_MALFORMEDPATTERN: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`MalformedPatternInput`](crate::input::MalformedPatternInput) using modelled bindings.
     pub struct MalformedPatternInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::MalformedPatternInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-4774
+    }
-4775
+}
-4776
 impl std::future::Future for MalformedPatternInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::MalformedPatternInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-4782
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-4789
+    }
-4790
+}
-4791
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::MalformedPatternInput
 where

@@ -4749,4806 +4850,4912 @@

↥ Expand context

     type Future = MalformedPatternInputFuture;
-4807
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_MALFORMEDPATTERN,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-4815
+            }
             crate::protocol_serde::shape_malformed_pattern::de_malformed_pattern_http_request(
                 request,
-4818
+            )
             .await
             .map_err(Into::into)
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-4828
+                )
             },
         );
         MalformedPatternInputFuture {
             inner: Box::pin(fut),
-4833
+        }
-4834
+    }
-4835
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::MalformedPatternOutput
-4841
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_malformed_pattern::ser_malformed_pattern_http_response(
             self,
         ) {
             Ok(response) => response,
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-4850
+            }
-4851
+        }
-4852
+    }
-4853
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::MalformedPatternError
-4859
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_malformed_pattern::ser_malformed_pattern_http_error(
             &self,
         ) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                 );
                 response
-4869
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-4873
+            }
-4874
+        }
-4875
+    }
-4876
+}
-4877
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod malformed_pattern_test {
-4884
     /// When a string member does not match the specified pattern,
     /// the response should be a 400 ValidationException.
     /// Test ID: RestJsonMalformedPatternString_case0
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn rest_json_malformed_pattern_string_case0_malformed_request() {
-4891
+        {
             #[allow(unused_mut)]

↧ Expand context

             let mut http_request = http::Request::builder()
                 .uri("/MalformedPattern")
                 .method("POST")
                 .header("content-type", "application/json")
                 .body(::aws_smithy_http_server::body::Body::from(
                     ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                         "{ \"string\" : \"ABC\" }".as_bytes(),
                         ::aws_smithy_protocol_test::MediaType::from("unknown"),
                     )),
                 ))
                 .unwrap();
             #[allow(unused_mut)]
             let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
             let config = crate::service::RestJsonValidationConfig::builder().build();
             let service = crate::service::RestJsonValidation::builder::<::hyper::body::Body, _, _, _>(config)
                             .malformed_pattern(move |input: crate::input::MalformedPatternInput| {
                                 let sender = sender.clone();
                                 async move {
                                     let result = { panic!("request should have been rejected, but we accepted it; we parsed operation input `{:?}`", &input) as Result<crate::output::MalformedPatternOutput, crate::error::MalformedPatternError> };
                                     sender.send(()).await.expect("receiver dropped early");

@@ -5425,5487 +5486,5551 @@

↥ Expand context

             let service = crate::service::RestJsonValidation::builder::<::hyper::body::Body, _, _, _>(config)
                             .malformed_pattern(move |input: crate::input::MalformedPatternInput| {
                                 let sender = sender.clone();
                                 async move {
                                     let result = { panic!("request should have been rejected, but we accepted it; we parsed operation input `{:?}`", &input) as Result<crate::output::MalformedPatternOutput, crate::error::MalformedPatternError> };
                                     sender.send(()).await.expect("receiver dropped early");
                                     result
-5494
+                                }
                             })
                             .build_unchecked();
             let http_response = ::tower::ServiceExt::oneshot(service, http_request)
                 .await
                 .expect("unable to make an HTTP request");
             ::pretty_assertions::assert_eq!(
                 http::StatusCode::from_u16(400).expect("invalid expected HTTP status code"),
                 http_response.status()
             );
             let expected_headers = [("x-amzn-errortype", "ValidationException")];
             ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
                 http_response.headers(),

                 expected_headers,
             ));
             let body = ::hyper::body::to_bytes(http_response.into_body())
                 .await
                 .expect("unable to extract body to bytes");
             ::aws_smithy_protocol_test::assert_ok(
             ::aws_smithy_protocol_test::validate_body(&body, "{ \"message\" : \"1 validation error detected. Value at '/union/first' failed to satisfy constraint: Member must satisfy regular expression pattern: ^[a-m]+$\",\n  \"fieldList\" : [{\"message\": \"Value at '/union/first' failed to satisfy constraint: Member must satisfy regular expression pattern: ^[a-m]+$\", \"path\": \"/union/first\"}]}", ::aws_smithy_protocol_test::MediaType::from("application/json"))
             );
-5515
+        }
-5516
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-5519
+}
-5520
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_MALFORMEDLENGTHQUERYSTRING: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`MalformedLengthQueryStringInput`](crate::input::MalformedLengthQueryStringInput) using modelled bindings.
     pub struct MalformedLengthQueryStringInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::MalformedLengthQueryStringInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-5528
+    }
-5529
+}
-5530
 impl std::future::Future for MalformedLengthQueryStringInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::MalformedLengthQueryStringInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-5536
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-5543
+    }
-5544
+}
-5545
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::MalformedLengthQueryStringInput
 where

@@ -5493,5558 +5645,5718 @@

↥ Expand context

-5558
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = MalformedLengthQueryStringInputFuture;
-5561
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_MALFORMEDLENGTHQUERYSTRING,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-5569
+            }
             crate::protocol_serde::shape_malformed_length_query_string::de_malformed_length_query_string_http_request(request)
                             .await
                             .map_err(Into::into)
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-5580
+                )
             },
         );
         MalformedLengthQueryStringInputFuture {
             inner: Box::pin(fut),
-5585
+        }
-5586
+    }
-5587
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::MalformedLengthQueryStringOutput
-5593
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_malformed_length_query_string::ser_malformed_length_query_string_http_response(self) {
                         Ok(response) => response,
                         Err(e) => {
                             ::tracing::error!(error = %e, "failed to serialize response");
                             ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-5600
+                        }
-5601
+                    }
-5602
+    }
-5603
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::MalformedLengthQueryStringError
-5609
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_malformed_length_query_string::ser_malformed_length_query_string_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response
             },
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-5619
+            }
-5620
+        }
-5621
+    }
-5622
+}
-5623
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod malformed_length_query_string_test {
-5630
     /// When a required member has no value in the query string,
     /// the response should be a 400 ValidationException.
     /// Test ID: RestJsonMalformedLengthQueryStringNoValue
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn rest_json_malformed_length_query_string_no_value_malformed_request() {
-5637
+        {
             #[allow(unused_mut)]
             let mut http_request = http::Request::builder()
                 .uri("/MalformedLengthQueryString")
                 .method("POST")
                 .header("content-type", "application/json")
                 .body(::aws_smithy_http_server::body::Body::from(
                     ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                         "{}".as_bytes(),
                         ::aws_smithy_protocol_test::MediaType::from("unknown"),
                     )),
                 ))
                 .unwrap();
             *http_request.uri_mut() = "/MalformedLengthQueryString?string".parse().unwrap();
             #[allow(unused_mut)]
             let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
             let config = crate::service::RestJsonValidationConfig::builder().build();
             let service = crate::service::RestJsonValidation::builder::<::hyper::body::Body, _, _, _>(config)
                             .malformed_length_query_string(move |input: crate::input::MalformedLengthQueryStringInput| {
                                 let sender = sender.clone();
                                 async move {
                                     let result = { panic!("request should have been rejected, but we accepted it; we parsed operation input `{:?}`", &input) as Result<crate::output::MalformedLengthQueryStringOutput, crate::error::MalformedLengthQueryStringError> };
                                     sender.send(()).await.expect("receiver dropped early");
                                     result
-5661
+                                }
                             })
                             .build_unchecked();
             let http_response = ::tower::ServiceExt::oneshot(service, http_request)
                 .await
                 .expect("unable to make an HTTP request");
             ::pretty_assertions::assert_eq!(
                 http::StatusCode::from_u16(400).expect("invalid expected HTTP status code"),
                 http_response.status()
             );
             let expected_headers = [("x-amzn-errortype", "ValidationException")];
             ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
                 http_response.headers(),
                 expected_headers,
             ));
             let body = ::hyper::body::to_bytes(http_response.into_body())
                 .await
                 .expect("unable to extract body to bytes");
             ::aws_smithy_protocol_test::assert_ok(
             ::aws_smithy_protocol_test::validate_body(&body, "{ \"message\" : \"1 validation error detected. Value with length 0 at '/string' failed to satisfy constraint: Member must have length between 2 and 8, inclusive\",\n  \"fieldList\" : [{\"message\": \"Value with length 0 at '/string' failed to satisfy constraint: Member must have length between 2 and 8, inclusive\", \"path\": \"/string\"}]}", ::aws_smithy_protocol_test::MediaType::from("application/json"))
             );
-5682
+        }
-5683
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-5686
+}
-5687
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_MALFORMEDLENGTHOVERRIDE: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`MalformedLengthOverrideInput`](crate::input::MalformedLengthOverrideInput) using modelled bindings.
     pub struct MalformedLengthOverrideInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::MalformedLengthOverrideInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-5695
+    }
-5696
+}
-5697
 impl std::future::Future for MalformedLengthOverrideInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::MalformedLengthOverrideInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-5703
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-5710
+    }
-5711
+}
-5712
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::MalformedLengthOverrideInput
 where

@@ -5652,5725 +5747,5825 @@

↥ Expand context

-5725
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = MalformedLengthOverrideInputFuture;
-5728
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_MALFORMEDLENGTHOVERRIDE,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-5736
+            }
             crate::protocol_serde::shape_malformed_length_override::de_malformed_length_override_http_request(request)
                             .await
                             .map_err(Into::into)
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-5747
+                )
             },
         );
         MalformedLengthOverrideInputFuture {
             inner: Box::pin(fut),
-5752
+        }
-5753
+    }
-5754
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::MalformedLengthOverrideOutput
-5760
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_malformed_length_override::ser_malformed_length_override_http_response(self) {
                         Ok(response) => response,
                         Err(e) => {
                             ::tracing::error!(error = %e, "failed to serialize response");
                             ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-5767
+                        }
-5768
+                    }
-5769
+    }
-5770
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::MalformedLengthOverrideError
-5776
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_malformed_length_override::ser_malformed_length_override_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response
             },
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-5786
+            }
-5787
+        }
-5788
+    }
-5789
+}
-5790
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod malformed_length_override_test {
-5797
     /// When a blob member does not fit within length bounds,
     /// the response should be a 400 ValidationException.
     /// Test ID: RestJsonMalformedLengthBlobOverride_case0
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn rest_json_malformed_length_blob_override_case0_malformed_request() {
-5804
+        {
             #[allow(unused_mut)]

↧ Expand context

             let mut http_request = http::Request::builder()
                 .uri("/MalformedLengthOverride")
                 .method("POST")
                 .header("content-type", "application/json")
                 .body(::aws_smithy_http_server::body::Body::from(
                     ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                         "{ \"blob\" : \"YWJj\" }".as_bytes(),
                         ::aws_smithy_protocol_test::MediaType::from("unknown"),
                     )),
                 ))
                 .unwrap();
             #[allow(unused_mut)]
             let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
             let config = crate::service::RestJsonValidationConfig::builder().build();
             let service = crate::service::RestJsonValidation::builder::<::hyper::body::Body, _, _, _>(config)
                             .malformed_length_override(move |input: crate::input::MalformedLengthOverrideInput| {
                                 let sender = sender.clone();
                                 async move {
                                     let result = { panic!("request should have been rejected, but we accepted it; we parsed operation input `{:?}`", &input) as Result<crate::output::MalformedLengthOverrideOutput, crate::error::MalformedLengthOverrideError> };
                                     sender.send(()).await.expect("receiver dropped early");

@@ -6266,6344 +6327,6408 @@

↥ Expand context

             let service = crate::service::RestJsonValidation::builder::<::hyper::body::Body, _, _, _>(config)
                             .malformed_length_override(move |input: crate::input::MalformedLengthOverrideInput| {
                                 let sender = sender.clone();
                                 async move {
                                     let result = { panic!("request should have been rejected, but we accepted it; we parsed operation input `{:?}`", &input) as Result<crate::output::MalformedLengthOverrideOutput, crate::error::MalformedLengthOverrideError> };
                                     sender.send(()).await.expect("receiver dropped early");
                                     result
-6351
+                                }
                             })
                             .build_unchecked();
             let http_response = ::tower::ServiceExt::oneshot(service, http_request)
                 .await
                 .expect("unable to make an HTTP request");
             ::pretty_assertions::assert_eq!(
                 http::StatusCode::from_u16(400).expect("invalid expected HTTP status code"),
                 http_response.status()
             );
             let expected_headers = [("x-amzn-errortype", "ValidationException")];
             ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
                 http_response.headers(),

                 expected_headers,
             ));
             let body = ::hyper::body::to_bytes(http_response.into_body())
                 .await
                 .expect("unable to extract body to bytes");
             ::aws_smithy_protocol_test::assert_ok(
             ::aws_smithy_protocol_test::validate_body(&body, "{ \"message\" : \"1 validation error detected. Value with length 7 at '/map' failed to satisfy constraint: Member must have length between 4 and 6, inclusive\",\n  \"fieldList\" : [{\"message\": \"Value with length 7 at '/map' failed to satisfy constraint: Member must have length between 4 and 6, inclusive\", \"path\": \"/map\"}]}", ::aws_smithy_protocol_test::MediaType::from("application/json"))
             );
-6372
+        }
-6373
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-6376
+}
-6377
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_MALFORMEDLENGTH: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`MalformedLengthInput`](crate::input::MalformedLengthInput) using modelled bindings.
     pub struct MalformedLengthInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::MalformedLengthInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-6385
+    }
-6386
+}
-6387
 impl std::future::Future for MalformedLengthInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::MalformedLengthInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-6393
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-6400
+    }
-6401
+}
-6402
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::MalformedLengthInput
 where

@@ -6334,6415 +6434,6520 @@

↥ Expand context

-6415
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = MalformedLengthInputFuture;
-6418
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_MALFORMEDLENGTH,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-6426
+            }
             crate::protocol_serde::shape_malformed_length::de_malformed_length_http_request(request)
                 .await
                 .map_err(Into::into)
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-6437
+                )
             },
         );
         MalformedLengthInputFuture {
             inner: Box::pin(fut),
-6442
+        }
-6443
+    }
-6444
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::MalformedLengthOutput
-6450
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_malformed_length::ser_malformed_length_http_response(
             self,
         ) {
             Ok(response) => response,
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-6459
+            }
-6460
+        }
-6461
+    }
-6462
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::MalformedLengthError
-6468
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_malformed_length::ser_malformed_length_http_error(&self)
-6471
+        {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                 );
                 response
-6477
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-6481
+            }
-6482
+        }
-6483
+    }
-6484
+}
-6485
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod malformed_length_test {
-6492
     /// When a blob member does not fit within length bounds,
     /// the response should be a 400 ValidationException.
     /// Test ID: RestJsonMalformedLengthBlob_case0
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn rest_json_malformed_length_blob_case0_malformed_request() {
-6499
+        {
             #[allow(unused_mut)]

↧ Expand context

             let mut http_request = http::Request::builder()
                 .uri("/MalformedLength")
                 .method("POST")
                 .header("content-type", "application/json")
                 .body(::aws_smithy_http_server::body::Body::from(
                     ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                         "{ \"blob\" : \"YQ==\" }".as_bytes(),
                         ::aws_smithy_protocol_test::MediaType::from("unknown"),
                     )),
                 ))
                 .unwrap();
             #[allow(unused_mut)]
             let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
             let config = crate::service::RestJsonValidationConfig::builder().build();
             let service = crate::service::RestJsonValidation::builder::<::hyper::body::Body, _, _, _>(config)
                             .malformed_length(move |input: crate::input::MalformedLengthInput| {
                                 let sender = sender.clone();
                                 async move {
                                     let result = { panic!("request should have been rejected, but we accepted it; we parsed operation input `{:?}`", &input) as Result<crate::output::MalformedLengthOutput, crate::error::MalformedLengthError> };
                                     sender.send(()).await.expect("receiver dropped early");

@@ -7265,7351 +7326,7415 @@

↥ Expand context

             let service = crate::service::RestJsonValidation::builder::<::hyper::body::Body, _, _, _>(config)
                             .malformed_length(move |input: crate::input::MalformedLengthInput| {
                                 let sender = sender.clone();
                                 async move {
                                     let result = { panic!("request should have been rejected, but we accepted it; we parsed operation input `{:?}`", &input) as Result<crate::output::MalformedLengthOutput, crate::error::MalformedLengthError> };
                                     sender.send(()).await.expect("receiver dropped early");
                                     result
-7358
+                                }
                             })
                             .build_unchecked();
             let http_response = ::tower::ServiceExt::oneshot(service, http_request)
                 .await
                 .expect("unable to make an HTTP request");
             ::pretty_assertions::assert_eq!(
                 http::StatusCode::from_u16(400).expect("invalid expected HTTP status code"),
                 http_response.status()
             );
             let expected_headers = [("x-amzn-errortype", "ValidationException")];
             ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
                 http_response.headers(),

                 expected_headers,
             ));
             let body = ::hyper::body::to_bytes(http_response.into_body())
                 .await
                 .expect("unable to extract body to bytes");
             ::aws_smithy_protocol_test::assert_ok(
             ::aws_smithy_protocol_test::validate_body(&body, "{ \"message\" : \"1 validation error detected. Value with length 10 at '/map/abc' failed to satisfy constraint: Member must have length between 2 and 8, inclusive\",\n  \"fieldList\" : [{\"message\": \"Value with length 10 at '/map/abc' failed to satisfy constraint: Member must have length between 2 and 8, inclusive\", \"path\": \"/map/abc\"}]}", ::aws_smithy_protocol_test::MediaType::from("application/json"))
             );
-7379
+        }
-7380
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-7383
+}
-7384
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_MALFORMEDENUM: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`MalformedEnumInput`](crate::input::MalformedEnumInput) using modelled bindings.
     pub struct MalformedEnumInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::MalformedEnumInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-7392
+    }
-7393
+}
-7394
 impl std::future::Future for MalformedEnumInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::MalformedEnumInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-7400
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-7407
+    }
-7408
+}
-7409
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::MalformedEnumInput
 where

@@ -7333,7422 +7430,7524 @@

↥ Expand context

-7422
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = MalformedEnumInputFuture;
-7425
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_MALFORMEDENUM,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-7433
+            }
             crate::protocol_serde::shape_malformed_enum::de_malformed_enum_http_request(request)
                 .await
                 .map_err(Into::into)
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-7444
+                )
             },
         );
         MalformedEnumInputFuture {
             inner: Box::pin(fut),
-7449
+        }
-7450
+    }
-7451
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::MalformedEnumOutput
-7457
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_malformed_enum::ser_malformed_enum_http_response(self) {
             Ok(response) => response,
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-7464
+            }
-7465
+        }
-7466
+    }
-7467
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::MalformedEnumError
-7473
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_malformed_enum::ser_malformed_enum_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                 );
                 response
-7481
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-7485
+            }
-7486
+        }
-7487
+    }
-7488
+}
-7489
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod malformed_enum_test {
-7496
     /// When a string member does not contain a valid enum value,
     /// the response should be a 400 ValidationException. Internal-only
     /// enum values are excluded from the response message.
     /// Test ID: RestJsonMalformedEnumString_case0
     #[::tokio::test]
     #[::tracing_test::traced_test]
     #[should_panic]
     async fn rest_json_malformed_enum_string_case0_malformed_request() {

↧ Expand context

-7505
+        {
             #[allow(unused_mut)]
             let mut http_request = http::Request::builder()
                 .uri("/MalformedEnum")
                 .method("POST")
                 .header("content-type", "application/json")
                 .body(::aws_smithy_http_server::body::Body::from(
                     ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                         "{ \"string\" : \"ABC\" }".as_bytes(),
                         ::aws_smithy_protocol_test::MediaType::from("unknown"),
                     )),
                 ))
                 .unwrap();
             #[allow(unused_mut)]
             let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
             let config = crate::service::RestJsonValidationConfig::builder().build();
             let service = crate::service::RestJsonValidation::builder::<::hyper::body::Body, _, _, _>(config)
                             .malformed_enum(move |input: crate::input::MalformedEnumInput| {
                                 let sender = sender.clone();
                                 async move {

@@ -8032,8126 +8062,8158 @@

↥ Expand context

             let service = crate::service::RestJsonValidation::builder::<::hyper::body::Body, _, _, _>(config)
                             .malformed_enum(move |input: crate::input::MalformedEnumInput| {
                                 let sender = sender.clone();
                                 async move {
                                     let result = { panic!("request should have been rejected, but we accepted it; we parsed operation input `{:?}`", &input) as Result<crate::output::MalformedEnumOutput, crate::error::MalformedEnumError> };
                                     sender.send(()).await.expect("receiver dropped early");
                                     result
-8133
+                                }
                             })
                             .build_unchecked();
             let http_response = ::tower::ServiceExt::oneshot(service, http_request)
                 .await
                 .expect("unable to make an HTTP request");
             ::pretty_assertions::assert_eq!(
                 http::StatusCode::from_u16(400).expect("invalid expected HTTP status code"),
                 http_response.status()
             );
             let expected_headers = [("x-amzn-errortype", "ValidationException")];
             ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
                 http_response.headers(),

                 expected_headers,
             ));
             let body = ::hyper::body::to_bytes(http_response.into_body())
                 .await
                 .expect("unable to extract body to bytes");
             ::aws_smithy_protocol_test::assert_ok(
             ::aws_smithy_protocol_test::validate_body(&body, "{ \"message\" : \"1 validation error detected. Value at '/union/first' failed to satisfy constraint: Member must satisfy enum value set: [abc, def, jkl]\",\n  \"fieldList\" : [{\"message\": \"Value at '/union/first' failed to satisfy constraint: Member must satisfy enum value set: [abc, def, jkl]\", \"path\": \"/union/first\"}]}", ::aws_smithy_protocol_test::MediaType::from("application/json"))
             );
-8154
+        }
-8155
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-8158
+}

tmp-codegen-diff/codegen-server-test/rest_json_validation/rust-server-codegen/src/operation_shape.rs

@@ -1,1 +0,500 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct SensitiveValidation;
-6
 impl ::aws_smithy_http_server::operation::OperationShape for SensitiveValidation {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson.validation#SensitiveValidation",
             "aws.protocoltests.restjson.validation",
             "SensitiveValidation",
         );
-14
     type Input = crate::input::SensitiveValidationInput;
     type Output = crate::output::SensitiveValidationOutput;
     type Error = crate::error::SensitiveValidationError;
-18
+}
-19
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for SensitiveValidation {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-32
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-35
+    }
-36
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-39
+    }
-40
+}
 /* ServerOperationGenerator.kt:88 */
-42
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct RecursiveStructures;
-47
 impl ::aws_smithy_http_server::operation::OperationShape for RecursiveStructures {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson.validation#RecursiveStructures",
             "aws.protocoltests.restjson.validation",
             "RecursiveStructures",
         );
-55
     type Input = crate::input::RecursiveStructuresInput;
     type Output = crate::output::RecursiveStructuresOutput;
     type Error = crate::error::RecursiveStructuresError;
-59
+}
-60
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for RecursiveStructures {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-73
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-76
+    }
-77
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-80
+    }
-81
+}
 /* ServerOperationGenerator.kt:88 */
-83
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct MalformedUniqueItems;
-88
 impl ::aws_smithy_http_server::operation::OperationShape for MalformedUniqueItems {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson.validation#MalformedUniqueItems",
             "aws.protocoltests.restjson.validation",
             "MalformedUniqueItems",
         );
-96
     type Input = crate::input::MalformedUniqueItemsInput;
     type Output = crate::output::MalformedUniqueItemsOutput;
     type Error = crate::error::MalformedUniqueItemsError;
-100
+}
-101
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for MalformedUniqueItems {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-114
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-117
+    }
-118
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-121
+    }
-122
+}
 /* ServerOperationGenerator.kt:88 */
-124
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct MalformedRequired;
-129
 impl ::aws_smithy_http_server::operation::OperationShape for MalformedRequired {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson.validation#MalformedRequired",
             "aws.protocoltests.restjson.validation",
             "MalformedRequired",
         );
-137
     type Input = crate::input::MalformedRequiredInput;
     type Output = crate::output::MalformedRequiredOutput;
     type Error = crate::error::MalformedRequiredError;
-141
+}
-142
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for MalformedRequired {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-155
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-158
+    }
-159
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-162
+    }
-163
+}
 /* ServerOperationGenerator.kt:88 */
-165
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct MalformedRangeOverride;
-170
 impl ::aws_smithy_http_server::operation::OperationShape for MalformedRangeOverride {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson.validation#MalformedRangeOverride",
             "aws.protocoltests.restjson.validation",
             "MalformedRangeOverride",
         );
-178
     type Input = crate::input::MalformedRangeOverrideInput;
     type Output = crate::output::MalformedRangeOverrideOutput;
     type Error = crate::error::MalformedRangeOverrideError;
-182
+}
-183
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity
     for MalformedRangeOverride
-186
+{
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-198
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-201
+    }
-202
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-205
+    }
-206
+}
 /* ServerOperationGenerator.kt:88 */
-208
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct MalformedRange;
-213
 impl ::aws_smithy_http_server::operation::OperationShape for MalformedRange {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson.validation#MalformedRange",
             "aws.protocoltests.restjson.validation",
             "MalformedRange",
         );
-221
     type Input = crate::input::MalformedRangeInput;
     type Output = crate::output::MalformedRangeOutput;
     type Error = crate::error::MalformedRangeError;
-225
+}
-226
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for MalformedRange {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-239
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-242
+    }
-243
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-246
+    }
-247
+}
 /* ServerOperationGenerator.kt:88 */
-249
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct MalformedPatternOverride;
-254
 impl ::aws_smithy_http_server::operation::OperationShape for MalformedPatternOverride {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson.validation#MalformedPatternOverride",
             "aws.protocoltests.restjson.validation",
             "MalformedPatternOverride",
         );
-262
     type Input = crate::input::MalformedPatternOverrideInput;
     type Output = crate::output::MalformedPatternOverrideOutput;
     type Error = crate::error::MalformedPatternOverrideError;
-266
+}
-267
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity
     for MalformedPatternOverride
-270
+{
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-282
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-285
+    }
-286
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-289
+    }
-290
+}
 /* ServerOperationGenerator.kt:88 */
-292
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct MalformedPattern;
-297
 impl ::aws_smithy_http_server::operation::OperationShape for MalformedPattern {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson.validation#MalformedPattern",
             "aws.protocoltests.restjson.validation",
             "MalformedPattern",
         );
-305
     type Input = crate::input::MalformedPatternInput;
     type Output = crate::output::MalformedPatternOutput;
     type Error = crate::error::MalformedPatternError;
-309
+}
-310
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for MalformedPattern {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-323
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-326
+    }
-327
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-330
+    }
-331
+}
 /* ServerOperationGenerator.kt:88 */
-333
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct MalformedLengthQueryString;
-338
 impl ::aws_smithy_http_server::operation::OperationShape for MalformedLengthQueryString {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson.validation#MalformedLengthQueryString",
             "aws.protocoltests.restjson.validation",
             "MalformedLengthQueryString",
         );
-346
     type Input = crate::input::MalformedLengthQueryStringInput;
     type Output = crate::output::MalformedLengthQueryStringOutput;
     type Error = crate::error::MalformedLengthQueryStringError;
-350
+}
-351
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity
     for MalformedLengthQueryString
-354
+{
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-366
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-369
+    }
-370
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-373
+    }
-374
+}
 /* ServerOperationGenerator.kt:88 */
-376
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct MalformedLengthOverride;
-381
 impl ::aws_smithy_http_server::operation::OperationShape for MalformedLengthOverride {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson.validation#MalformedLengthOverride",
             "aws.protocoltests.restjson.validation",
             "MalformedLengthOverride",
         );
-389
     type Input = crate::input::MalformedLengthOverrideInput;
     type Output = crate::output::MalformedLengthOverrideOutput;
     type Error = crate::error::MalformedLengthOverrideError;
-393
+}
-394
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity
     for MalformedLengthOverride
-397
+{
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-409
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-412
+    }
-413
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-416
+    }
-417
+}
 /* ServerOperationGenerator.kt:88 */
-419
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct MalformedLength;
-424
 impl ::aws_smithy_http_server::operation::OperationShape for MalformedLength {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson.validation#MalformedLength",
             "aws.protocoltests.restjson.validation",
             "MalformedLength",
         );
-432
     type Input = crate::input::MalformedLengthInput;
     type Output = crate::output::MalformedLengthOutput;
     type Error = crate::error::MalformedLengthError;
-436
+}
-437
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for MalformedLength {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-450
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-453
+    }
-454
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-457
+    }
-458
+}
 /* ServerOperationGenerator.kt:88 */
-460
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct MalformedEnum;
-465
 impl ::aws_smithy_http_server::operation::OperationShape for MalformedEnum {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson.validation#MalformedEnum",
             "aws.protocoltests.restjson.validation",
             "MalformedEnum",
         );
-473
     type Input = crate::input::MalformedEnumInput;
     type Output = crate::output::MalformedEnumOutput;
     type Error = crate::error::MalformedEnumError;
-477
+}
-478
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for MalformedEnum {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-491
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-494
+    }
-495
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-498
+    }
-499
+}
 /* ServerOperationGenerator.kt:88 */

tmp-codegen-diff/codegen-server-test/rest_json_validation/rust-server-codegen/src/output.rs

@@ -1,1 +398,626 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct SensitiveValidationOutput {}
 pub /* StructureGenerator.kt:201 */ struct SensitiveValidationOutput {/* StructureGenerator.kt:201 */}
 /* ServerCodegenVisitor.kt:345 */
 impl SensitiveValidationOutput {
     /// Creates a new builder-style object to manufacture [`SensitiveValidationOutput`](crate::output::SensitiveValidationOutput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`SensitiveValidationOutput`](crate::output::SensitiveValidationOutput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::output::sensitive_validation_output::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::output::sensitive_validation_output::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-17
+    }
     /* ServerCodegenVisitor.kt:345 */
-19
+}
-20
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct RecursiveStructuresOutput {}
 pub /* StructureGenerator.kt:201 */ struct RecursiveStructuresOutput {/* StructureGenerator.kt:201 */}
 /* ServerCodegenVisitor.kt:345 */
 impl RecursiveStructuresOutput {
     /// Creates a new builder-style object to manufacture [`RecursiveStructuresOutput`](crate::output::RecursiveStructuresOutput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`RecursiveStructuresOutput`](crate::output::RecursiveStructuresOutput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::output::recursive_structures_output::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::output::recursive_structures_output::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-36
+    }
     /* ServerCodegenVisitor.kt:345 */
-38
+}
-39
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct MalformedUniqueItemsOutput {}
 pub /* StructureGenerator.kt:201 */ struct MalformedUniqueItemsOutput {/* StructureGenerator.kt:201 */}
 /* ServerCodegenVisitor.kt:345 */
 impl MalformedUniqueItemsOutput {
     /// Creates a new builder-style object to manufacture [`MalformedUniqueItemsOutput`](crate::output::MalformedUniqueItemsOutput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`MalformedUniqueItemsOutput`](crate::output::MalformedUniqueItemsOutput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::output::malformed_unique_items_output::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::output::malformed_unique_items_output::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-55
+    }
     /* ServerCodegenVisitor.kt:345 */
-57
+}
-58
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct MalformedRequiredOutput {}
 pub /* StructureGenerator.kt:201 */ struct MalformedRequiredOutput {/* StructureGenerator.kt:201 */}
 /* ServerCodegenVisitor.kt:345 */
 impl MalformedRequiredOutput {
     /// Creates a new builder-style object to manufacture [`MalformedRequiredOutput`](crate::output::MalformedRequiredOutput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`MalformedRequiredOutput`](crate::output::MalformedRequiredOutput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::output::malformed_required_output::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::output::malformed_required_output::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-74
+    }
     /* ServerCodegenVisitor.kt:345 */
-76
+}
-77
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct MalformedRangeOverrideOutput {}
 pub /* StructureGenerator.kt:201 */ struct MalformedRangeOverrideOutput {/* StructureGenerator.kt:201 */}
 /* ServerCodegenVisitor.kt:345 */
 impl MalformedRangeOverrideOutput {
     /// Creates a new builder-style object to manufacture [`MalformedRangeOverrideOutput`](crate::output::MalformedRangeOverrideOutput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`MalformedRangeOverrideOutput`](crate::output::MalformedRangeOverrideOutput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::output::malformed_range_override_output::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::output::malformed_range_override_output::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-93
+    }
     /* ServerCodegenVisitor.kt:345 */
-95
+}
-96
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct MalformedRangeOutput {}
 pub /* StructureGenerator.kt:201 */ struct MalformedRangeOutput {/* StructureGenerator.kt:201 */}
 /* ServerCodegenVisitor.kt:345 */
 impl MalformedRangeOutput {
     /// Creates a new builder-style object to manufacture [`MalformedRangeOutput`](crate::output::MalformedRangeOutput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`MalformedRangeOutput`](crate::output::MalformedRangeOutput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::output::malformed_range_output::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::output::malformed_range_output::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-112
+    }
     /* ServerCodegenVisitor.kt:345 */
-114
+}
-115
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct MalformedPatternOverrideOutput {}
 pub /* StructureGenerator.kt:201 */ struct MalformedPatternOverrideOutput {/* StructureGenerator.kt:201 */}
 /* ServerCodegenVisitor.kt:345 */
 impl MalformedPatternOverrideOutput {
     /// Creates a new builder-style object to manufacture [`MalformedPatternOverrideOutput`](crate::output::MalformedPatternOverrideOutput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`MalformedPatternOverrideOutput`](crate::output::MalformedPatternOverrideOutput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::output::malformed_pattern_override_output::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::output::malformed_pattern_override_output::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-131
+    }
     /* ServerCodegenVisitor.kt:345 */
-133
+}
-134
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct MalformedPatternOutput {}
 pub /* StructureGenerator.kt:201 */ struct MalformedPatternOutput {/* StructureGenerator.kt:201 */}
 /* ServerCodegenVisitor.kt:345 */
 impl MalformedPatternOutput {
     /// Creates a new builder-style object to manufacture [`MalformedPatternOutput`](crate::output::MalformedPatternOutput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`MalformedPatternOutput`](crate::output::MalformedPatternOutput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::output::malformed_pattern_output::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::output::malformed_pattern_output::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-150
+    }
     /* ServerCodegenVisitor.kt:345 */
-152
+}
-153
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct MalformedLengthQueryStringOutput {}
 pub /* StructureGenerator.kt:201 */ struct MalformedLengthQueryStringOutput {/* StructureGenerator.kt:201 */}
 /* ServerCodegenVisitor.kt:345 */
 impl MalformedLengthQueryStringOutput {
     /// Creates a new builder-style object to manufacture [`MalformedLengthQueryStringOutput`](crate::output::MalformedLengthQueryStringOutput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`MalformedLengthQueryStringOutput`](crate::output::MalformedLengthQueryStringOutput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::output::malformed_length_query_string_output::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::output::malformed_length_query_string_output::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-169
+    }
     /* ServerCodegenVisitor.kt:345 */
-171
+}
-172
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct MalformedLengthOverrideOutput {}
 pub /* StructureGenerator.kt:201 */ struct MalformedLengthOverrideOutput {/* StructureGenerator.kt:201 */}
 /* ServerCodegenVisitor.kt:345 */
 impl MalformedLengthOverrideOutput {
     /// Creates a new builder-style object to manufacture [`MalformedLengthOverrideOutput`](crate::output::MalformedLengthOverrideOutput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`MalformedLengthOverrideOutput`](crate::output::MalformedLengthOverrideOutput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::output::malformed_length_override_output::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::output::malformed_length_override_output::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-188
+    }
     /* ServerCodegenVisitor.kt:345 */
-190
+}
-191
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct MalformedLengthOutput {}
 pub /* StructureGenerator.kt:201 */ struct MalformedLengthOutput {/* StructureGenerator.kt:201 */}
 /* ServerCodegenVisitor.kt:345 */
 impl MalformedLengthOutput {
     /// Creates a new builder-style object to manufacture [`MalformedLengthOutput`](crate::output::MalformedLengthOutput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`MalformedLengthOutput`](crate::output::MalformedLengthOutput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::output::malformed_length_output::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::output::malformed_length_output::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-207
+    }
     /* ServerCodegenVisitor.kt:345 */
-209
+}
-210
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct MalformedEnumOutput {}
 pub /* StructureGenerator.kt:201 */ struct MalformedEnumOutput {/* StructureGenerator.kt:201 */}
 /* ServerCodegenVisitor.kt:345 */
 impl MalformedEnumOutput {
     /// Creates a new builder-style object to manufacture [`MalformedEnumOutput`](crate::output::MalformedEnumOutput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`MalformedEnumOutput`](crate::output::MalformedEnumOutput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::output::malformed_enum_output::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::output::malformed_enum_output::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-226
+    }
     /* ServerCodegenVisitor.kt:345 */
-228
+}
 /// See [`SensitiveValidationOutput`](crate::output::SensitiveValidationOutput).
 /// /* ServerBuilderGenerator.kt:171 */See [`SensitiveValidationOutput`](crate::output::SensitiveValidationOutput).
 pub mod sensitive_validation_output {
-231
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::output::SensitiveValidationOutput {
         fn from(builder: Builder) -> Self {
             builder.build()
-236
+        }
-237
+    }
     /// A builder for [`SensitiveValidationOutput`](crate::output::SensitiveValidationOutput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`SensitiveValidationOutput`](crate::output::SensitiveValidationOutput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {}
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {/* ServerBuilderGenerator.kt:211 */}
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// Consumes the builder and constructs a [`SensitiveValidationOutput`](crate::output::SensitiveValidationOutput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`SensitiveValidationOutput`](crate::output::SensitiveValidationOutput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::output::SensitiveValidationOutput {
             self.build_enforcing_all_constraints()
-249
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(self) -> crate::output::SensitiveValidationOutput {
             crate::output::SensitiveValidationOutput {}
             /* ServerBuilderGenerator.kt:542 */
             crate::output::SensitiveValidationOutput {
             /* ServerBuilderGenerator.kt:542 */}
             /* ServerBuilderGenerator.kt:283 */
-256
+        }
         /* ServerBuilderGenerator.kt:215 */
-258
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-261
+}
 /// See [`RecursiveStructuresOutput`](crate::output::RecursiveStructuresOutput).
 /// /* ServerBuilderGenerator.kt:171 */See [`RecursiveStructuresOutput`](crate::output::RecursiveStructuresOutput).
 pub mod recursive_structures_output {
-264
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::output::RecursiveStructuresOutput {
         fn from(builder: Builder) -> Self {
             builder.build()
-269
+        }
-270
+    }
     /// A builder for [`RecursiveStructuresOutput`](crate::output::RecursiveStructuresOutput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`RecursiveStructuresOutput`](crate::output::RecursiveStructuresOutput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {}
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {/* ServerBuilderGenerator.kt:211 */}
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// Consumes the builder and constructs a [`RecursiveStructuresOutput`](crate::output::RecursiveStructuresOutput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`RecursiveStructuresOutput`](crate::output::RecursiveStructuresOutput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::output::RecursiveStructuresOutput {
             self.build_enforcing_all_constraints()
-282
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(self) -> crate::output::RecursiveStructuresOutput {
             crate::output::RecursiveStructuresOutput {}
             /* ServerBuilderGenerator.kt:542 */
             crate::output::RecursiveStructuresOutput {
             /* ServerBuilderGenerator.kt:542 */}
             /* ServerBuilderGenerator.kt:283 */
-289
+        }
         /* ServerBuilderGenerator.kt:215 */
-291
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-294
+}
 /// See [`MalformedUniqueItemsOutput`](crate::output::MalformedUniqueItemsOutput).
 /// /* ServerBuilderGenerator.kt:171 */See [`MalformedUniqueItemsOutput`](crate::output::MalformedUniqueItemsOutput).
 pub mod malformed_unique_items_output {
-297
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::output::MalformedUniqueItemsOutput {
         fn from(builder: Builder) -> Self {
             builder.build()
-302
+        }
-303
+    }
     /// A builder for [`MalformedUniqueItemsOutput`](crate::output::MalformedUniqueItemsOutput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`MalformedUniqueItemsOutput`](crate::output::MalformedUniqueItemsOutput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {}
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {/* ServerBuilderGenerator.kt:211 */}
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// Consumes the builder and constructs a [`MalformedUniqueItemsOutput`](crate::output::MalformedUniqueItemsOutput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`MalformedUniqueItemsOutput`](crate::output::MalformedUniqueItemsOutput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::output::MalformedUniqueItemsOutput {
             self.build_enforcing_all_constraints()
-315
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(self) -> crate::output::MalformedUniqueItemsOutput {
             crate::output::MalformedUniqueItemsOutput {}
             /* ServerBuilderGenerator.kt:542 */
             crate::output::MalformedUniqueItemsOutput {
             /* ServerBuilderGenerator.kt:542 */}
             /* ServerBuilderGenerator.kt:283 */
-322
+        }
         /* ServerBuilderGenerator.kt:215 */
-324
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-327
+}
 /// See [`MalformedRequiredOutput`](crate::output::MalformedRequiredOutput).
 /// /* ServerBuilderGenerator.kt:171 */See [`MalformedRequiredOutput`](crate::output::MalformedRequiredOutput).
 pub mod malformed_required_output {
-330
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::output::MalformedRequiredOutput {
         fn from(builder: Builder) -> Self {
             builder.build()
-335
+        }
-336
+    }
     /// A builder for [`MalformedRequiredOutput`](crate::output::MalformedRequiredOutput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`MalformedRequiredOutput`](crate::output::MalformedRequiredOutput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {}
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {/* ServerBuilderGenerator.kt:211 */}
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// Consumes the builder and constructs a [`MalformedRequiredOutput`](crate::output::MalformedRequiredOutput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`MalformedRequiredOutput`](crate::output::MalformedRequiredOutput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::output::MalformedRequiredOutput {
             self.build_enforcing_all_constraints()
-348
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(self) -> crate::output::MalformedRequiredOutput {
             crate::output::MalformedRequiredOutput {}
             /* ServerBuilderGenerator.kt:542 */
             crate::output::MalformedRequiredOutput {
             /* ServerBuilderGenerator.kt:542 */}
             /* ServerBuilderGenerator.kt:283 */
-355
+        }
         /* ServerBuilderGenerator.kt:215 */
-357
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-360
+}
 /// See [`MalformedRangeOverrideOutput`](crate::output::MalformedRangeOverrideOutput).
 /// /* ServerBuilderGenerator.kt:171 */See [`MalformedRangeOverrideOutput`](crate::output::MalformedRangeOverrideOutput).
 pub mod malformed_range_override_output {
-363
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::output::MalformedRangeOverrideOutput {
         fn from(builder: Builder) -> Self {
             builder.build()
-368
+        }
-369
+    }
     /// A builder for [`MalformedRangeOverrideOutput`](crate::output::MalformedRangeOverrideOutput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`MalformedRangeOverrideOutput`](crate::output::MalformedRangeOverrideOutput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {}
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {/* ServerBuilderGenerator.kt:211 */}
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// Consumes the builder and constructs a [`MalformedRangeOverrideOutput`](crate::output::MalformedRangeOverrideOutput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`MalformedRangeOverrideOutput`](crate::output::MalformedRangeOverrideOutput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::output::MalformedRangeOverrideOutput {
             self.build_enforcing_all_constraints()
-381
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(self) -> crate::output::MalformedRangeOverrideOutput {
             crate::output::MalformedRangeOverrideOutput {}
             /* ServerBuilderGenerator.kt:542 */
             crate::output::MalformedRangeOverrideOutput {
             /* ServerBuilderGenerator.kt:542 */}
             /* ServerBuilderGenerator.kt:283 */
-388
+        }
         /* ServerBuilderGenerator.kt:215 */
-390
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-393
+}
 /// See [`MalformedRangeOutput`](crate::output::MalformedRangeOutput).
 /// /* ServerBuilderGenerator.kt:171 */See [`MalformedRangeOutput`](crate::output::MalformedRangeOutput).
 pub mod malformed_range_output {
-396
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::output::MalformedRangeOutput {
         fn from(builder: Builder) -> Self {
             builder.build()
-401
+        }
-402
+    }
     /// A builder for [`MalformedRangeOutput`](crate::output::MalformedRangeOutput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`MalformedRangeOutput`](crate::output::MalformedRangeOutput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {}
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {/* ServerBuilderGenerator.kt:211 */}
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// Consumes the builder and constructs a [`MalformedRangeOutput`](crate::output::MalformedRangeOutput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`MalformedRangeOutput`](crate::output::MalformedRangeOutput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::output::MalformedRangeOutput {
             self.build_enforcing_all_constraints()
-414
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(self) -> crate::output::MalformedRangeOutput {
             crate::output::MalformedRangeOutput {}
             /* ServerBuilderGenerator.kt:542 */
             crate::output::MalformedRangeOutput {
             /* ServerBuilderGenerator.kt:542 */}
             /* ServerBuilderGenerator.kt:283 */
-421
+        }
         /* ServerBuilderGenerator.kt:215 */
-423
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-426
+}
 /// See [`MalformedPatternOverrideOutput`](crate::output::MalformedPatternOverrideOutput).
 /// /* ServerBuilderGenerator.kt:171 */See [`MalformedPatternOverrideOutput`](crate::output::MalformedPatternOverrideOutput).
 pub mod malformed_pattern_override_output {
-429
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::output::MalformedPatternOverrideOutput {
         fn from(builder: Builder) -> Self {
             builder.build()
-434
+        }
-435
+    }
     /// A builder for [`MalformedPatternOverrideOutput`](crate::output::MalformedPatternOverrideOutput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`MalformedPatternOverrideOutput`](crate::output::MalformedPatternOverrideOutput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {}
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {/* ServerBuilderGenerator.kt:211 */}
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// Consumes the builder and constructs a [`MalformedPatternOverrideOutput`](crate::output::MalformedPatternOverrideOutput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`MalformedPatternOverrideOutput`](crate::output::MalformedPatternOverrideOutput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::output::MalformedPatternOverrideOutput {
             self.build_enforcing_all_constraints()
-447
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(self) -> crate::output::MalformedPatternOverrideOutput {
             crate::output::MalformedPatternOverrideOutput {}
             /* ServerBuilderGenerator.kt:542 */
             crate::output::MalformedPatternOverrideOutput {
             /* ServerBuilderGenerator.kt:542 */}
             /* ServerBuilderGenerator.kt:283 */
-454
+        }
         /* ServerBuilderGenerator.kt:215 */
-456
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-459
+}
 /// See [`MalformedPatternOutput`](crate::output::MalformedPatternOutput).
 /// /* ServerBuilderGenerator.kt:171 */See [`MalformedPatternOutput`](crate::output::MalformedPatternOutput).
 pub mod malformed_pattern_output {
-462
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::output::MalformedPatternOutput {
         fn from(builder: Builder) -> Self {
             builder.build()
-467
+        }
-468
+    }
     /// A builder for [`MalformedPatternOutput`](crate::output::MalformedPatternOutput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`MalformedPatternOutput`](crate::output::MalformedPatternOutput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {}
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {/* ServerBuilderGenerator.kt:211 */}
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// Consumes the builder and constructs a [`MalformedPatternOutput`](crate::output::MalformedPatternOutput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`MalformedPatternOutput`](crate::output::MalformedPatternOutput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::output::MalformedPatternOutput {
             self.build_enforcing_all_constraints()
-480
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(self) -> crate::output::MalformedPatternOutput {
             crate::output::MalformedPatternOutput {}
             /* ServerBuilderGenerator.kt:542 */
             crate::output::MalformedPatternOutput {
             /* ServerBuilderGenerator.kt:542 */}
             /* ServerBuilderGenerator.kt:283 */
-487
+        }
         /* ServerBuilderGenerator.kt:215 */
-489
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-492
+}
 /// See [`MalformedLengthQueryStringOutput`](crate::output::MalformedLengthQueryStringOutput).
 /// /* ServerBuilderGenerator.kt:171 */See [`MalformedLengthQueryStringOutput`](crate::output::MalformedLengthQueryStringOutput).
 pub mod malformed_length_query_string_output {
-495
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::output::MalformedLengthQueryStringOutput {
         fn from(builder: Builder) -> Self {
             builder.build()
-500
+        }
-501
+    }
     /// A builder for [`MalformedLengthQueryStringOutput`](crate::output::MalformedLengthQueryStringOutput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`MalformedLengthQueryStringOutput`](crate::output::MalformedLengthQueryStringOutput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {}
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {/* ServerBuilderGenerator.kt:211 */}
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// Consumes the builder and constructs a [`MalformedLengthQueryStringOutput`](crate::output::MalformedLengthQueryStringOutput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`MalformedLengthQueryStringOutput`](crate::output::MalformedLengthQueryStringOutput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::output::MalformedLengthQueryStringOutput {
             self.build_enforcing_all_constraints()
-513
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(
             self,
         ) -> crate::output::MalformedLengthQueryStringOutput {
             crate::output::MalformedLengthQueryStringOutput {}
             /* ServerBuilderGenerator.kt:542 */
             crate::output::MalformedLengthQueryStringOutput {
             /* ServerBuilderGenerator.kt:542 */}
             /* ServerBuilderGenerator.kt:283 */
-522
+        }
         /* ServerBuilderGenerator.kt:215 */
-524
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-527
+}
 /// See [`MalformedLengthOverrideOutput`](crate::output::MalformedLengthOverrideOutput).
 /// /* ServerBuilderGenerator.kt:171 */See [`MalformedLengthOverrideOutput`](crate::output::MalformedLengthOverrideOutput).
 pub mod malformed_length_override_output {
-530
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::output::MalformedLengthOverrideOutput {
         fn from(builder: Builder) -> Self {
             builder.build()
-535
+        }
-536
+    }
     /// A builder for [`MalformedLengthOverrideOutput`](crate::output::MalformedLengthOverrideOutput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`MalformedLengthOverrideOutput`](crate::output::MalformedLengthOverrideOutput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {}
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {/* ServerBuilderGenerator.kt:211 */}
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// Consumes the builder and constructs a [`MalformedLengthOverrideOutput`](crate::output::MalformedLengthOverrideOutput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`MalformedLengthOverrideOutput`](crate::output::MalformedLengthOverrideOutput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::output::MalformedLengthOverrideOutput {
             self.build_enforcing_all_constraints()
-548
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(self) -> crate::output::MalformedLengthOverrideOutput {
             crate::output::MalformedLengthOverrideOutput {}
             /* ServerBuilderGenerator.kt:542 */
             crate::output::MalformedLengthOverrideOutput {
             /* ServerBuilderGenerator.kt:542 */}
             /* ServerBuilderGenerator.kt:283 */
-555
+        }
         /* ServerBuilderGenerator.kt:215 */
-557
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-560
+}
 /// See [`MalformedLengthOutput`](crate::output::MalformedLengthOutput).
 /// /* ServerBuilderGenerator.kt:171 */See [`MalformedLengthOutput`](crate::output::MalformedLengthOutput).
 pub mod malformed_length_output {
-563
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::output::MalformedLengthOutput {
         fn from(builder: Builder) -> Self {
             builder.build()
-568
+        }
-569
+    }
     /// A builder for [`MalformedLengthOutput`](crate::output::MalformedLengthOutput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`MalformedLengthOutput`](crate::output::MalformedLengthOutput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {}
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {/* ServerBuilderGenerator.kt:211 */}
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// Consumes the builder and constructs a [`MalformedLengthOutput`](crate::output::MalformedLengthOutput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`MalformedLengthOutput`](crate::output::MalformedLengthOutput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::output::MalformedLengthOutput {
             self.build_enforcing_all_constraints()
-581
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(self) -> crate::output::MalformedLengthOutput {
             crate::output::MalformedLengthOutput {}
             /* ServerBuilderGenerator.kt:542 */
             crate::output::MalformedLengthOutput {
             /* ServerBuilderGenerator.kt:542 */}
             /* ServerBuilderGenerator.kt:283 */
-588
+        }
         /* ServerBuilderGenerator.kt:215 */
-590
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-593
+}
 /// See [`MalformedEnumOutput`](crate::output::MalformedEnumOutput).
 /// /* ServerBuilderGenerator.kt:171 */See [`MalformedEnumOutput`](crate::output::MalformedEnumOutput).
 pub mod malformed_enum_output {
-596
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::output::MalformedEnumOutput {
         fn from(builder: Builder) -> Self {
             builder.build()
-601
+        }
-602
+    }
     /// A builder for [`MalformedEnumOutput`](crate::output::MalformedEnumOutput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`MalformedEnumOutput`](crate::output::MalformedEnumOutput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {}
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {/* ServerBuilderGenerator.kt:211 */}
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// Consumes the builder and constructs a [`MalformedEnumOutput`](crate::output::MalformedEnumOutput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`MalformedEnumOutput`](crate::output::MalformedEnumOutput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::output::MalformedEnumOutput {
             self.build_enforcing_all_constraints()
-614
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(self) -> crate::output::MalformedEnumOutput {
             crate::output::MalformedEnumOutput {}
             /* ServerBuilderGenerator.kt:542 */
             crate::output::MalformedEnumOutput {
             /* ServerBuilderGenerator.kt:542 */}
             /* ServerBuilderGenerator.kt:283 */
-621
+        }
         /* ServerBuilderGenerator.kt:215 */
-623
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-626
+}

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

@@ -1,1 +55,56 @@

↥ Expand context

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub(crate) mod shape_malformed_enum;
-3
 pub(crate) mod shape_malformed_length;
-5
 pub(crate) mod shape_malformed_length_override;
-7
 pub(crate) mod shape_malformed_length_query_string;
-9
 pub(crate) mod shape_malformed_pattern;
-11
 pub(crate) mod shape_malformed_pattern_override;
-13
 pub(crate) mod shape_malformed_range;
-15

 pub(crate) mod shape_malformed_range_override;
-17
 pub(crate) mod shape_malformed_required;
-19
 pub(crate) mod shape_malformed_unique_items;
-21
 pub(crate) mod shape_recursive_structures;
-23
 pub(crate) mod shape_sensitive_validation;
-25
 /* JsonParserGenerator.kt:227 */
 pub(crate) fn or_empty_doc(data: &[u8]) -> &[u8] {
     if data.is_empty() {
         b"{}"
     } else {
         data
-32
+    }
-33
+}
-34
 pub(crate) mod shape_malformed_length_query_string_input;
-36

↧ Expand context

 pub(crate) mod shape_malformed_required_input;
-38
 pub(crate) mod shape_validation_exception;
-40
 pub(crate) mod shape_blob_set;
-42
 pub(crate) mod shape_boolean_set;
-44
 pub(crate) mod shape_byte_set;
-46
 pub(crate) mod shape_date_time_set;
-48
 pub(crate) mod shape_enum_list;
-50
 pub(crate) mod shape_enum_map;
-52
 pub(crate) mod shape_enum_union;
-54
 pub(crate) mod shape_foo_enum_set;
-56

tmp-codegen-diff/codegen-server-test/rest_json_validation/rust-server-codegen/src/protocol_serde/shape_blob_set.rs

@@ -1,1 +52,76 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonParserGenerator.kt:398 */
 pub(crate) fn de_blob_set<'a, I>(
     tokens: &mut ::std::iter::Peekable<I>,
 ) -> ::std::result::Result<
     Option<crate::unconstrained::blob_set_unconstrained::BlobSetUnconstrained>,
     ::aws_smithy_json::deserialize::error::DeserializeError,
-8
+>
 where
     I: Iterator<
         Item = Result<
             ::aws_smithy_json::deserialize::Token<'a>,
             ::aws_smithy_json::deserialize::error::DeserializeError,
         >,
     >,
-16
+{
     /* JsonParserGenerator.kt:712 */
     match tokens.next().transpose()? {
         /* JsonParserGenerator.kt:713 */
         Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
         Some(::aws_smithy_json::deserialize::Token::StartArray { .. }) => {
             /* JsonParserGenerator.kt:407 */
             let mut items = Vec::new();
             /* JsonParserGenerator.kt:408 */
             loop {
                 /* JsonParserGenerator.kt:409 */
                 match tokens.peek() {
                     /* JsonParserGenerator.kt:410 */
                     Some(Ok(::aws_smithy_json::deserialize::Token::EndArray { .. })) => {
                         /* JsonParserGenerator.kt:411 */
                         tokens.next().transpose().unwrap();
                         break;
                         /* JsonParserGenerator.kt:410 */
-34
+                    }
                     /* JsonParserGenerator.kt:413 */
                     _ => {
                         let value = ::aws_smithy_json::deserialize::token::expect_blob_or_null(
                             tokens.next(),
                         )?;
                         /* JsonParserGenerator.kt:419 */
                         let value =
                             /* JsonParserGenerator.kt:326 */::aws_smithy_json::deserialize::token::expect_blob_or_null(tokens.next())?
                         /* JsonParserGenerator.kt:419 */;
                         /* JsonParserGenerator.kt:422 */
                         if let Some(value) = value {
                             items.push(value);
                         } else {
-+
+                        }
                         /* JsonParserGenerator.kt:430 */
                         else {
                             return Err(
                                 ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                                     "dense list cannot contain null values",
                                 ),
                             );
-52
+                        }
                         /* JsonParserGenerator.kt:413 */
                     } /* JsonParserGenerator.kt:409 */
-55
+                }
                 /* JsonParserGenerator.kt:408 */
-57
+            }
--
+            }
             /* JsonParserGenerator.kt:444 */
             Ok(Some(
                 crate::unconstrained::blob_set_unconstrained::BlobSetUnconstrained(items),
             ))
             /* JsonParserGenerator.kt:713 */
-63
+        }
         _ => Err(
         /* JsonParserGenerator.kt:722 */
         _ => {
             /* JsonParserGenerator.kt:723 */
             Err(
                 ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                     "expected start array or null",
                 ),
         ),
-+
+            )
             /* JsonParserGenerator.kt:722 */
         } /* JsonParserGenerator.kt:712 */
-74
+    }
     /* JsonParserGenerator.kt:398 */
-76
+}

tmp-codegen-diff/codegen-server-test/rest_json_validation/rust-server-codegen/src/protocol_serde/shape_boolean_set.rs

@@ -1,1 +52,76 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonParserGenerator.kt:398 */
 pub(crate) fn de_boolean_set<'a, I>(
     tokens: &mut ::std::iter::Peekable<I>,
 ) -> ::std::result::Result<
     Option<crate::unconstrained::boolean_set_unconstrained::BooleanSetUnconstrained>,
     ::aws_smithy_json::deserialize::error::DeserializeError,
-8
+>
 where
     I: Iterator<
         Item = Result<
             ::aws_smithy_json::deserialize::Token<'a>,
             ::aws_smithy_json::deserialize::error::DeserializeError,
         >,
     >,
-16
+{
     /* JsonParserGenerator.kt:712 */
     match tokens.next().transpose()? {
         /* JsonParserGenerator.kt:713 */
         Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
         Some(::aws_smithy_json::deserialize::Token::StartArray { .. }) => {
             /* JsonParserGenerator.kt:407 */
             let mut items = Vec::new();
             /* JsonParserGenerator.kt:408 */
             loop {
                 /* JsonParserGenerator.kt:409 */
                 match tokens.peek() {
                     /* JsonParserGenerator.kt:410 */
                     Some(Ok(::aws_smithy_json::deserialize::Token::EndArray { .. })) => {
                         /* JsonParserGenerator.kt:411 */
                         tokens.next().transpose().unwrap();
                         break;
                         /* JsonParserGenerator.kt:410 */
-34
+                    }
                     /* JsonParserGenerator.kt:413 */
                     _ => {
                         let value = ::aws_smithy_json::deserialize::token::expect_bool_or_null(
                             tokens.next(),
                         )?;
                         /* JsonParserGenerator.kt:419 */
                         let value =
                             /* JsonParserGenerator.kt:298 */::aws_smithy_json::deserialize::token::expect_bool_or_null(tokens.next())?
                         /* JsonParserGenerator.kt:419 */;
                         /* JsonParserGenerator.kt:422 */
                         if let Some(value) = value {
                             items.push(value);
                         } else {
-+
+                        }
                         /* JsonParserGenerator.kt:430 */
                         else {
                             return Err(
                                 ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                                     "dense list cannot contain null values",
                                 ),
                             );
-52
+                        }
                         /* JsonParserGenerator.kt:413 */
                     } /* JsonParserGenerator.kt:409 */
-55
+                }
                 /* JsonParserGenerator.kt:408 */
-57
+            }
--
+            }
             /* JsonParserGenerator.kt:444 */
             Ok(Some(
                 crate::unconstrained::boolean_set_unconstrained::BooleanSetUnconstrained(items),
             ))
             /* JsonParserGenerator.kt:713 */
-63
+        }
         _ => Err(
         /* JsonParserGenerator.kt:722 */
         _ => {
             /* JsonParserGenerator.kt:723 */
             Err(
                 ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                     "expected start array or null",
                 ),
         ),
-+
+            )
             /* JsonParserGenerator.kt:722 */
         } /* JsonParserGenerator.kt:712 */
-74
+    }
     /* JsonParserGenerator.kt:398 */
-76
+}

tmp-codegen-diff/codegen-server-test/rest_json_validation/rust-server-codegen/src/protocol_serde/shape_byte_set.rs

@@ -1,1 +54,78 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonParserGenerator.kt:398 */
 pub(crate) fn de_byte_set<'a, I>(
     tokens: &mut ::std::iter::Peekable<I>,
 ) -> ::std::result::Result<
     Option<crate::unconstrained::byte_set_unconstrained::ByteSetUnconstrained>,
     ::aws_smithy_json::deserialize::error::DeserializeError,
-8
+>
 where
     I: Iterator<
         Item = Result<
             ::aws_smithy_json::deserialize::Token<'a>,
             ::aws_smithy_json::deserialize::error::DeserializeError,
         >,
     >,
-16
+{
     /* JsonParserGenerator.kt:712 */
     match tokens.next().transpose()? {
         /* JsonParserGenerator.kt:713 */
         Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
         Some(::aws_smithy_json::deserialize::Token::StartArray { .. }) => {
             /* JsonParserGenerator.kt:407 */
             let mut items = Vec::new();
             /* JsonParserGenerator.kt:408 */
             loop {
                 /* JsonParserGenerator.kt:409 */
                 match tokens.peek() {
                     /* JsonParserGenerator.kt:410 */
                     Some(Ok(::aws_smithy_json::deserialize::Token::EndArray { .. })) => {
                         /* JsonParserGenerator.kt:411 */
                         tokens.next().transpose().unwrap();
                         break;
                         /* JsonParserGenerator.kt:410 */
-34
+                    }
                     /* JsonParserGenerator.kt:413 */
                     _ => {
                         let value = ::aws_smithy_json::deserialize::token::expect_number_or_null(
                             tokens.next(),
                         )?
                         /* JsonParserGenerator.kt:419 */
                         let value =
                             /* JsonParserGenerator.kt:365 */::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
                                                 .map(i8::try_from)
                         .transpose()?;
                                                 .transpose()?
                         /* JsonParserGenerator.kt:419 */;
                         /* JsonParserGenerator.kt:422 */
                         if let Some(value) = value {
                             items.push(value);
                         } else {
-+
+                        }
                         /* JsonParserGenerator.kt:430 */
                         else {
                             return Err(
                                 ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                                     "dense list cannot contain null values",
                                 ),
                             );
-54
+                        }
                         /* JsonParserGenerator.kt:413 */
                     } /* JsonParserGenerator.kt:409 */
-57
+                }
                 /* JsonParserGenerator.kt:408 */
-59
+            }
--
+            }
             /* JsonParserGenerator.kt:444 */
             Ok(Some(
                 crate::unconstrained::byte_set_unconstrained::ByteSetUnconstrained(items),
             ))
             /* JsonParserGenerator.kt:713 */
-65
+        }
         _ => Err(
         /* JsonParserGenerator.kt:722 */
         _ => {
             /* JsonParserGenerator.kt:723 */
             Err(
                 ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                     "expected start array or null",
                 ),
         ),
-+
+            )
             /* JsonParserGenerator.kt:722 */
         } /* JsonParserGenerator.kt:712 */
-76
+    }
     /* JsonParserGenerator.kt:398 */
-78
+}

tmp-codegen-diff/codegen-server-test/rest_json_validation/rust-server-codegen/src/protocol_serde/shape_date_time_set.rs

@@ -1,1 +54,76 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonParserGenerator.kt:398 */
 pub(crate) fn de_date_time_set<'a, I>(
     tokens: &mut ::std::iter::Peekable<I>,
 ) -> ::std::result::Result<
     Option<crate::unconstrained::date_time_set_unconstrained::DateTimeSetUnconstrained>,
     ::aws_smithy_json::deserialize::error::DeserializeError,
-8
+>
 where
     I: Iterator<
         Item = Result<
             ::aws_smithy_json::deserialize::Token<'a>,
             ::aws_smithy_json::deserialize::error::DeserializeError,
         >,
     >,
-16
+{
     /* JsonParserGenerator.kt:712 */
     match tokens.next().transpose()? {
         /* JsonParserGenerator.kt:713 */
         Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
         Some(::aws_smithy_json::deserialize::Token::StartArray { .. }) => {
             /* JsonParserGenerator.kt:407 */
             let mut items = Vec::new();
             /* JsonParserGenerator.kt:408 */
             loop {
                 /* JsonParserGenerator.kt:409 */
                 match tokens.peek() {
                     /* JsonParserGenerator.kt:410 */
                     Some(Ok(::aws_smithy_json::deserialize::Token::EndArray { .. })) => {
                         /* JsonParserGenerator.kt:411 */
                         tokens.next().transpose().unwrap();
                         break;
                         /* JsonParserGenerator.kt:410 */
-34
+                    }
                     /* JsonParserGenerator.kt:413 */
                     _ => {
                         /* JsonParserGenerator.kt:419 */
                         let value =
                             ::aws_smithy_json::deserialize::token::expect_timestamp_or_null(
                                 tokens.next(),
                                 ::aws_smithy_types::date_time::Format::DateTime,
                             )?;
                             /* JsonParserGenerator.kt:384 */::aws_smithy_json::deserialize::token::expect_timestamp_or_null(tokens.next(), ::aws_smithy_types::date_time::Format::DateTime)?
                         /* JsonParserGenerator.kt:419 */;
                         /* JsonParserGenerator.kt:422 */
                         if let Some(value) = value {
                             items.push(value);
                         } else {
-+
+                        }
                         /* JsonParserGenerator.kt:430 */
                         else {
                             return Err(
                                 ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                                     "dense list cannot contain null values",
                                 ),
                             );
-52
+                        }
                         /* JsonParserGenerator.kt:413 */
                     } /* JsonParserGenerator.kt:409 */
-55
+                }
                 /* JsonParserGenerator.kt:408 */
-57
+            }
--
+            }
             /* JsonParserGenerator.kt:444 */
             Ok(Some(
                 crate::unconstrained::date_time_set_unconstrained::DateTimeSetUnconstrained(items),
             ))
             /* JsonParserGenerator.kt:713 */
-63
+        }
         _ => Err(
         /* JsonParserGenerator.kt:722 */
         _ => {
             /* JsonParserGenerator.kt:723 */
             Err(
                 ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                     "expected start array or null",
                 ),
         ),
-+
+            )
             /* JsonParserGenerator.kt:722 */
         } /* JsonParserGenerator.kt:712 */
-74
+    }
     /* JsonParserGenerator.kt:398 */
-76
+}

tmp-codegen-diff/codegen-server-test/rest_json_validation/rust-server-codegen/src/protocol_serde/shape_enum_list.rs

@@ -1,1 +54,80 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonParserGenerator.kt:398 */
 pub(crate) fn de_enum_list<'a, I>(
     tokens: &mut ::std::iter::Peekable<I>,
 ) -> ::std::result::Result<
     Option<crate::unconstrained::enum_list_unconstrained::EnumListUnconstrained>,
     ::aws_smithy_json::deserialize::error::DeserializeError,
-8
+>
 where
     I: Iterator<
         Item = Result<
             ::aws_smithy_json::deserialize::Token<'a>,
             ::aws_smithy_json::deserialize::error::DeserializeError,
         >,
     >,
-16
+{
     /* JsonParserGenerator.kt:712 */
     match tokens.next().transpose()? {
         /* JsonParserGenerator.kt:713 */
         Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
         Some(::aws_smithy_json::deserialize::Token::StartArray { .. }) => {
             /* JsonParserGenerator.kt:407 */
             let mut items = Vec::new();
             /* JsonParserGenerator.kt:408 */
             loop {
                 /* JsonParserGenerator.kt:409 */
                 match tokens.peek() {
                     /* JsonParserGenerator.kt:410 */
                     Some(Ok(::aws_smithy_json::deserialize::Token::EndArray { .. })) => {
                         /* JsonParserGenerator.kt:411 */
                         tokens.next().transpose().unwrap();
                         break;
                         /* JsonParserGenerator.kt:410 */
-34
+                    }
                     /* JsonParserGenerator.kt:413 */
                     _ => {
                         let value = ::aws_smithy_json::deserialize::token::expect_string_or_null(
                             tokens.next(),
                         )?
                         .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                         .transpose()?;
                         /* JsonParserGenerator.kt:419 */
                         let value =
                             /* JsonParserGenerator.kt:354 */::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?.map(|s|
                                 /* JsonParserGenerator.kt:339 */s.to_unescaped().map(|u|
                                     /* JsonParserGenerator.kt:343 */u.into_owned()
                                 /* JsonParserGenerator.kt:339 */)
                             /* JsonParserGenerator.kt:354 */).transpose()?
                         /* JsonParserGenerator.kt:419 */;
                         /* JsonParserGenerator.kt:422 */
                         if let Some(value) = value {
                             items.push(value);
                         } else {
-+
+                        }
                         /* JsonParserGenerator.kt:430 */
                         else {
                             return Err(
                                 ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                                     "dense list cannot contain null values",
                                 ),
                             );
-56
+                        }
                         /* JsonParserGenerator.kt:413 */
                     } /* JsonParserGenerator.kt:409 */
-59
+                }
                 /* JsonParserGenerator.kt:408 */
-61
+            }
--
+            }
             /* JsonParserGenerator.kt:444 */
             Ok(Some(
                 crate::unconstrained::enum_list_unconstrained::EnumListUnconstrained(items),
             ))
             /* JsonParserGenerator.kt:713 */
-67
+        }
         _ => Err(
         /* JsonParserGenerator.kt:722 */
         _ => {
             /* JsonParserGenerator.kt:723 */
             Err(
                 ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                     "expected start array or null",
                 ),
         ),
-+
+            )
             /* JsonParserGenerator.kt:722 */
         } /* JsonParserGenerator.kt:712 */
-78
+    }
     /* JsonParserGenerator.kt:398 */
-80
+}

tmp-codegen-diff/codegen-server-test/rest_json_validation/rust-server-codegen/src/protocol_serde/shape_enum_map.rs

@@ -1,1 +62,89 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonParserGenerator.kt:460 */
 pub(crate) fn de_enum_map<'a, I>(
     tokens: &mut ::std::iter::Peekable<I>,
 ) -> ::std::result::Result<
     Option<crate::unconstrained::enum_map_unconstrained::EnumMapUnconstrained>,
     ::aws_smithy_json::deserialize::error::DeserializeError,
-8
+>
 where
     I: Iterator<
         Item = Result<
             ::aws_smithy_json::deserialize::Token<'a>,
             ::aws_smithy_json::deserialize::error::DeserializeError,
         >,
     >,
-16
+{
     /* JsonParserGenerator.kt:712 */
     match tokens.next().transpose()? {
         /* JsonParserGenerator.kt:713 */
         Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
         Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
             /* JsonParserGenerator.kt:469 */
             let mut map = ::std::collections::HashMap::new();
             /* JsonParserGenerator.kt:684 */
             loop {
                 /* JsonParserGenerator.kt:685 */
                 match tokens.next().transpose()? {
                     /* JsonParserGenerator.kt:686 */
                     Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
                     Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
                         let key = key.to_unescaped().map(|u| u.into_owned())?;
                         let value = ::aws_smithy_json::deserialize::token::expect_string_or_null(
                             tokens.next(),
                         )?
                         .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                         .transpose()?;
                         /* JsonParserGenerator.kt:471 */
                         let key =
                             /* JsonParserGenerator.kt:339 */key.to_unescaped().map(|u|
                                 /* JsonParserGenerator.kt:343 */u.into_owned()
                             /* JsonParserGenerator.kt:339 */)
                         /* JsonParserGenerator.kt:471 */?;
                         /* JsonParserGenerator.kt:474 */
                         let value =
                             /* JsonParserGenerator.kt:354 */::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?.map(|s|
                                 /* JsonParserGenerator.kt:339 */s.to_unescaped().map(|u|
                                     /* JsonParserGenerator.kt:343 */u.into_owned()
                                 /* JsonParserGenerator.kt:339 */)
                             /* JsonParserGenerator.kt:354 */).transpose()?
                         /* JsonParserGenerator.kt:474 */;
                         /* JsonParserGenerator.kt:481 */
                         match value {
                             Some(value) => {
                                 map.insert(key, value);
-49
+                            }
                             None => {
                                 return Err(
                                     ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                                         "dense map cannot contain null values",
                                     ),
-55
+                                )
-56
+                            }
-57
+                        }
                         /* JsonParserGenerator.kt:686 */
-59
+                    }
                     /* JsonParserGenerator.kt:695 */
                     other => {
                         return Err(
                             ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                                 format!("expected object key or end object, found: {:?}", other),
                             ),
-66
+                        )
                     } /* JsonParserGenerator.kt:685 */
-68
+                }
                 /* JsonParserGenerator.kt:684 */
-70
+            }
--
+            }
             /* JsonParserGenerator.kt:502 */
             Ok(Some(
                 crate::unconstrained::enum_map_unconstrained::EnumMapUnconstrained(map),
             ))
             /* JsonParserGenerator.kt:713 */
-76
+        }
         _ => Err(
         /* JsonParserGenerator.kt:722 */
         _ => {
             /* JsonParserGenerator.kt:723 */
             Err(
                 ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                     "expected start object or null",
                 ),
         ),
-+
+            )
             /* JsonParserGenerator.kt:722 */
         } /* JsonParserGenerator.kt:712 */
-87
+    }
     /* JsonParserGenerator.kt:460 */
-89
+}

tmp-codegen-diff/codegen-server-test/rest_json_validation/rust-server-codegen/src/protocol_serde/shape_enum_union.rs

@@ -1,1 +92,124 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonParserGenerator.kt:551 */
 pub(crate) fn de_enum_union<'a, I>(
     tokens: &mut ::std::iter::Peekable<I>,
 ) -> ::std::result::Result<
     Option<crate::unconstrained::enum_union_unconstrained::EnumUnionUnconstrained>,
     ::aws_smithy_json::deserialize::error::DeserializeError,
-8
+>
 where
     I: Iterator<
         Item = Result<
             ::aws_smithy_json::deserialize::Token<'a>,
             ::aws_smithy_json::deserialize::error::DeserializeError,
         >,
     >,
-16
+{
     /* JsonParserGenerator.kt:565 */
     let mut variant = None;
     /* JsonParserGenerator.kt:567 */
     match tokens.next().transpose()? {
         /* JsonParserGenerator.kt:568 */
         Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => return Ok(None),
         Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => loop {
         Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
             /* JsonParserGenerator.kt:684 */
             loop {
                 /* JsonParserGenerator.kt:685 */
                 match tokens.next().transpose()? {
                     /* JsonParserGenerator.kt:686 */
                     Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
                     Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
                         /* JsonParserGenerator.kt:576 */
                         if let ::std::option::Option::Some(::std::result::Result::Ok(
                             ::aws_smithy_json::deserialize::Token::ValueNull { .. },
                         )) = tokens.peek()
-35
+                        {
                             let _ = tokens.next().expect("peek returned a token")?;
                             continue;
-38
+                        }
                         /* JsonParserGenerator.kt:585 */
                         let key = key.to_unescaped()?;
                         if key == "__type" {
                             ::aws_smithy_json::deserialize::token::skip_value(tokens)?;
                             continue;
-44
+                        }
                         if variant.is_some() {
                             return Err(
                                 ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                                     "encountered mixed variants in union",
                                 ),
                             );
-51
+                        }
                         /* JsonParserGenerator.kt:598 */
                         variant = match key.as_ref() {
                             /* JsonParserGenerator.kt:601 */
                             "first" => {
                                 /* JsonParserGenerator.kt:611 */
                                 Some(crate::unconstrained::enum_union_unconstrained::EnumUnionUnconstrained::First(
                                     ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?.map(|s|
                                         s.to_unescaped().map(|u|
                                             u.into_owned()
--
+                                        )
                                     ).transpose()?
                                     .ok_or_else(|| ::aws_smithy_json::deserialize::error::DeserializeError::custom("value for 'first' cannot be null"))?
                                 ))
                                     /* JsonParserGenerator.kt:354 */::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?.map(|s|
                                         /* JsonParserGenerator.kt:339 */s.to_unescaped().map(|u|
                                             /* JsonParserGenerator.kt:343 */u.into_owned()
                                         /* JsonParserGenerator.kt:339 */)
                                     /* JsonParserGenerator.kt:354 */).transpose()?
                                     /* JsonParserGenerator.kt:670 */.ok_or_else(|| ::aws_smithy_json::deserialize::error::DeserializeError::custom("value for 'first' cannot be null"))?
                                 /* JsonParserGenerator.kt:611 */))
                                 /* JsonParserGenerator.kt:601 */
-66
+                            }
                             /* JsonParserGenerator.kt:601 */
                             "second" => {
                                 /* JsonParserGenerator.kt:611 */
                                 Some(crate::unconstrained::enum_union_unconstrained::EnumUnionUnconstrained::Second(
                                     ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?.map(|s|
                                         s.to_unescaped().map(|u|
                                             u.into_owned()
--
+                                        )
                                     ).transpose()?
                                     .ok_or_else(|| ::aws_smithy_json::deserialize::error::DeserializeError::custom("value for 'second' cannot be null"))?
                                 ))
                                     /* JsonParserGenerator.kt:354 */::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?.map(|s|
                                         /* JsonParserGenerator.kt:339 */s.to_unescaped().map(|u|
                                             /* JsonParserGenerator.kt:343 */u.into_owned()
                                         /* JsonParserGenerator.kt:339 */)
                                     /* JsonParserGenerator.kt:354 */).transpose()?
                                     /* JsonParserGenerator.kt:670 */.ok_or_else(|| ::aws_smithy_json::deserialize::error::DeserializeError::custom("value for 'second' cannot be null"))?
                                 /* JsonParserGenerator.kt:611 */))
                                 /* JsonParserGenerator.kt:601 */
-79
+                            }
                             variant => return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!("unexpected union variant: {}", variant)))
                             /* JsonParserGenerator.kt:634 */
                             variant => {
                                 return Err(
                                     ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                                         format!("unexpected union variant: {}", variant),
                                     ),
-+
+                                )
                             } /* JsonParserGenerator.kt:598 */
                         };
                         /* JsonParserGenerator.kt:686 */
-90
+                    }
                     /* JsonParserGenerator.kt:695 */
                     other => {
                         return Err(
                         ::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
                             "expected object key or end object, found: {:?}",
                             other
                         )),
                             ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                                 format!("expected object key or end object, found: {:?}", other),
                             ),
-97
+                        )
                     } /* JsonParserGenerator.kt:685 */
-99
+                }
                 /* JsonParserGenerator.kt:684 */
-101
+            }
         },
             /* JsonParserGenerator.kt:568 */
-+
+        }
         /* JsonParserGenerator.kt:642 */
         _ => {
             return Err(
                 ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                     "expected start object or null",
                 ),
-110
+            )
         } /* JsonParserGenerator.kt:567 */
-112
+    }
--
+    }
     /* JsonParserGenerator.kt:649 */
     if variant.is_none() {
         return Err(
             ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                 "Union did not contain a valid variant.",
             ),
         );
-120
+    }
     /* JsonParserGenerator.kt:657 */
     Ok(variant)
     /* JsonParserGenerator.kt:551 */
-124
+}

tmp-codegen-diff/codegen-server-test/rest_json_validation/rust-server-codegen/src/protocol_serde/shape_foo_enum_set.rs

@@ -1,1 +54,80 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonParserGenerator.kt:398 */
 pub(crate) fn de_foo_enum_set<'a, I>(
     tokens: &mut ::std::iter::Peekable<I>,
 ) -> ::std::result::Result<
     Option<crate::unconstrained::foo_enum_set_unconstrained::FooEnumSetUnconstrained>,
     ::aws_smithy_json::deserialize::error::DeserializeError,
-8
+>
 where
     I: Iterator<
         Item = Result<
             ::aws_smithy_json::deserialize::Token<'a>,
             ::aws_smithy_json::deserialize::error::DeserializeError,
         >,
     >,
-16
+{
     /* JsonParserGenerator.kt:712 */
     match tokens.next().transpose()? {
         /* JsonParserGenerator.kt:713 */
         Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
         Some(::aws_smithy_json::deserialize::Token::StartArray { .. }) => {
             /* JsonParserGenerator.kt:407 */
             let mut items = Vec::new();
             /* JsonParserGenerator.kt:408 */
             loop {
                 /* JsonParserGenerator.kt:409 */
                 match tokens.peek() {
                     /* JsonParserGenerator.kt:410 */
                     Some(Ok(::aws_smithy_json::deserialize::Token::EndArray { .. })) => {
                         /* JsonParserGenerator.kt:411 */
                         tokens.next().transpose().unwrap();
                         break;
                         /* JsonParserGenerator.kt:410 */
-34
+                    }
                     /* JsonParserGenerator.kt:413 */
                     _ => {
                         let value = ::aws_smithy_json::deserialize::token::expect_string_or_null(
                             tokens.next(),
                         )?
                         .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                         .transpose()?;
                         /* JsonParserGenerator.kt:419 */
                         let value =
                             /* JsonParserGenerator.kt:354 */::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?.map(|s|
                                 /* JsonParserGenerator.kt:339 */s.to_unescaped().map(|u|
                                     /* JsonParserGenerator.kt:343 */u.into_owned()
                                 /* JsonParserGenerator.kt:339 */)
                             /* JsonParserGenerator.kt:354 */).transpose()?
                         /* JsonParserGenerator.kt:419 */;
                         /* JsonParserGenerator.kt:422 */
                         if let Some(value) = value {
                             items.push(value);
                         } else {
-+
+                        }
                         /* JsonParserGenerator.kt:430 */
                         else {
                             return Err(
                                 ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                                     "dense list cannot contain null values",
                                 ),
                             );
-56
+                        }
                         /* JsonParserGenerator.kt:413 */
                     } /* JsonParserGenerator.kt:409 */
-59
+                }
                 /* JsonParserGenerator.kt:408 */
-61
+            }
--
+            }
             /* JsonParserGenerator.kt:444 */
             Ok(Some(
                 crate::unconstrained::foo_enum_set_unconstrained::FooEnumSetUnconstrained(items),
             ))
             /* JsonParserGenerator.kt:713 */
-67
+        }
         _ => Err(
         /* JsonParserGenerator.kt:722 */
         _ => {
             /* JsonParserGenerator.kt:723 */
             Err(
                 ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                     "expected start array or null",
                 ),
         ),
-+
+            )
             /* JsonParserGenerator.kt:722 */
         } /* JsonParserGenerator.kt:712 */
-78
+    }
     /* JsonParserGenerator.kt:398 */
-80
+}

tmp-codegen-diff/codegen-server-test/rest_json_validation/rust-server-codegen/src/protocol_serde/shape_foo_union.rs

@@ -1,1 +102,122 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonParserGenerator.kt:551 */
 pub(crate) fn de_foo_union<'a, I>(
     tokens: &mut ::std::iter::Peekable<I>,
 ) -> ::std::result::Result<
     Option<crate::model::FooUnion>,
     ::aws_smithy_json::deserialize::error::DeserializeError,
-8
+>
 where
     I: Iterator<
         Item = Result<
             ::aws_smithy_json::deserialize::Token<'a>,
             ::aws_smithy_json::deserialize::error::DeserializeError,
         >,
     >,
-16
+{
     /* JsonParserGenerator.kt:565 */
     let mut variant = None;
     /* JsonParserGenerator.kt:567 */
     match tokens.next().transpose()? {
         /* JsonParserGenerator.kt:568 */
         Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => return Ok(None),
         Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => loop {
         Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
             /* JsonParserGenerator.kt:684 */
             loop {
                 /* JsonParserGenerator.kt:685 */
                 match tokens.next().transpose()? {
                     /* JsonParserGenerator.kt:686 */
                     Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
                     Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
                         /* JsonParserGenerator.kt:576 */
                         if let ::std::option::Option::Some(::std::result::Result::Ok(
                             ::aws_smithy_json::deserialize::Token::ValueNull { .. },
                         )) = tokens.peek()
-35
+                        {
                             let _ = tokens.next().expect("peek returned a token")?;
                             continue;
-38
+                        }
                         /* JsonParserGenerator.kt:585 */
                         let key = key.to_unescaped()?;
                         if key == "__type" {
                             ::aws_smithy_json::deserialize::token::skip_value(tokens)?;
                             continue;
-44
+                        }
                         if variant.is_some() {
                             return Err(
                                 ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                                     "encountered mixed variants in union",
                                 ),
                             );
-51
+                        }
                         /* JsonParserGenerator.kt:598 */
                         variant = match key.as_ref() {
                         "string" => Some(crate::model::FooUnion::String(
                             ::aws_smithy_json::deserialize::token::expect_string_or_null(
                                 tokens.next(),
                             )?
                             .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                             .transpose()?
                             .ok_or_else(|| {
                                 ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                                     "value for 'string' cannot be null",
--
+                                )
                             })?,
                         )),
                         "integer" => Some(crate::model::FooUnion::Integer(
                             ::aws_smithy_json::deserialize::token::expect_number_or_null(
                                 tokens.next(),
                             )?
                             /* JsonParserGenerator.kt:601 */
                             "string" => {
                                 /* JsonParserGenerator.kt:611 */
                                 Some(crate::model::FooUnion::String(
                                     /* JsonParserGenerator.kt:354 */::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?.map(|s|
                                         /* JsonParserGenerator.kt:339 */s.to_unescaped().map(|u|
                                             /* JsonParserGenerator.kt:348 */u.into_owned()
                                         /* JsonParserGenerator.kt:339 */)
                                     /* JsonParserGenerator.kt:354 */).transpose()?
                                     /* JsonParserGenerator.kt:670 */.ok_or_else(|| ::aws_smithy_json::deserialize::error::DeserializeError::custom("value for 'string' cannot be null"))?
                                 /* JsonParserGenerator.kt:611 */))
                                 /* JsonParserGenerator.kt:601 */
-+
+                            }
                             /* JsonParserGenerator.kt:601 */
                             "integer" => {
                                 /* JsonParserGenerator.kt:611 */
                                 Some(crate::model::FooUnion::Integer(
                                     /* JsonParserGenerator.kt:365 */::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
                                                         .map(i32::try_from)
                                                         .transpose()?
                             .ok_or_else(|| {
                                 ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                                     "value for 'integer' cannot be null",
--
+                                )
                             })?,
                         )),
                                     /* JsonParserGenerator.kt:670 */.ok_or_else(|| ::aws_smithy_json::deserialize::error::DeserializeError::custom("value for 'integer' cannot be null"))?
                                 /* JsonParserGenerator.kt:611 */))
                                 /* JsonParserGenerator.kt:601 */
-+
+                            }
                             /* JsonParserGenerator.kt:634 */
                             variant => {
                                 return Err(
                                     ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                                         format!("unexpected union variant: {}", variant),
                                     ),
-84
+                                )
--
+                        }
                             } /* JsonParserGenerator.kt:598 */
                         };
                         /* JsonParserGenerator.kt:686 */
-88
+                    }
                     /* JsonParserGenerator.kt:695 */
                     other => {
                         return Err(
                         ::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
                             "expected object key or end object, found: {:?}",
                             other
                         )),
                             ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                                 format!("expected object key or end object, found: {:?}", other),
                             ),
-95
+                        )
                     } /* JsonParserGenerator.kt:685 */
-+
+                }
                 /* JsonParserGenerator.kt:684 */
-99
+            }
             /* JsonParserGenerator.kt:568 */
-101
+        }
         },
         /* JsonParserGenerator.kt:642 */
         _ => {
             return Err(
                 ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                     "expected start object or null",
                 ),
-108
+            )
         } /* JsonParserGenerator.kt:567 */
-110
+    }
--
+    }
     /* JsonParserGenerator.kt:649 */
     if variant.is_none() {
         return Err(
             ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                 "Union did not contain a valid variant.",
             ),
         );
-118
+    }
     /* JsonParserGenerator.kt:657 */
     Ok(variant)
     /* JsonParserGenerator.kt:551 */
-122
+}

tmp-codegen-diff/codegen-server-test/rest_json_validation/rust-server-codegen/src/protocol_serde/shape_greeting_struct.rs

@@ -1,1 +55,79 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonParserGenerator.kt:516 */
 pub(crate) fn de_greeting_struct<'a, I>(
     tokens: &mut ::std::iter::Peekable<I>,
 ) -> ::std::result::Result<
     Option<crate::model::GreetingStruct>,
     ::aws_smithy_json::deserialize::error::DeserializeError,
-8
+>
 where
     I: Iterator<
         Item = Result<
             ::aws_smithy_json::deserialize::Token<'a>,
             ::aws_smithy_json::deserialize::error::DeserializeError,
         >,
     >,
-16
+{
     /* JsonParserGenerator.kt:712 */
     match tokens.next().transpose()? {
         /* JsonParserGenerator.kt:713 */
         Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
         Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
             /* RustType.kt:516 */
             #[allow(unused_mut)]
             /* JsonParserGenerator.kt:526 */
             let mut builder = crate::model::greeting_struct::Builder::default();
             /* JsonParserGenerator.kt:684 */
             loop {
                 /* JsonParserGenerator.kt:685 */
                 match tokens.next().transpose()? {
                     /* JsonParserGenerator.kt:686 */
                     Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
                     Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
                         /* JsonParserGenerator.kt:260 */
                         match key.to_unescaped()?.as_ref() {
                             /* JsonParserGenerator.kt:262 */
                             "hi" => {
                                 /* JsonParserGenerator.kt:272 */
                                 builder = builder.set_hi(
                                     ::aws_smithy_json::deserialize::token::expect_string_or_null(
                                         tokens.next(),
                                     )?
                                     .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                                     .transpose()?,
                                 );
                                     /* JsonParserGenerator.kt:354 */::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?.map(|s|
                                         /* JsonParserGenerator.kt:339 */s.to_unescaped().map(|u|
                                             /* JsonParserGenerator.kt:348 */u.into_owned()
                                         /* JsonParserGenerator.kt:339 */)
                                     /* JsonParserGenerator.kt:354 */).transpose()?
                                 /* JsonParserGenerator.kt:272 */);
                                 /* JsonParserGenerator.kt:262 */
-46
+                            }
                             _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
                             /* JsonParserGenerator.kt:290 */
                             _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?, /* JsonParserGenerator.kt:260 */
-49
+                        }
                         /* JsonParserGenerator.kt:686 */
-51
+                    }
                     /* JsonParserGenerator.kt:695 */
                     other => {
                         return Err(
                             ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                                 format!("expected object key or end object, found: {:?}", other),
                             ),
-58
+                        )
                     } /* JsonParserGenerator.kt:685 */
-60
+                }
                 /* JsonParserGenerator.kt:684 */
-62
+            }
--
+            }
             /* JsonParserGenerator.kt:540 */
             Ok(Some(builder.build()))
             /* JsonParserGenerator.kt:713 */
-66
+        }
         _ => Err(
         /* JsonParserGenerator.kt:722 */
         _ => {
             /* JsonParserGenerator.kt:723 */
             Err(
                 ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                     "expected start object or null",
                 ),
         ),
-+
+            )
             /* JsonParserGenerator.kt:722 */
         } /* JsonParserGenerator.kt:712 */
-77
+    }
     /* JsonParserGenerator.kt:516 */
-79
+}

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