Server Test

rev. 3c756f73b1f83a0eed4275d9d1e22df0b10b66fb (ignoring whitespace)

Files changed:

tmp-codegen-diff/codegen-server-test/constraints/rust-server-codegen/Cargo.toml

@@ -1,1 +57,65 @@

 # Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 [package]
 name = "constraints"
 version = "0.0.1"
 authors = ["protocoltest@example.com"]
 description = "test"
 edition = "2021"
-8
 [package.metadata.smithy]
 codegen-version = "ci"
 protocol = "aws.protocols#restJson1"
 [dependencies.aws-smithy-eventstream]

 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-eventstream"
 [dependencies.aws-smithy-http]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-http"
 features = ["event-stream"]
 [dependencies.aws-smithy-http-server]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-http-server"
 [dependencies.aws-smithy-json]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-json"
 [dependencies.aws-smithy-runtime-api]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-runtime-api"
 features = ["http-1x"]
 [dependencies.aws-smithy-types]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-types"
 features = ["http-body-1-x"]
 [dependencies.bytes]
 version = "1.4.0"
 [dependencies.form_urlencoded]
 version = "1"
 [dependencies.futures-util]
 version = "0.3"
 [dependencies.http]
 version = "0.2.9"
 [dependencies.hyper]
 version = "0.14.26"
 [dependencies.http-1x]
 version = "1"
 package = "http"
 [dependencies.http-body-1x]
 version = "1"
 package = "http-body"
 [dependencies.http-body-util]
 version = "0.1.3"
 [dependencies.mime]
 version = "0.3"
 [dependencies.nom]
 version = "7"
 [dependencies.percent-encoding]
 version = "2.0.0"
 [dependencies.pin-project-lite]
 version = "0.2"
 [dependencies.regex]
 version = "1.5.5"
 [dependencies.tower]
 version = "0.4"
 [dependencies.tracing]
 version = "0.1"
 [dev-dependencies.hyper]
 version = "0.14.12"
 version = "1"
 [dev-dependencies.tokio]
 version = "1.23.1"
 [features]
 aws-lambda = ["aws-smithy-http-server/aws-lambda"]
 request-id = ["aws-smithy-http-server/request-id"]
 rt-tokio = ["aws-smithy-types/rt-tokio"]
 rt-tokio = ["aws-smithy-types/http-body-1-x", "aws-smithy-types/rt-tokio"]
 default = ["request-id", "rt-tokio"]
-64
-65

tmp-codegen-diff/codegen-server-test/constraints/rust-server-codegen/src/lib.rs

@@ -19,19 +128,131 @@

↥ Expand context

 #![allow(rustdoc::invalid_html_tags)]
 #![forbid(unsafe_code)]
 #![cfg_attr(docsrs, feature(doc_cfg))]
 //! A service to test aspects of code generation where shapes have constraint traits.
-23
 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 //! A fast and customizable Rust implementation of the ConstraintsService Smithy service.
 //!
 //! # Using ConstraintsService
 //!
 //! The primary entrypoint is [`ConstraintsService`]: it satisfies the [`Service<http::Request, Response = http::Response>`](::tower::Service)
 //! trait and therefore can be handed to a [`hyper` server](https://github.com/hyperium/hyper) via [`ConstraintsService::into_make_service`]
 //! or used in AWS Lambda
 #![cfg_attr(
     feature = "aws-lambda",
     doc = " via [`LambdaHandler`](crate::server::routing::LambdaHandler)."
 )]
 #![cfg_attr(
     not(feature = "aws-lambda"),
     doc = " by enabling the `aws-lambda` feature flag and utilizing the `LambdaHandler`."

 )]
 //! The [`crate::input`], [`crate::output`], and [`crate::error`]
 //! modules provide the types used in each operation.
 //!
 //! ### Running on Hyper
 //!
 //! ```rust,no_run
 //! # use std::net::SocketAddr;
 //! # async fn dummy() {
 //! use constraints::{ConstraintsService, ConstraintsServiceConfig};
 //! use constraints::serve;
 //! use ::tokio::net::TcpListener;
 //!
 //! # let app = ConstraintsService::builder(
 //! #     ConstraintsServiceConfig::builder()
 //! #         .build()
 //! # ).build_unchecked();
 //! let server = app.into_make_service();
 //! let bind: SocketAddr = "127.0.0.1:6969".parse()
 //!     .expect("unable to parse the server bind address and port");
 //! ::hyper::Server::bind(&bind).serve(server).await.unwrap();
 //! let listener = TcpListener::bind(bind).await
 //!     .expect("failed to bind TCP listener");
 //! serve(listener, app.into_make_service()).await.unwrap();
 //! # }
 //! ```
 //!
 //! ### Running on Lambda
 //!
 //! ```rust,ignore
 //! use constraints::server::routing::LambdaHandler;
 //! use constraints::ConstraintsService;
 //!
 //! # async fn dummy() {
 //! # let app = ConstraintsService::builder(
 //! #     ConstraintsServiceConfig::builder()
 //! #         .build()
 //! # ).build_unchecked();
 //! let handler = LambdaHandler::new(app);
 //! lambda_http::run(handler).await.unwrap();
 //! # }
 //! ```
 //!
 //! # Building the ConstraintsService
 //!
 //! To construct [`ConstraintsService`] we use [`ConstraintsServiceBuilder`] returned by [`ConstraintsService::builder`].
 //!
 //! ## Plugins
 //!
 //! The [`ConstraintsService::builder`] method, returning [`ConstraintsServiceBuilder`],
 //! accepts a config object on which plugins can be registered.
 //! Plugins allow you to build middleware which is aware of the operation it is being applied to.
 //!
 //! ```rust,no_run
 //! # use constraints::server::plugin::IdentityPlugin as LoggingPlugin;
 //! # use constraints::server::plugin::IdentityPlugin as MetricsPlugin;
 //! # use ::hyper::Body;
 //! # use ::hyper::body::Incoming;
 //! use constraints::server::plugin::HttpPlugins;
 //! use constraints::{ConstraintsService, ConstraintsServiceConfig, ConstraintsServiceBuilder};
 //!
 //! let http_plugins = HttpPlugins::new()
 //!         .push(LoggingPlugin)
 //!         .push(MetricsPlugin);
 //! let config = ConstraintsServiceConfig::builder().build();
 //! let builder: ConstraintsServiceBuilder<Body, _, _, _> = ConstraintsService::builder(config);
 //! let builder: ConstraintsServiceBuilder<::hyper::body::Incoming, _, _, _> = ConstraintsService::builder(config);
 //! ```
 //!
 //! Check out [`crate::server::plugin`] to learn more about plugins.
 //!
 //! ## Handlers
 //!
 //! [`ConstraintsServiceBuilder`] provides a setter method for each operation in your Smithy model. The setter methods expect an async function as input, matching the signature for the corresponding operation in your Smithy model.
 //! We call these async functions **handlers**. This is where your application business logic lives.
 //!
 //! Every handler must take an `Input`, and optional [`extractor arguments`](crate::server::request), while returning:

↧ Expand context

 //!
 //! * A `Result<Output, Error>` if your operation has modeled errors, or
 //! * An `Output` otherwise.
 //!
 //! ```rust,no_run
 //! # struct Input;
 //! # struct Output;
 //! # struct Error;
 //! async fn infallible_handler(input: Input) -> Output { todo!() }
 //!
 //! async fn fallible_handler(input: Input) -> Result<Output, Error> { todo!() }
 //! ```
 //!
 //! Handlers can accept up to 8 extractors:
 //!
 //! ```rust,no_run
 //! # struct Input;
 //! # struct Output;
 //! # struct Error;
 //! # struct State;

@@ -135,138 +229,235 @@

↥ Expand context

 //!
 //! async fn handler_with_one_extractor(input: Input, ext: Extension<State>) -> Output {
 //!     todo!()
 //! }
 //!
 //! async fn handler_with_two_extractors(
 //!     input: Input,
 //!     ext0: Extension<State>,
 //!     ext1: ConnectInfo<SocketAddr>,
 //! ) -> Output {
 //!     todo!()
 //! }
 //! ```
 //!
 //! See the [`operation module`](crate::operation) for information on precisely what constitutes a handler.
 //!
 //! ## Build
 //!
 //! You can convert [`ConstraintsServiceBuilder`] into [`ConstraintsService`] using either [`ConstraintsServiceBuilder::build`] or [`ConstraintsServiceBuilder::build_unchecked`].
 //!

 //! [`ConstraintsServiceBuilder::build`] requires you to provide a handler for every single operation in your Smithy model. It will return an error if that is not the case.
 //!
 //! [`ConstraintsServiceBuilder::build_unchecked`], instead, does not require exhaustiveness. The server will automatically return 500 Internal Server Error to all requests for operations that do not have a registered handler.
 //! [`ConstraintsServiceBuilder::build_unchecked`] is particularly useful if you are deploying your Smithy service as a collection of Lambda functions, where each Lambda is only responsible for a subset of the operations in the Smithy service (or even a single one!).
 //!
 //! # Example
 //!
 //! ```rust,no_run
 //! # use std::net::SocketAddr;
 //! use constraints::{ConstraintsService, ConstraintsServiceConfig};
 //! use constraints::serve;
 //! use ::tokio::net::TcpListener;
 //!
 //! #[::tokio::main]
 //! pub async fn main() {
 //!    let config = ConstraintsServiceConfig::builder().build();
 //!    let app = ConstraintsService::builder(config)
 //!        .constrained_http_bound_shapes_operation(constrained_http_bound_shapes_operation)
 //!        .constrained_http_payload_bound_shape_operation(constrained_http_payload_bound_shape_operation)
 //!        .constrained_recursive_shapes_operation(constrained_recursive_shapes_operation)
 //!        .constrained_shapes_only_in_output_operation(constrained_shapes_only_in_output_operation)
 //!        .constrained_shapes_operation(constrained_shapes_operation)
 //!        .event_streams_operation(event_streams_operation)
 //!        .http_prefix_headers_targeting_length_map_operation(http_prefix_headers_targeting_length_map_operation)
 //!        .non_streaming_blob_operation(non_streaming_blob_operation)
 //!        .query_params_targeting_length_map_operation(query_params_targeting_length_map_operation)
 //!        .query_params_targeting_map_of_enum_string_operation(query_params_targeting_map_of_enum_string_operation)
 //!        .query_params_targeting_map_of_length_list_of_pattern_string_operation(query_params_targeting_map_of_length_list_of_pattern_string_operation)
 //!        .query_params_targeting_map_of_length_pattern_string_operation(query_params_targeting_map_of_length_pattern_string_operation)
 //!        .query_params_targeting_map_of_length_string_operation(query_params_targeting_map_of_length_string_operation)
 //!        .query_params_targeting_map_of_list_of_enum_string_operation(query_params_targeting_map_of_list_of_enum_string_operation)
 //!        .query_params_targeting_map_of_list_of_length_pattern_string_operation(query_params_targeting_map_of_list_of_length_pattern_string_operation)
 //!        .query_params_targeting_map_of_list_of_length_string_operation(query_params_targeting_map_of_list_of_length_string_operation)
 //!        .query_params_targeting_map_of_list_of_pattern_string_operation(query_params_targeting_map_of_list_of_pattern_string_operation)
 //!        .query_params_targeting_map_of_pattern_string_operation(query_params_targeting_map_of_pattern_string_operation)
 //!        .query_params_targeting_map_of_set_of_length_string_operation(query_params_targeting_map_of_set_of_length_string_operation)
 //!        .streaming_blob_operation(streaming_blob_operation)
 //!        .build()
 //!        .expect("failed to build an instance of ConstraintsService");
 //!
 //!    let bind: SocketAddr = "127.0.0.1:6969".parse()
 //!        .expect("unable to parse the server bind address and port");
 //!    let server = ::hyper::Server::bind(&bind).serve(app.into_make_service());
 //!    let listener = TcpListener::bind(bind).await
 //!        .expect("failed to bind TCP listener");
 //!    # let server = async { Ok::<_, ()>(()) };
 //!
 //!    // Run your service!
 //!    if let Err(err) = server.await {
 //!    if let Err(err) = serve(listener, app.into_make_service()).await {
 //!        eprintln!("server error: {:?}", err);
 //!    }
 //! }
 //!
 //! use constraints::{input, output, error};
 //!
 //! async fn constrained_http_bound_shapes_operation(input: input::ConstrainedHttpBoundShapesOperationInput) -> Result<output::ConstrainedHttpBoundShapesOperationOutput, error::ConstrainedHttpBoundShapesOperationError> {
 //!     todo!()
 //! }
 //!

↧ Expand context

 //! async fn constrained_http_payload_bound_shape_operation(input: input::ConstrainedHttpPayloadBoundShapeOperationInput) -> Result<output::ConstrainedHttpPayloadBoundShapeOperationOutput, error::ConstrainedHttpPayloadBoundShapeOperationError> {
 //!     todo!()
 //! }
 //!
 //! async fn constrained_recursive_shapes_operation(input: input::ConstrainedRecursiveShapesOperationInput) -> Result<output::ConstrainedRecursiveShapesOperationOutput, error::ConstrainedRecursiveShapesOperationError> {
 //!     todo!()
 //! }
 //!
 //! async fn constrained_shapes_only_in_output_operation(input: input::ConstrainedShapesOnlyInOutputOperationInput) -> output::ConstrainedShapesOnlyInOutputOperationOutput {
 //!     todo!()
 //! }
 //!
 //! async fn constrained_shapes_operation(input: input::ConstrainedShapesOperationInput) -> Result<output::ConstrainedShapesOperationOutput, error::ConstrainedShapesOperationError> {
 //!     todo!()
 //! }
 //!
 //! async fn event_streams_operation(input: input::EventStreamsOperationInput) -> Result<output::EventStreamsOperationOutput, error::EventStreamsOperationError> {
 //!     todo!()
 //! }
 //!

@@ -258,264 +323,330 @@

↥ Expand context

 //! async fn query_params_targeting_map_of_list_of_enum_string_operation(input: input::QueryParamsTargetingMapOfListOfEnumStringOperationInput) -> Result<output::QueryParamsTargetingMapOfListOfEnumStringOperationOutput, error::QueryParamsTargetingMapOfListOfEnumStringOperationError> {
 //!     todo!()
 //! }
 //!
 //! async fn query_params_targeting_map_of_list_of_length_pattern_string_operation(input: input::QueryParamsTargetingMapOfListOfLengthPatternStringOperationInput) -> Result<output::QueryParamsTargetingMapOfListOfLengthPatternStringOperationOutput, error::QueryParamsTargetingMapOfListOfLengthPatternStringOperationError> {
 //!     todo!()
 //! }
 //!
 //! async fn query_params_targeting_map_of_list_of_length_string_operation(input: input::QueryParamsTargetingMapOfListOfLengthStringOperationInput) -> Result<output::QueryParamsTargetingMapOfListOfLengthStringOperationOutput, error::QueryParamsTargetingMapOfListOfLengthStringOperationError> {
 //!     todo!()
 //! }
 //!
 //! async fn query_params_targeting_map_of_list_of_pattern_string_operation(input: input::QueryParamsTargetingMapOfListOfPatternStringOperationInput) -> Result<output::QueryParamsTargetingMapOfListOfPatternStringOperationOutput, error::QueryParamsTargetingMapOfListOfPatternStringOperationError> {
 //!     todo!()
 //! }
 //!
 //! async fn query_params_targeting_map_of_pattern_string_operation(input: input::QueryParamsTargetingMapOfPatternStringOperationInput) -> Result<output::QueryParamsTargetingMapOfPatternStringOperationOutput, error::QueryParamsTargetingMapOfPatternStringOperationError> {
 //!     todo!()
 //! }
 //!

 //! async fn query_params_targeting_map_of_set_of_length_string_operation(input: input::QueryParamsTargetingMapOfSetOfLengthStringOperationInput) -> Result<output::QueryParamsTargetingMapOfSetOfLengthStringOperationOutput, error::QueryParamsTargetingMapOfSetOfLengthStringOperationError> {
 //!     todo!()
 //! }
 //!
 //! async fn streaming_blob_operation(input: input::StreamingBlobOperationInput) -> output::StreamingBlobOperationOutput {
 //!     todo!()
 //! }
 //!
 //! ```
 //!
 //! [`serve`]: https://docs.rs/hyper/0.14.16/hyper/server/struct.Builder.html#method.serve
 //! [`serve`]: crate::serve
 //! [hyper server]: https://docs.rs/hyper/latest/hyper/server/index.html
 //! [`tower::make::MakeService`]: https://docs.rs/tower/latest/tower/make/trait.MakeService.html
 //! [HTTP binding traits]: https://smithy.io/2.0/spec/http-bindings.html
 //! [operations]: https://smithy.io/2.0/spec/service-types.html#operation
 //! [hyper server]: https://docs.rs/hyper/latest/hyper/server/index.html
 //! [Service]: https://docs.rs/tower-service/latest/tower_service/trait.Service.html
 pub use crate::server::serve::serve;
 pub use crate::service::{
     ConstraintsService, ConstraintsServiceBuilder, ConstraintsServiceConfig,
     ConstraintsServiceConfigBuilder, MissingOperationsError,
 };
-305
 /// Contains the types that are re-exported from the `aws-smithy-http-server` crate.
 pub mod server {
     // Re-export all types from the `aws-smithy-http-server` crate.
     pub use ::aws_smithy_http_server::*;
-310
+}

↧ Expand context

-311
 /// Crate version number.
 pub static PKG_VERSION: &str = env!("CARGO_PKG_VERSION");
-314
 /// Constrained types for constrained shapes.
 mod constrained;
-317
 /// All error types that operations can return. Documentation on these types is copied from the model.
 pub mod error;
-320
 /// Input structures for operations. Documentation on these types is copied from the model.
 pub mod input;
-323
 /// Data structures used by operation inputs/outputs. Documentation on these types is copied from the model.
 pub mod model;
-326
 /// All operations that this crate can perform.
 pub mod operation;
-329
 /// A collection of types representing each operation defined in the service closure.

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

@@ -4,4 +72,77 @@

↥ Expand context

     /// [`EventStreamsOperationInput`](crate::input::EventStreamsOperationInput) using modelled bindings.
     pub struct EventStreamsOperationInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EventStreamsOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-7
+    }
-8
+}
-9
 impl std::future::Future for EventStreamsOperationInputFuture {
     type Output = Result<
         crate::input::EventStreamsOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-15
     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)
-22
+    }
-23
+}

-24
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::EventStreamsOperationInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-33
     B: Into<::aws_smithy_types::byte_stream::ByteStream>,
     B: ::http_body_1x::Body<Data = ::bytes::Bytes>
         + ::std::marker::Send
         + ::std::marker::Sync
         + 'static,
     B::Error: Into<::aws_smithy_types::body::Error> + 'static,
-+
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-43
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = EventStreamsOperationInputFuture;
-46
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_VND_AMAZON_EVENTSTREAM,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-54
+            }
             crate::protocol_serde::shape_event_streams_operation::de_event_streams_operation_http_request(request)
                             .await
         };

↧ Expand context

         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,
-64
+                )
             },
         );
         EventStreamsOperationInputFuture {
             inner: Box::pin(fut),
-69
+        }
-70
+    }
-71
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::EventStreamsOperationOutput
-76
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

@@ -103,108 +171,181 @@

↥ Expand context

     /// [`StreamingBlobOperationInput`](crate::input::StreamingBlobOperationInput) using modelled bindings.
     pub struct StreamingBlobOperationInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::StreamingBlobOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-111
+    }
-112
+}
-113
 impl std::future::Future for StreamingBlobOperationInputFuture {
     type Output = Result<
         crate::input::StreamingBlobOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-119
     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)
-126
+    }
-127
+}

-128
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::StreamingBlobOperationInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-137
     B: Into<::aws_smithy_types::byte_stream::ByteStream>,
     B: ::http_body_1x::Body<Data = ::bytes::Bytes>
         + ::std::marker::Send
         + ::std::marker::Sync
         + 'static,
     B::Error: Into<::aws_smithy_types::body::Error> + 'static,
-+
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-147
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = StreamingBlobOperationInputFuture;
-150
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_OCTET_STREAM,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-158
+            }
             crate::protocol_serde::shape_streaming_blob_operation::de_streaming_blob_operation_http_request(request)
                             .await
         };

↧ Expand context

         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,
-168
+                )
             },
         );
         StreamingBlobOperationInputFuture {
             inner: Box::pin(fut),
-173
+        }
-174
+    }
-175
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::StreamingBlobOperationOutput
-180
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

@@ -191,201 +251,261 @@

↥ Expand context

     type Output = Result<
         crate::input::NonStreamingBlobOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-205
     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)
-212
+    }
-213
+}
-214
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::NonStreamingBlobOperationInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-223
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-227
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = NonStreamingBlobOperationInputFuture;
-230
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             crate::protocol_serde::shape_non_streaming_blob_operation::de_non_streaming_blob_operation_http_request(request)
                             .await
         };
         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,

↧ Expand context

-242
+                )
             },
         );
         NonStreamingBlobOperationInputFuture {
             inner: Box::pin(fut),
-247
+        }
-248
+    }
-249
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::NonStreamingBlobOperationOutput
-254
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_non_streaming_blob_operation::ser_non_streaming_blob_operation_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))
-261
+                        }

@@ -265,275 +325,335 @@

↥ Expand context

     type Output = Result<
         crate::input::QueryParamsTargetingMapOfEnumStringOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-279
     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)
-286
+    }
-287
+}
-288
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::QueryParamsTargetingMapOfEnumStringOperationInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-297
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-301
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = QueryParamsTargetingMapOfEnumStringOperationInputFuture;
-304
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-312
+            }
             crate::protocol_serde::shape_query_params_targeting_map_of_enum_string_operation::de_query_params_targeting_map_of_enum_string_operation_http_request(request)
                             .await
         };

↧ Expand context

         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,
-322
+                )
             },
         );
         QueryParamsTargetingMapOfEnumStringOperationInputFuture {
             inner: Box::pin(fut),
-327
+        }
-328
+    }
-329
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::QueryParamsTargetingMapOfEnumStringOperationOutput
-334
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

@@ -363,373 +423,433 @@

↥ Expand context

     type Output = Result<
         crate::input::HttpPrefixHeadersTargetingLengthMapOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-377
     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)
-384
+    }
-385
+}
-386
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::HttpPrefixHeadersTargetingLengthMapOperationInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-395
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-399
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = HttpPrefixHeadersTargetingLengthMapOperationInputFuture;
-402
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-410
+            }
             crate::protocol_serde::shape_http_prefix_headers_targeting_length_map_operation::de_http_prefix_headers_targeting_length_map_operation_http_request(request)
                             .await
         };

↧ Expand context

         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,
-420
+                )
             },
         );
         HttpPrefixHeadersTargetingLengthMapOperationInputFuture {
             inner: Box::pin(fut),
-425
+        }
-426
+    }
-427
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::HttpPrefixHeadersTargetingLengthMapOperationOutput
-432
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

@@ -463,473 +523,533 @@

↥ Expand context

     type Output = Result<
         crate::input::QueryParamsTargetingMapOfListOfLengthPatternStringOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-477
     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)
-484
+    }
-485
+}
-486
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::QueryParamsTargetingMapOfListOfLengthPatternStringOperationInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-495
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-499
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = QueryParamsTargetingMapOfListOfLengthPatternStringOperationInputFuture;
-502
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-510
+            }
             crate::protocol_serde::shape_query_params_targeting_map_of_list_of_length_pattern_string_operation::de_query_params_targeting_map_of_list_of_length_pattern_string_operation_http_request(request)
                             .await
         };

↧ Expand context

         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,
-520
+                )
             },
         );
         QueryParamsTargetingMapOfListOfLengthPatternStringOperationInputFuture {
             inner: Box::pin(fut),
-525
+        }
-526
+    }
-527
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::QueryParamsTargetingMapOfListOfLengthPatternStringOperationOutput
-532
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

@@ -561,571 +621,631 @@

↥ Expand context

     type Output = Result<
         crate::input::QueryParamsTargetingMapOfLengthPatternStringOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-575
     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)
-582
+    }
-583
+}
-584
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::QueryParamsTargetingMapOfLengthPatternStringOperationInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-593
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-597
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = QueryParamsTargetingMapOfLengthPatternStringOperationInputFuture;
-600
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-608
+            }
             crate::protocol_serde::shape_query_params_targeting_map_of_length_pattern_string_operation::de_query_params_targeting_map_of_length_pattern_string_operation_http_request(request)
                             .await
         };

↧ Expand context

         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,
-618
+                )
             },
         );
         QueryParamsTargetingMapOfLengthPatternStringOperationInputFuture {
             inner: Box::pin(fut),
-623
+        }
-624
+    }
-625
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::QueryParamsTargetingMapOfLengthPatternStringOperationOutput
-630
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

@@ -659,669 +719,729 @@

↥ Expand context

     type Output = Result<
         crate::input::QueryParamsTargetingMapOfListOfPatternStringOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-673
     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)
-680
+    }
-681
+}
-682
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::QueryParamsTargetingMapOfListOfPatternStringOperationInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-691
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-695
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = QueryParamsTargetingMapOfListOfPatternStringOperationInputFuture;
-698
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-706
+            }
             crate::protocol_serde::shape_query_params_targeting_map_of_list_of_pattern_string_operation::de_query_params_targeting_map_of_list_of_pattern_string_operation_http_request(request)
                             .await
         };

↧ Expand context

         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,
-716
+                )
             },
         );
         QueryParamsTargetingMapOfListOfPatternStringOperationInputFuture {
             inner: Box::pin(fut),
-721
+        }
-722
+    }
-723
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::QueryParamsTargetingMapOfListOfPatternStringOperationOutput
-728
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

@@ -757,767 +817,827 @@

↥ Expand context

     type Output = Result<
         crate::input::QueryParamsTargetingMapOfPatternStringOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-771
     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)
-778
+    }
-779
+}
-780
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::QueryParamsTargetingMapOfPatternStringOperationInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-789
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-793
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = QueryParamsTargetingMapOfPatternStringOperationInputFuture;
-796
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-804
+            }
             crate::protocol_serde::shape_query_params_targeting_map_of_pattern_string_operation::de_query_params_targeting_map_of_pattern_string_operation_http_request(request)
                             .await
         };

↧ Expand context

         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,
-814
+                )
             },
         );
         QueryParamsTargetingMapOfPatternStringOperationInputFuture {
             inner: Box::pin(fut),
-819
+        }
-820
+    }
-821
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::QueryParamsTargetingMapOfPatternStringOperationOutput
-826
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

@@ -855,865 +915,925 @@

↥ Expand context

     type Output = Result<
         crate::input::QueryParamsTargetingMapOfListOfEnumStringOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-869
     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)
-876
+    }
-877
+}
-878
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::QueryParamsTargetingMapOfListOfEnumStringOperationInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-887
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-891
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = QueryParamsTargetingMapOfListOfEnumStringOperationInputFuture;
-894
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-902
+            }
             crate::protocol_serde::shape_query_params_targeting_map_of_list_of_enum_string_operation::de_query_params_targeting_map_of_list_of_enum_string_operation_http_request(request)
                             .await
         };

↧ Expand context

         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,
-912
+                )
             },
         );
         QueryParamsTargetingMapOfListOfEnumStringOperationInputFuture {
             inner: Box::pin(fut),
-917
+        }
-918
+    }
-919
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::QueryParamsTargetingMapOfListOfEnumStringOperationOutput
-924
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

@@ -955,965 +1015,1025 @@

↥ Expand context

     type Output = Result<
         crate::input::QueryParamsTargetingMapOfLengthListOfPatternStringOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-969
     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)
-976
+    }
-977
+}
-978
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::QueryParamsTargetingMapOfLengthListOfPatternStringOperationInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-987
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-991
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = QueryParamsTargetingMapOfLengthListOfPatternStringOperationInputFuture;
-994
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-1002
+            }
             crate::protocol_serde::shape_query_params_targeting_map_of_length_list_of_pattern_string_operation::de_query_params_targeting_map_of_length_list_of_pattern_string_operation_http_request(request)
                             .await
         };

↧ Expand context

         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,
-1012
+                )
             },
         );
         QueryParamsTargetingMapOfLengthListOfPatternStringOperationInputFuture {
             inner: Box::pin(fut),
-1017
+        }
-1018
+    }
-1019
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::QueryParamsTargetingMapOfLengthListOfPatternStringOperationOutput
-1024
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

@@ -1053,1063 +1113,1123 @@

↥ Expand context

     type Output = Result<
         crate::input::QueryParamsTargetingMapOfSetOfLengthStringOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-1067
     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)
-1074
+    }
-1075
+}
-1076
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::QueryParamsTargetingMapOfSetOfLengthStringOperationInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-1085
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-1089
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = QueryParamsTargetingMapOfSetOfLengthStringOperationInputFuture;
-1092
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-1100
+            }
             crate::protocol_serde::shape_query_params_targeting_map_of_set_of_length_string_operation::de_query_params_targeting_map_of_set_of_length_string_operation_http_request(request)
                             .await
         };

↧ Expand context

         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,
-1110
+                )
             },
         );
         QueryParamsTargetingMapOfSetOfLengthStringOperationInputFuture {
             inner: Box::pin(fut),
-1115
+        }
-1116
+    }
-1117
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::QueryParamsTargetingMapOfSetOfLengthStringOperationOutput
-1122
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

@@ -1151,1161 +1211,1221 @@

↥ Expand context

     type Output = Result<
         crate::input::QueryParamsTargetingMapOfListOfLengthStringOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-1165
     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)
-1172
+    }
-1173
+}
-1174
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::QueryParamsTargetingMapOfListOfLengthStringOperationInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-1183
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-1187
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = QueryParamsTargetingMapOfListOfLengthStringOperationInputFuture;
-1190
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-1198
+            }
             crate::protocol_serde::shape_query_params_targeting_map_of_list_of_length_string_operation::de_query_params_targeting_map_of_list_of_length_string_operation_http_request(request)
                             .await
         };

↧ Expand context

         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,
-1208
+                )
             },
         );
         QueryParamsTargetingMapOfListOfLengthStringOperationInputFuture {
             inner: Box::pin(fut),
-1213
+        }
-1214
+    }
-1215
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::QueryParamsTargetingMapOfListOfLengthStringOperationOutput
-1220
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

@@ -1249,1259 +1309,1319 @@

↥ Expand context

     type Output = Result<
         crate::input::QueryParamsTargetingMapOfLengthStringOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-1263
     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)
-1270
+    }
-1271
+}
-1272
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::QueryParamsTargetingMapOfLengthStringOperationInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-1281
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-1285
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = QueryParamsTargetingMapOfLengthStringOperationInputFuture;
-1288
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-1296
+            }
             crate::protocol_serde::shape_query_params_targeting_map_of_length_string_operation::de_query_params_targeting_map_of_length_string_operation_http_request(request)
                             .await
         };

↧ Expand context

         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,
-1306
+                )
             },
         );
         QueryParamsTargetingMapOfLengthStringOperationInputFuture {
             inner: Box::pin(fut),
-1311
+        }
-1312
+    }
-1313
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::QueryParamsTargetingMapOfLengthStringOperationOutput
-1318
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

@@ -1347,1357 +1407,1417 @@

↥ Expand context

     type Output = Result<
         crate::input::QueryParamsTargetingLengthMapOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-1361
     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)
-1368
+    }
-1369
+}
-1370
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::QueryParamsTargetingLengthMapOperationInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-1379
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-1383
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = QueryParamsTargetingLengthMapOperationInputFuture;
-1386
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-1394
+            }
             crate::protocol_serde::shape_query_params_targeting_length_map_operation::de_query_params_targeting_length_map_operation_http_request(request)
                             .await
         };

↧ Expand context

         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,
-1404
+                )
             },
         );
         QueryParamsTargetingLengthMapOperationInputFuture {
             inner: Box::pin(fut),
-1409
+        }
-1410
+    }
-1411
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::QueryParamsTargetingLengthMapOperationOutput
-1416
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

@@ -1445,1455 +1505,1515 @@

↥ Expand context

     type Output = Result<
         crate::input::ConstrainedRecursiveShapesOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-1459
     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)
-1466
+    }
-1467
+}
-1468
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::ConstrainedRecursiveShapesOperationInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-1477
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-1481
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = ConstrainedRecursiveShapesOperationInputFuture;
-1484
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-1492
+            }
             crate::protocol_serde::shape_constrained_recursive_shapes_operation::de_constrained_recursive_shapes_operation_http_request(request)
                             .await
         };

↧ Expand context

         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,
-1502
+                )
             },
         );
         ConstrainedRecursiveShapesOperationInputFuture {
             inner: Box::pin(fut),
-1507
+        }
-1508
+    }
-1509
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::ConstrainedRecursiveShapesOperationOutput
-1514
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

@@ -1543,1553 +1603,1613 @@

↥ Expand context

     type Output = Result<
         crate::input::ConstrainedHttpPayloadBoundShapeOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-1557
     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)
-1564
+    }
-1565
+}
-1566
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::ConstrainedHttpPayloadBoundShapeOperationInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-1575
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-1579
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = ConstrainedHttpPayloadBoundShapeOperationInputFuture;
-1582
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-1590
+            }
             crate::protocol_serde::shape_constrained_http_payload_bound_shape_operation::de_constrained_http_payload_bound_shape_operation_http_request(request)
                             .await
         };

↧ Expand context

         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,
-1600
+                )
             },
         );
         ConstrainedHttpPayloadBoundShapeOperationInputFuture {
             inner: Box::pin(fut),
-1605
+        }
-1606
+    }
-1607
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::ConstrainedHttpPayloadBoundShapeOperationOutput
-1612
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

@@ -1641,1651 +1701,1711 @@

↥ Expand context

     type Output = Result<
         crate::input::ConstrainedHttpBoundShapesOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-1655
     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)
-1662
+    }
-1663
+}
-1664
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::ConstrainedHttpBoundShapesOperationInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-1673
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-1677
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = ConstrainedHttpBoundShapesOperationInputFuture;
-1680
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-1688
+            }
             crate::protocol_serde::shape_constrained_http_bound_shapes_operation::de_constrained_http_bound_shapes_operation_http_request(request)
                             .await
         };

↧ Expand context

         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,
-1698
+                )
             },
         );
         ConstrainedHttpBoundShapesOperationInputFuture {
             inner: Box::pin(fut),
-1703
+        }
-1704
+    }
-1705
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::ConstrainedHttpBoundShapesOperationOutput
-1710
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

@@ -1739,1749 +1799,1809 @@

↥ Expand context

     type Output = Result<
         crate::input::ConstrainedShapesOnlyInOutputOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-1753
     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)
-1760
+    }
-1761
+}
-1762
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::ConstrainedShapesOnlyInOutputOperationInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-1771
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-1775
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = ConstrainedShapesOnlyInOutputOperationInputFuture;
-1778
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-1786
+            }
             crate::protocol_serde::shape_constrained_shapes_only_in_output_operation::de_constrained_shapes_only_in_output_operation_http_request(request)
                             .await
         };

↧ Expand context

         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,
-1796
+                )
             },
         );
         ConstrainedShapesOnlyInOutputOperationInputFuture {
             inner: Box::pin(fut),
-1801
+        }
-1802
+    }
-1803
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::ConstrainedShapesOnlyInOutputOperationOutput
-1808
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

@@ -1819,1829 +1879,1889 @@

↥ Expand context

     type Output = Result<
         crate::input::ConstrainedShapesOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-1833
     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)
-1840
+    }
-1841
+}
-1842
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::ConstrainedShapesOperationInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-1851
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-1855
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = ConstrainedShapesOperationInputFuture;
-1858
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-1866
+            }
             crate::protocol_serde::shape_constrained_shapes_operation::de_constrained_shapes_operation_http_request(request)
                             .await
         };

↧ Expand context

         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,
-1876
+                )
             },
         );
         ConstrainedShapesOperationInputFuture {
             inner: Box::pin(fut),
-1881
+        }
-1882
+    }
-1883
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::ConstrainedShapesOperationOutput
-1888
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

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

@@ -1,1 +34,34 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_constrained_http_bound_shapes_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::ConstrainedHttpBoundShapesOperationInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-14
+{

↧ Expand context

     Ok({
         #[allow(unused_mut)]
         let mut input =
             crate::input::constrained_http_bound_shapes_operation_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) = crate::protocol_serde::shape_constrained_http_bound_shapes_operation_input::de_length_list_pattern_string_header_header(&headers)? {
                                 input = input.set_length_list_pattern_string_header(Some(value))
-25
+                            }
         if let Some(value) = crate::protocol_serde::shape_constrained_http_bound_shapes_operation_input::de_length_set_pattern_string_header_header(&headers)? {
                                 input = input.set_length_set_pattern_string_header(Some(value))
-28
+                            }
         if let Some(value) = crate::protocol_serde::shape_constrained_http_bound_shapes_operation_input::de_length_string_header_header(&headers)? {
                                 input = input.set_length_string_header(Some(value))
-31
+                            }
         if let Some(value) = crate::protocol_serde::shape_constrained_http_bound_shapes_operation_input::de_length_string_header_map_prefix_header(&headers)? {
                                 input = input.set_length_string_header_map(value)
-34
+                            }

@@ -330,330 +758,760 @@

↥ Expand context

             input = input.set_range_short_list_query(
                 Some(
                     crate::unconstrained::list_of_range_short_unconstrained::ListOfRangeShortUnconstrained(
                         range_short_list_query
-334
+                    )
-335
+                )
             );
-337
+        }
         if !range_short_set_query.is_empty() {
             input = input.set_range_short_set_query(
                 Some(
                     crate::unconstrained::set_of_range_short_unconstrained::SetOfRangeShortUnconstrained(
                         range_short_set_query
-343
+                    )
-344
+                )
             );
-346
+        }
         input.build()?
     })
-349
+}

-350
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_constrained_http_bound_shapes_operation_http_response(
     #[allow(unused_variables)] output: crate::output::ConstrainedHttpBoundShapesOperationOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         let mut builder = ::http_1x::Response::builder();
         builder = crate::protocol_serde::shape_constrained_http_bound_shapes_operation::ser_constrained_http_bound_shapes_operation_headers(&output, builder)?;
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             ::http_1x::header::CONTENT_TYPE,
             "application/json",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload =
             crate::protocol_serde::shape_constrained_http_bound_shapes_operation_output::ser_constrained_http_bound_shapes_operation_output_output_output(&output)?
-371
+        ;
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             ::http_1x::header::CONTENT_LENGTH,
             content_length,
         );
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         builder.body(body)?
     })
-381
+}
-382
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_constrained_http_bound_shapes_operation_http_error(
     error: &crate::error::ConstrainedHttpBoundShapesOperationError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::ConstrainedHttpBoundShapesOperationError::ValidationException(output) => {
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 let mut builder = ::http_1x::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     ::http_1x::header::CONTENT_TYPE,
                     "application/json",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
                     "ValidationException",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     ::http_1x::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
-415
+            }
-416
+        }
     })
-418
+}
-419
 pub fn ser_constrained_http_bound_shapes_operation_headers(
     input: &crate::output::ConstrainedHttpBoundShapesOperationOutput,
     mut builder: ::http::response::Builder,
 ) -> std::result::Result<::http::response::Builder, ::aws_smithy_types::error::operation::BuildError>
--
+{
     mut builder: ::http_1x::response::Builder,
 ) -> std::result::Result<
     ::http_1x::response::Builder,
     ::aws_smithy_types::error::operation::BuildError,
 > {
     if let ::std::option::Option::Some(inner_1) = &input.length_string_header {
         let formatted_2 = inner_1.as_str();
         if !formatted_2.is_empty() {
             let header_value = formatted_2;
             let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
             let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
                 ::aws_smithy_types::error::operation::BuildError::invalid_field(
                     "length_string_header",
                     format!(
                         "`{}` cannot be used as a header value: {}",
                         &header_value, err
                     ),
-438
+                )
             })?;
             builder = builder.header("X-Length", header_value);
-441
+        }
-442
+    }
-443
+    {
         let mut encoder =
             ::aws_smithy_types::primitive::Encoder::from(input.range_integer_header.0);
         let formatted_3 = encoder.encode();
         if !formatted_3.is_empty() {
             let header_value = formatted_3;
             let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
             let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
                 ::aws_smithy_types::error::operation::BuildError::invalid_field(
                     "range_integer_header",
                     format!(
                         "`{}` cannot be used as a header value: {}",
                         &header_value, err
                     ),
-456
+                )
             })?;
             builder = builder.header("X-Range-Integer", header_value);
-459
+        }
-460
+    }
-461
+    {
         let mut encoder = ::aws_smithy_types::primitive::Encoder::from(input.range_short_header.0);
         let formatted_4 = encoder.encode();
         if !formatted_4.is_empty() {
             let header_value = formatted_4;
             let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
             let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
                 ::aws_smithy_types::error::operation::BuildError::invalid_field(
                     "range_short_header",
                     format!(
                         "`{}` cannot be used as a header value: {}",
                         &header_value, err
                     ),
-473
+                )
             })?;
             builder = builder.header("X-Range-Short", header_value);
-476
+        }
-477
+    }
-478
+    {
         let mut encoder = ::aws_smithy_types::primitive::Encoder::from(input.range_long_header.0);
         let formatted_5 = encoder.encode();
         if !formatted_5.is_empty() {
             let header_value = formatted_5;
             let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
             let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
                 ::aws_smithy_types::error::operation::BuildError::invalid_field(
                     "range_long_header",
                     format!(
                         "`{}` cannot be used as a header value: {}",
                         &header_value, err
                     ),
-490
+                )
             })?;
             builder = builder.header("X-Range-Long", header_value);
-493
+        }
-494
+    }
-495
+    {
         let mut encoder = ::aws_smithy_types::primitive::Encoder::from(input.range_byte_header.0);
         let formatted_6 = encoder.encode();
         if !formatted_6.is_empty() {
             let header_value = formatted_6;
             let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
             let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
                 ::aws_smithy_types::error::operation::BuildError::invalid_field(
                     "range_byte_header",
                     format!(
                         "`{}` cannot be used as a header value: {}",
                         &header_value, err
                     ),
-507
+                )
             })?;
             builder = builder.header("X-Range-Byte", header_value);
-510
+        }
-511
+    }
     if let ::std::option::Option::Some(inner_7) = &input.length_string_set_header {
         for inner_8 in &inner_7.0 {
             let formatted_9 = ::aws_smithy_http::header::quote_header_value(inner_8.as_str());
             if !formatted_9.is_empty() {
                 let header_value = formatted_9;
                 let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
                 let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
                     ::aws_smithy_types::error::operation::BuildError::invalid_field(
                         "length_string_set_header",
                         format!(
                             "`{}` cannot be used as a header value: {}",
                             &header_value, err
                         ),
-524
+                    )
                 })?;
                 builder = builder.header("X-Length-Set", header_value);
-527
+            }
-528
+        }
-529
+    }
     if let ::std::option::Option::Some(inner_10) = &input.list_length_string_header {
         for inner_11 in inner_10 {
             let formatted_12 = ::aws_smithy_http::header::quote_header_value(inner_11.as_str());
             if !formatted_12.is_empty() {
                 let header_value = formatted_12;
                 let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
                 let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
                     ::aws_smithy_types::error::operation::BuildError::invalid_field(
                         "list_length_string_header",
                         format!(
                             "`{}` cannot be used as a header value: {}",
                             &header_value, err
                         ),
-542
+                    )
                 })?;
                 builder = builder.header("X-List-Length-String", header_value);
-545
+            }
-546
+        }
-547
+    }
     if let ::std::option::Option::Some(inner_13) = &input.length_list_pattern_string_header {
         for inner_14 in &inner_13.0 {
             let formatted_15 = ::aws_smithy_http::header::quote_header_value(inner_14.as_str());
             if !formatted_15.is_empty() {
                 let header_value = formatted_15;
                 let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
                 let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
                     ::aws_smithy_types::error::operation::BuildError::invalid_field(
                         "length_list_pattern_string_header",
                         format!(
                             "`{}` cannot be used as a header value: {}",
                             &header_value, err
                         ),
-560
+                    )
                 })?;
                 builder = builder.header("X-Length-List-Pattern-String", header_value);
-563
+            }
-564
+        }
-565
+    }
     if let ::std::option::Option::Some(inner_16) = &input.length_set_pattern_string_header {
         for inner_17 in &inner_16.0 {
             let formatted_18 = ::aws_smithy_http::header::quote_header_value(inner_17.as_str());
             if !formatted_18.is_empty() {
                 let header_value = formatted_18;
                 let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
                 let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
                     ::aws_smithy_types::error::operation::BuildError::invalid_field(
                         "length_set_pattern_string_header",
                         format!(
                             "`{}` cannot be used as a header value: {}",
                             &header_value, err
                         ),
-578
+                    )
                 })?;
                 builder = builder.header("X-Length-Set-Pattern-String", header_value);
-581
+            }
-582
+        }
-583
+    }
     if let ::std::option::Option::Some(inner_19) = &input.range_byte_set_header {
         for inner_20 in &inner_19.0 {
             let mut encoder = ::aws_smithy_types::primitive::Encoder::from(inner_20.0);
             let formatted_21 = encoder.encode();
             if !formatted_21.is_empty() {
                 let header_value = formatted_21;
                 let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
                 let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
                     ::aws_smithy_types::error::operation::BuildError::invalid_field(
                         "range_byte_set_header",
                         format!(
                             "`{}` cannot be used as a header value: {}",
                             &header_value, err
                         ),
-597
+                    )
                 })?;
                 builder = builder.header("X-Range-Byte-Set", header_value);
-600
+            }
-601
+        }
-602
+    }
     if let ::std::option::Option::Some(inner_22) = &input.range_short_set_header {
         for inner_23 in &inner_22.0 {
             let mut encoder = ::aws_smithy_types::primitive::Encoder::from(inner_23.0);
             let formatted_24 = encoder.encode();
             if !formatted_24.is_empty() {
                 let header_value = formatted_24;
                 let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
                 let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
                     ::aws_smithy_types::error::operation::BuildError::invalid_field(
                         "range_short_set_header",
                         format!(
                             "`{}` cannot be used as a header value: {}",
                             &header_value, err
                         ),
-616
+                    )
                 })?;
                 builder = builder.header("X-Range-Short-Set", header_value);
-619
+            }
-620
+        }
-621
+    }
     if let ::std::option::Option::Some(inner_25) = &input.range_integer_set_header {
         for inner_26 in &inner_25.0 {
             let mut encoder = ::aws_smithy_types::primitive::Encoder::from(inner_26.0);
             let formatted_27 = encoder.encode();
             if !formatted_27.is_empty() {
                 let header_value = formatted_27;
                 let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
                 let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
                     ::aws_smithy_types::error::operation::BuildError::invalid_field(
                         "range_integer_set_header",
                         format!(
                             "`{}` cannot be used as a header value: {}",
                             &header_value, err
                         ),
-635
+                    )
                 })?;
                 builder = builder.header("X-Range-Integer-Set", header_value);
-638
+            }
-639
+        }
-640
+    }
     if let ::std::option::Option::Some(inner_28) = &input.range_long_set_header {
         for inner_29 in &inner_28.0 {
             let mut encoder = ::aws_smithy_types::primitive::Encoder::from(inner_29.0);
             let formatted_30 = encoder.encode();
             if !formatted_30.is_empty() {
                 let header_value = formatted_30;
                 let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
                 let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
                     ::aws_smithy_types::error::operation::BuildError::invalid_field(
                         "range_long_set_header",
                         format!(
                             "`{}` cannot be used as a header value: {}",
                             &header_value, err
                         ),
-654
+                    )
                 })?;
                 builder = builder.header("X-Range-Long-Set", header_value);
-657
+            }
-658
+        }
-659
+    }
     if let ::std::option::Option::Some(inner_31) = &input.range_byte_list_header {
         for inner_32 in inner_31 {
             let mut encoder = ::aws_smithy_types::primitive::Encoder::from(inner_32.0);
             let formatted_33 = encoder.encode();
             if !formatted_33.is_empty() {
                 let header_value = formatted_33;
                 let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
                 let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
                     ::aws_smithy_types::error::operation::BuildError::invalid_field(
                         "range_byte_list_header",
                         format!(
                             "`{}` cannot be used as a header value: {}",
                             &header_value, err
                         ),
-673
+                    )
                 })?;
                 builder = builder.header("X-Range-Byte-List", header_value);
-676
+            }
-677
+        }
-678
+    }
     if let ::std::option::Option::Some(inner_34) = &input.range_short_list_header {
         for inner_35 in inner_34 {
             let mut encoder = ::aws_smithy_types::primitive::Encoder::from(inner_35.0);
             let formatted_36 = encoder.encode();
             if !formatted_36.is_empty() {
                 let header_value = formatted_36;
                 let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
                 let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
                     ::aws_smithy_types::error::operation::BuildError::invalid_field(
                         "range_short_list_header",
                         format!(
                             "`{}` cannot be used as a header value: {}",
                             &header_value, err
                         ),
-692
+                    )
                 })?;
                 builder = builder.header("X-Range-Short-List", header_value);
-695
+            }
-696
+        }
-697
+    }
     if let ::std::option::Option::Some(inner_37) = &input.range_integer_list_header {
         for inner_38 in inner_37 {
             let mut encoder = ::aws_smithy_types::primitive::Encoder::from(inner_38.0);
             let formatted_39 = encoder.encode();
             if !formatted_39.is_empty() {
                 let header_value = formatted_39;
                 let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
                 let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
                     ::aws_smithy_types::error::operation::BuildError::invalid_field(
                         "range_integer_list_header",
                         format!(
                             "`{}` cannot be used as a header value: {}",
                             &header_value, err
                         ),
-711
+                    )
                 })?;
                 builder = builder.header("X-Range-Integer-List", header_value);
-714
+            }
-715
+        }
-716
+    }
     if let ::std::option::Option::Some(inner_40) = &input.range_long_list_header {
         for inner_41 in inner_40 {
             let mut encoder = ::aws_smithy_types::primitive::Encoder::from(inner_41.0);
             let formatted_42 = encoder.encode();
             if !formatted_42.is_empty() {
                 let header_value = formatted_42;
                 let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
                 let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
                     ::aws_smithy_types::error::operation::BuildError::invalid_field(
                         "range_long_list_header",
                         format!(
                             "`{}` cannot be used as a header value: {}",
                             &header_value, err
                         ),
-730
+                    )
                 })?;
                 builder = builder.header("X-Range-Long-List", header_value);
-733
+            }
-734
+        }
-735
+    }
-736
+    {
         for (k, v) in &input.length_string_header_map {
             use std::str::FromStr;
             let header_name = http::header::HeaderName::from_str(&format!(
             let header_name = ::http_1x::HeaderName::from_str(&format!(
                 "{}{}",
                 "X-Length-String-Prefix-Headers-", &k
             ))
             .map_err(|err| {
                 ::aws_smithy_types::error::operation::BuildError::invalid_field(
                     "length_string_header_map",
                     format!("`{k}` cannot be used as a header name: {err}"),
-747
+                )
             })?;
             let header_value = v.as_str();
             let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
             let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
                 ::aws_smithy_types::error::operation::BuildError::invalid_field(
                     "length_string_header_map",
                     format!("`{v}` cannot be used as a header value: {err}"),
-754
+                )
             })?;
             builder = builder.header(header_name, header_value);
-757
+        }
-758
+    }
     Ok(builder)
-760
+}

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

@@ -1,1 +108,111 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_constrained_http_payload_bound_shape_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::ConstrainedHttpPayloadBoundShapeOperationInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input =
             crate::input::constrained_http_payload_bound_shape_operation_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) = {
             let bytes = ::hyper::body::to_bytes(body).await?;
             let bytes = {
                 use ::http_body_util::BodyExt;
                 body.collect().await?.to_bytes()
             };
             if !bytes.is_empty() {
                 ::aws_smithy_http_server::protocol::content_type_header_classifier_smithy(
                     &headers,
                     Some("application/json"),
                 )?;
-33
+            }
             crate::protocol_serde::shape_constrained_http_payload_bound_shape_operation_input::de_http_payload_bound_constrained_shape_payload(&bytes)?
         } {
             input = input.set_http_payload_bound_constrained_shape(value)
-37
+        }
         input.build()?
     })
-40
+}
-41
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_constrained_http_payload_bound_shape_operation_http_response(
     #[allow(unused_variables)]
     output: crate::output::ConstrainedHttpPayloadBoundShapeOperationOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         let mut builder = ::http_1x::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             ::http_1x::header::CONTENT_TYPE,
             "application/json",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload =
             crate::protocol_serde::shape_constrained_http_payload_bound_shape_operation_output::ser_http_payload_bound_constrained_shape_http_payload(& output.http_payload_bound_constrained_shape)?
-62
+        ;
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             ::http_1x::header::CONTENT_LENGTH,
             content_length,
         );
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         builder.body(body)?
     })
-72
+}
-73
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_constrained_http_payload_bound_shape_operation_http_error(
     error: &crate::error::ConstrainedHttpPayloadBoundShapeOperationError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::ConstrainedHttpPayloadBoundShapeOperationError::ValidationException(
                 output,
             ) => {
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 let mut builder = ::http_1x::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     ::http_1x::header::CONTENT_TYPE,
                     "application/json",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
                     "ValidationException",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     ::http_1x::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
-108
+            }
-109
+        }
     })
-111
+}

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

@@ -1,1 +122,125 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_constrained_recursive_shapes_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::ConstrainedRecursiveShapesOperationInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input =
             crate::input::constrained_recursive_shapes_operation_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         let bytes = ::hyper::body::to_bytes(body).await?;
         let bytes = {
             use ::http_body_util::BodyExt;
             body.collect().await?.to_bytes()
         };
         if !bytes.is_empty() {
             ::aws_smithy_http_server::protocol::content_type_header_classifier_smithy(
                 &headers,
                 Some("application/json"),
             )?;
             input = crate::protocol_serde::shape_constrained_recursive_shapes_operation::de_constrained_recursive_shapes_operation(bytes.as_ref(), input)?;
-33
+        }
         input.build()?
     })
-36
+}
-37
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_constrained_recursive_shapes_operation_http_response(
     #[allow(unused_variables)] output: crate::output::ConstrainedRecursiveShapesOperationOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         let mut builder = ::http_1x::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             ::http_1x::header::CONTENT_TYPE,
             "application/json",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload =
             crate::protocol_serde::shape_constrained_recursive_shapes_operation_output::ser_constrained_recursive_shapes_operation_output_output_output(&output)?
-57
+        ;
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             ::http_1x::header::CONTENT_LENGTH,
             content_length,
         );
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         builder.body(body)?
     })
-67
+}
-68
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_constrained_recursive_shapes_operation_http_error(
     error: &crate::error::ConstrainedRecursiveShapesOperationError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::ConstrainedRecursiveShapesOperationError::ValidationException(output) => {
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 let mut builder = ::http_1x::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     ::http_1x::header::CONTENT_TYPE,
                     "application/json",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
                     "ValidationException",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     ::http_1x::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
-101
+            }
-102
+        }
     })
-104
+}
-105

↧ Expand context

 pub(crate) fn de_constrained_recursive_shapes_operation(
     value: &[u8],
     mut builder: crate::input::constrained_recursive_shapes_operation_input::Builder,
 ) -> ::std::result::Result<
     crate::input::constrained_recursive_shapes_operation_input::Builder,
     ::aws_smithy_json::deserialize::error::DeserializeError,
 > {
     let mut tokens_owned =
         ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(value))
             .peekable();
     let tokens = &mut tokens_owned;
     ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
     loop {
         match tokens.next().transpose()? {
             Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
             Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
                 match key.to_unescaped()?.as_ref() {
                     "nested" => {
                         builder = builder.set_nested(
                             crate::protocol_serde::shape_recursive_shapes_input_output_nested1::de_recursive_shapes_input_output_nested1(tokens)?

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

@@ -1,1 +57,57 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_constrained_shapes_only_in_output_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::ConstrainedShapesOnlyInOutputOperationInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input =
             crate::input::constrained_shapes_only_in_output_operation_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         ::aws_smithy_http_server::protocol::content_type_header_classifier_smithy(&headers, None)?;
         input.build()
     })
-26
+}
-27
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_constrained_shapes_only_in_output_operation_http_response(
     #[allow(unused_variables)] output: crate::output::ConstrainedShapesOnlyInOutputOperationOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         let mut builder = ::http_1x::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             ::http_1x::header::CONTENT_TYPE,
             "application/json",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload =
             crate::protocol_serde::shape_constrained_shapes_only_in_output_operation_output::ser_constrained_shapes_only_in_output_operation_output_output_output(&output)?
-47
+        ;
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             ::http_1x::header::CONTENT_LENGTH,
             content_length,
         );
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         builder.body(body)?
     })
-57
+}

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

@@ -1,1 +121,124 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_constrained_shapes_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::ConstrainedShapesOperationInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::constrained_shapes_operation_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         let bytes = ::hyper::body::to_bytes(body).await?;
         let bytes = {
             use ::http_body_util::BodyExt;
             body.collect().await?.to_bytes()
         };
         if !bytes.is_empty() {
             ::aws_smithy_http_server::protocol::content_type_header_classifier_smithy(
                 &headers,
                 Some("application/json"),
             )?;
             input = crate::protocol_serde::shape_constrained_shapes_operation::de_constrained_shapes_operation(bytes.as_ref(), input)?;
-32
+        }
         input.build()?
     })
-35
+}
-36
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_constrained_shapes_operation_http_response(
     #[allow(unused_variables)] output: crate::output::ConstrainedShapesOperationOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         let mut builder = ::http_1x::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             ::http_1x::header::CONTENT_TYPE,
             "application/json",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload =
             crate::protocol_serde::shape_constrained_shapes_operation_output::ser_constrained_shapes_operation_output_output_output(&output)?
-56
+        ;
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             ::http_1x::header::CONTENT_LENGTH,
             content_length,
         );
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         builder.body(body)?
     })
-66
+}
-67
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_constrained_shapes_operation_http_error(
     error: &crate::error::ConstrainedShapesOperationError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::ConstrainedShapesOperationError::ValidationException(output) => {
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 let mut builder = ::http_1x::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     ::http_1x::header::CONTENT_TYPE,
                     "application/json",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
                     "ValidationException",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     ::http_1x::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
-100
+            }
-101
+        }
     })
-103
+}
-104

↧ Expand context

 pub(crate) fn de_constrained_shapes_operation(
     value: &[u8],
     mut builder: crate::input::constrained_shapes_operation_input::Builder,
 ) -> ::std::result::Result<
     crate::input::constrained_shapes_operation_input::Builder,
     ::aws_smithy_json::deserialize::error::DeserializeError,
 > {
     let mut tokens_owned =
         ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(value))
             .peekable();
     let tokens = &mut tokens_owned;
     ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
     loop {
         match tokens.next().transpose()? {
             Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
             Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
                 match key.to_unescaped()?.as_ref() {
                     "conA" => {
                         if let Some(v) = crate::protocol_serde::shape_con_a::de_con_a(tokens)? {
                             builder = builder.set_con_a(v);

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

@@ -1,1 +137,141 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_event_streams_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::EventStreamsOperationInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: Into<::aws_smithy_types::byte_stream::ByteStream>,
     B: ::http_body_1x::Body<Data = ::bytes::Bytes>
         + ::std::marker::Send
         + ::std::marker::Sync
         + 'static,
     B::Error: Into<::aws_smithy_types::body::Error> + 'static,
-+
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-20
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::event_streams_operation_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) = {
             let mut receiver =
                 crate::protocol_serde::shape_event_streams_operation_input::de_events_payload(
                     &mut body.into().into_inner(),
                     &mut ::aws_smithy_types::body::SdkBody::from_body_1_x(body),
                 )?;
             if let Some(_initial_event) = receiver
                                                 .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
                                                 .await
                                                 .map_err(
                                                     |ev_error| ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::ConstraintViolation(
                                                         #[allow(clippy::useless_conversion)]
                                                         format!("{ev_error}").into()
-40
+                                                    )
                                                 )? {
-42
-43
+                                            }
             Some(receiver)
         } {
             input = input.set_events(value)
-47
+        }
         input.build()?
     })
-50
+}
-51
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_event_streams_operation_http_response(
     #[allow(unused_variables)] output: crate::output::EventStreamsOperationOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         let mut builder = ::http_1x::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             ::http_1x::header::CONTENT_TYPE,
             "application/vnd.amazon.eventstream",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let body = ::aws_smithy_http_server::body::boxed(
             ::aws_smithy_http_server::body::Body::wrap_stream({
         let body =
             ::aws_smithy_http_server::body::boxed(::aws_smithy_http_server::body::wrap_stream({
                 let error_marshaller = crate::event_stream_serde::EventErrorMarshaller::new();
                 let marshaller = crate::event_stream_serde::EventMarshaller::new();
                 let signer = ::aws_smithy_eventstream::frame::NoOpSigner {};
                 output
                     .events
                     .into_body_stream(marshaller, error_marshaller, signer)
             }),
         );
             }));
         builder.body(body)?
     })
-80
+}
-81
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_event_streams_operation_http_error(
     error: &crate::error::EventStreamsOperationError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::EventStreamsOperationError::ValidationException(output) => {
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 let mut builder = ::http_1x::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     ::http_1x::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
                     "ValidationException",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     ::http_1x::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
-114
+            }
             crate::error::EventStreamsOperationError::EventStreamErrorMessage(output) => {
                 let payload = crate::protocol_serde::shape_event_stream_error_message::ser_event_stream_error_message_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 let mut builder = ::http_1x::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     ::http_1x::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
                     "EventStreamErrorMessage",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     ::http_1x::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(500)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
-138
+            }
-139
+        }
     })
-141
+}

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

@@ -1,1 +125,127 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_http_prefix_headers_targeting_length_map_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::HttpPrefixHeadersTargetingLengthMapOperationInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::http_prefix_headers_targeting_length_map_operation_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) = crate::protocol_serde::shape_http_prefix_headers_targeting_length_map_operation_input::de_length_map_prefix_header(&headers)? {
                                 input = input.set_length_map(Some(value))
-24
+                            }
         input.build()?
     })
-27
+}
-28
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_http_prefix_headers_targeting_length_map_operation_http_response(
     #[allow(unused_variables)]
     output: crate::output::HttpPrefixHeadersTargetingLengthMapOperationOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         let mut builder = ::http_1x::Response::builder();
         builder = crate::protocol_serde::shape_http_prefix_headers_targeting_length_map_operation::ser_http_prefix_headers_targeting_length_map_operation_headers(&output, builder)?;
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             ::http_1x::header::CONTENT_TYPE,
             "application/json",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload =
             crate::protocol_serde::shape_http_prefix_headers_targeting_length_map_operation_output::ser_http_prefix_headers_targeting_length_map_operation_output_output_output(&output)?
-50
+        ;
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             ::http_1x::header::CONTENT_LENGTH,
             content_length,
         );
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         builder.body(body)?
     })
-60
+}
-61
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_http_prefix_headers_targeting_length_map_operation_http_error(
     error: &crate::error::HttpPrefixHeadersTargetingLengthMapOperationError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::HttpPrefixHeadersTargetingLengthMapOperationError::ValidationException(output) => {
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 let mut builder = ::http_1x::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                                 builder,
                                 ::http::header::CONTENT_TYPE,
                                 ::http_1x::header::CONTENT_TYPE,
                                 "application/json",
                             );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                                 builder,
                                 ::http::header::HeaderName::from_static("x-amzn-errortype"),
                                 ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
                                 "ValidationException",
                             );
                 let content_length = payload.len();
                             builder = ::aws_smithy_http::header::set_response_header_if_absent(builder, ::http::header::CONTENT_LENGTH, content_length);
                             builder = ::aws_smithy_http::header::set_response_header_if_absent(builder, ::http_1x::header::CONTENT_LENGTH, content_length);
                 builder.status(400).body(::aws_smithy_http_server::body::to_boxed(payload))?
-88
+            }
-89
+        }
     })
-91
+}
-92
 pub fn ser_http_prefix_headers_targeting_length_map_operation_headers(
     input: &crate::output::HttpPrefixHeadersTargetingLengthMapOperationOutput,
     mut builder: ::http::response::Builder,
 ) -> std::result::Result<::http::response::Builder, ::aws_smithy_types::error::operation::BuildError>
--
+{
     mut builder: ::http_1x::response::Builder,
 ) -> std::result::Result<
     ::http_1x::response::Builder,
     ::aws_smithy_types::error::operation::BuildError,
 > {
     if let ::std::option::Option::Some(inner_1) = &input.length_map {
-101
+        {
             let inner_1 = &inner_1.0;
             for (k, v) in inner_1 {
                 use std::str::FromStr;
                 let header_name = http::header::HeaderName::from_str(&format!(
                 let header_name = ::http_1x::HeaderName::from_str(&format!(
                     "{}{}",
                     "X-Prefix-Headers-LengthMap-", &k
                 ))
                 .map_err(|err| {
                     ::aws_smithy_types::error::operation::BuildError::invalid_field(
                         "length_map",
                         format!("`{k}` cannot be used as a header name: {err}"),
-113
+                    )
                 })?;
                 let header_value = v.as_str();
                 let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
                 let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
                     ::aws_smithy_types::error::operation::BuildError::invalid_field(
                         "length_map",
                         format!("`{v}` cannot be used as a header value: {err}"),
-120
+                    )
                 })?;
                 builder = builder.header(header_name, header_value);
-123
+            }
-124
+        }
-125
+    }
     Ok(builder)

↧ Expand context

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

@@ -1,1 +57,60 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_non_streaming_blob_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::NonStreamingBlobOperationInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::non_streaming_blob_operation_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) = {
             let bytes = ::hyper::body::to_bytes(body).await?;
             let bytes = {
                 use ::http_body_util::BodyExt;
                 body.collect().await?.to_bytes()
             };
-27
             crate::protocol_serde::shape_non_streaming_blob_operation_input::de_non_streaming_blob_payload(&bytes)?
         } {
             input = input.set_non_streaming_blob(Some(value))
-31
+        }
         input.build()
     })
-34
+}
-35
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_non_streaming_blob_operation_http_response(
     #[allow(unused_variables)] output: crate::output::NonStreamingBlobOperationOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         let mut builder = ::http_1x::Response::builder();
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload =
             crate::protocol_serde::shape_non_streaming_blob_operation_output::ser_non_streaming_blob_http_payload( output.non_streaming_blob)?
-50
+        ;
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             ::http_1x::header::CONTENT_LENGTH,
             content_length,
         );
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         builder.body(body)?
     })
-60
+}

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

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

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_query_params_targeting_length_map_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::QueryParamsTargetingLengthMapOperationInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input =
             crate::input::query_params_targeting_length_map_operation_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         let query_string = uri.query().unwrap_or("");
         let pairs = ::form_urlencoded::parse(query_string.as_bytes());
         let mut query_params: crate::unconstrained::con_b_map_unconstrained::ConBMapUnconstrained =
             crate::unconstrained::con_b_map_unconstrained::ConBMapUnconstrained(
                 ::std::collections::HashMap::new(),
             );
         for (k, v) in pairs {
             query_params
                 .0
                 .entry(String::from(k))
                 .or_insert_with(|| String::from(v));
-34
+        }
         input = input.set_length_map(Some(query_params));
         input.build()?
     })
-38
+}
-39
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_query_params_targeting_length_map_operation_http_response(
     #[allow(unused_variables)] output: crate::output::QueryParamsTargetingLengthMapOperationOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         let mut builder = ::http_1x::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             ::http_1x::header::CONTENT_TYPE,
             "application/json",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload =
             crate::protocol_serde::shape_query_params_targeting_length_map_operation_output::ser_query_params_targeting_length_map_operation_output_output_output(&output)?
-59
+        ;
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             ::http_1x::header::CONTENT_LENGTH,
             content_length,
         );
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         builder.body(body)?
     })
-69
+}
-70
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_query_params_targeting_length_map_operation_http_error(
     error: &crate::error::QueryParamsTargetingLengthMapOperationError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::QueryParamsTargetingLengthMapOperationError::ValidationException(
                 output,
             ) => {
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 let mut builder = ::http_1x::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     ::http_1x::header::CONTENT_TYPE,
                     "application/json",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
                     "ValidationException",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     ::http_1x::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
-105
+            }
-106
+        }
     })
-108
+}

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

@@ -1,1 +101,101 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_query_params_targeting_map_of_enum_string_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::QueryParamsTargetingMapOfEnumStringOperationInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::query_params_targeting_map_of_enum_string_operation_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         let query_string = uri.query().unwrap_or("");
         let pairs = ::form_urlencoded::parse(query_string.as_bytes());
         let mut query_params: crate::unconstrained::map_of_enum_string_unconstrained::MapOfEnumStringUnconstrained =
             crate::unconstrained::map_of_enum_string_unconstrained::MapOfEnumStringUnconstrained(
                 ::std::collections::HashMap::new()
-27
+            )
-28
+        ;
         for (k, v) in pairs {
             query_params
                 .0
                 .entry(String::from(k))
                 .or_insert_with(|| String::from(v));
-34
+        }
         input = input.set_map_of_enum_string(Some(query_params));
         input.build()?
     })
-38
+}
-39
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_query_params_targeting_map_of_enum_string_operation_http_response(
     #[allow(unused_variables)]
     output: crate::output::QueryParamsTargetingMapOfEnumStringOperationOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         let mut builder = ::http_1x::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             ::http_1x::header::CONTENT_TYPE,
             "application/json",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload =
             crate::protocol_serde::shape_query_params_targeting_map_of_enum_string_operation_output::ser_query_params_targeting_map_of_enum_string_operation_output_output_output(&output)?
-60
+        ;
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             ::http_1x::header::CONTENT_LENGTH,
             content_length,
         );
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         builder.body(body)?
     })
-70
+}
-71
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_query_params_targeting_map_of_enum_string_operation_http_error(
     error: &crate::error::QueryParamsTargetingMapOfEnumStringOperationError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::QueryParamsTargetingMapOfEnumStringOperationError::ValidationException(output) => {
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 let mut builder = ::http_1x::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                                 builder,
                                 ::http::header::CONTENT_TYPE,
                                 ::http_1x::header::CONTENT_TYPE,
                                 "application/json",
                             );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                                 builder,
                                 ::http::header::HeaderName::from_static("x-amzn-errortype"),
                                 ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
                                 "ValidationException",
                             );
                 let content_length = payload.len();
                             builder = ::aws_smithy_http::header::set_response_header_if_absent(builder, ::http::header::CONTENT_LENGTH, content_length);
                             builder = ::aws_smithy_http::header::set_response_header_if_absent(builder, ::http_1x::header::CONTENT_LENGTH, content_length);
                 builder.status(400).body(::aws_smithy_http_server::body::to_boxed(payload))?
-98
+            }
-99
+        }
     })
-101
+}

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

@@ -1,1 +101,101 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_query_params_targeting_map_of_length_list_of_pattern_string_operation_http_request<
     B,
 >(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::QueryParamsTargetingMapOfLengthListOfPatternStringOperationInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-10
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-16
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::query_params_targeting_map_of_length_list_of_pattern_string_operation_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         let query_string = uri.query().unwrap_or("");
         let pairs = ::form_urlencoded::parse(query_string.as_bytes());
         let mut query_params: crate::unconstrained::map_of_length_list_of_pattern_string_unconstrained::MapOfLengthListOfPatternStringUnconstrained =
             crate::unconstrained::map_of_length_list_of_pattern_string_unconstrained::MapOfLengthListOfPatternStringUnconstrained(
                 ::std::collections::HashMap::new()
-29
+            )
-30
+        ;
         for (k, v) in pairs {
             let entry = query_params.0.entry(String::from(k)).or_insert_with(|| crate::unconstrained::length_list_of_pattern_string_unconstrained::LengthListOfPatternStringUnconstrained(std::vec::Vec::new()));
             entry.0.push(String::from(v));
-34
+        }
         input = input.set_map_of_length_list_of_pattern_string(Some(query_params));
         input.build()?
     })
-38
+}
-39
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_query_params_targeting_map_of_length_list_of_pattern_string_operation_http_response(
     #[allow(unused_variables)]
     output: crate::output::QueryParamsTargetingMapOfLengthListOfPatternStringOperationOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         let mut builder = ::http_1x::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             ::http_1x::header::CONTENT_TYPE,
             "application/json",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload =
             crate::protocol_serde::shape_query_params_targeting_map_of_length_list_of_pattern_string_operation_output::ser_query_params_targeting_map_of_length_list_of_pattern_string_operation_output_output_output(&output)?
-60
+        ;
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             ::http_1x::header::CONTENT_LENGTH,
             content_length,
         );
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         builder.body(body)?
     })
-70
+}
-71
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_query_params_targeting_map_of_length_list_of_pattern_string_operation_http_error(
     error: &crate::error::QueryParamsTargetingMapOfLengthListOfPatternStringOperationError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::QueryParamsTargetingMapOfLengthListOfPatternStringOperationError::ValidationException(output) => {
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 let mut builder = ::http_1x::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                                 builder,
                                 ::http::header::CONTENT_TYPE,
                                 ::http_1x::header::CONTENT_TYPE,
                                 "application/json",
                             );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                                 builder,
                                 ::http::header::HeaderName::from_static("x-amzn-errortype"),
                                 ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
                                 "ValidationException",
                             );
                 let content_length = payload.len();
                             builder = ::aws_smithy_http::header::set_response_header_if_absent(builder, ::http::header::CONTENT_LENGTH, content_length);
                             builder = ::aws_smithy_http::header::set_response_header_if_absent(builder, ::http_1x::header::CONTENT_LENGTH, content_length);
                 builder.status(400).body(::aws_smithy_http_server::body::to_boxed(payload))?
-98
+            }
-99
+        }
     })
-101
+}

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

@@ -1,1 +101,101 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_query_params_targeting_map_of_length_pattern_string_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::QueryParamsTargetingMapOfLengthPatternStringOperationInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::query_params_targeting_map_of_length_pattern_string_operation_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         let query_string = uri.query().unwrap_or("");
         let pairs = ::form_urlencoded::parse(query_string.as_bytes());
         let mut query_params: crate::unconstrained::map_of_length_pattern_string_unconstrained::MapOfLengthPatternStringUnconstrained =
             crate::unconstrained::map_of_length_pattern_string_unconstrained::MapOfLengthPatternStringUnconstrained(
                 ::std::collections::HashMap::new()
-27
+            )
-28
+        ;
         for (k, v) in pairs {
             query_params
                 .0
                 .entry(String::from(k))
                 .or_insert_with(|| String::from(v));
-34
+        }
         input = input.set_map_of_length_pattern_string(Some(query_params));
         input.build()?
     })
-38
+}
-39
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_query_params_targeting_map_of_length_pattern_string_operation_http_response(
     #[allow(unused_variables)]
     output: crate::output::QueryParamsTargetingMapOfLengthPatternStringOperationOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         let mut builder = ::http_1x::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             ::http_1x::header::CONTENT_TYPE,
             "application/json",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload =
             crate::protocol_serde::shape_query_params_targeting_map_of_length_pattern_string_operation_output::ser_query_params_targeting_map_of_length_pattern_string_operation_output_output_output(&output)?
-60
+        ;
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             ::http_1x::header::CONTENT_LENGTH,
             content_length,
         );
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         builder.body(body)?
     })
-70
+}
-71
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_query_params_targeting_map_of_length_pattern_string_operation_http_error(
     error: &crate::error::QueryParamsTargetingMapOfLengthPatternStringOperationError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::QueryParamsTargetingMapOfLengthPatternStringOperationError::ValidationException(output) => {
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 let mut builder = ::http_1x::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                                 builder,
                                 ::http::header::CONTENT_TYPE,
                                 ::http_1x::header::CONTENT_TYPE,
                                 "application/json",
                             );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                                 builder,
                                 ::http::header::HeaderName::from_static("x-amzn-errortype"),
                                 ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
                                 "ValidationException",
                             );
                 let content_length = payload.len();
                             builder = ::aws_smithy_http::header::set_response_header_if_absent(builder, ::http::header::CONTENT_LENGTH, content_length);
                             builder = ::aws_smithy_http::header::set_response_header_if_absent(builder, ::http_1x::header::CONTENT_LENGTH, content_length);
                 builder.status(400).body(::aws_smithy_http_server::body::to_boxed(payload))?
-98
+            }
-99
+        }
     })
-101
+}

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

@@ -1,1 +101,101 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_query_params_targeting_map_of_length_string_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::QueryParamsTargetingMapOfLengthStringOperationInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::query_params_targeting_map_of_length_string_operation_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         let query_string = uri.query().unwrap_or("");
         let pairs = ::form_urlencoded::parse(query_string.as_bytes());
         let mut query_params: crate::unconstrained::map_of_length_string_unconstrained::MapOfLengthStringUnconstrained =
             crate::unconstrained::map_of_length_string_unconstrained::MapOfLengthStringUnconstrained(
                 ::std::collections::HashMap::new()
-27
+            )
-28
+        ;
         for (k, v) in pairs {
             query_params
                 .0
                 .entry(String::from(k))
                 .or_insert_with(|| String::from(v));
-34
+        }
         input = input.set_map_of_length_string(Some(query_params));
         input.build()?
     })
-38
+}
-39
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_query_params_targeting_map_of_length_string_operation_http_response(
     #[allow(unused_variables)]
     output: crate::output::QueryParamsTargetingMapOfLengthStringOperationOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         let mut builder = ::http_1x::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             ::http_1x::header::CONTENT_TYPE,
             "application/json",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload =
             crate::protocol_serde::shape_query_params_targeting_map_of_length_string_operation_output::ser_query_params_targeting_map_of_length_string_operation_output_output_output(&output)?
-60
+        ;
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             ::http_1x::header::CONTENT_LENGTH,
             content_length,
         );
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         builder.body(body)?
     })
-70
+}
-71
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_query_params_targeting_map_of_length_string_operation_http_error(
     error: &crate::error::QueryParamsTargetingMapOfLengthStringOperationError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::QueryParamsTargetingMapOfLengthStringOperationError::ValidationException(output) => {
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 let mut builder = ::http_1x::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                                 builder,
                                 ::http::header::CONTENT_TYPE,
                                 ::http_1x::header::CONTENT_TYPE,
                                 "application/json",
                             );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                                 builder,
                                 ::http::header::HeaderName::from_static("x-amzn-errortype"),
                                 ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
                                 "ValidationException",
                             );
                 let content_length = payload.len();
                             builder = ::aws_smithy_http::header::set_response_header_if_absent(builder, ::http::header::CONTENT_LENGTH, content_length);
                             builder = ::aws_smithy_http::header::set_response_header_if_absent(builder, ::http_1x::header::CONTENT_LENGTH, content_length);
                 builder.status(400).body(::aws_smithy_http_server::body::to_boxed(payload))?
-98
+            }
-99
+        }
     })
-101
+}

Pages: 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207