Server Test

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

@@ -21,21 +130,133 @@

 #![cfg_attr(docsrs, feature(doc_cfg))]
 //! A service to test miscellaneous aspects of code generation where protocol
 //! selection is not relevant. If you want to test something protocol-specific,
 //! add it to a separate `[protocol]-extras.smithy`.
-25
 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 //! A fast and customizable Rust implementation of the MiscService Smithy service.
 //!
 //! # Using MiscService
 //!
 //! The primary entrypoint is [`MiscService`]: 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 [`MiscService::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 misc::{MiscService, MiscServiceConfig};
 //! use misc::serve;
 //! use ::tokio::net::TcpListener;
 //!
 //! # let app = MiscService::builder(
 //! #     MiscServiceConfig::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 misc::server::routing::LambdaHandler;
 //! use misc::MiscService;
 //!
 //! # async fn dummy() {
 //! # let app = MiscService::builder(
 //! #     MiscServiceConfig::builder()
 //! #         .build()
 //! # ).build_unchecked();
 //! let handler = LambdaHandler::new(app);
 //! lambda_http::run(handler).await.unwrap();
 //! # }
 //! ```
 //!
 //! # Building the MiscService
 //!
 //! To construct [`MiscService`] we use [`MiscServiceBuilder`] returned by [`MiscService::builder`].
 //!
 //! ## Plugins
 //!
 //! The [`MiscService::builder`] method, returning [`MiscServiceBuilder`],
 //! 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 misc::server::plugin::IdentityPlugin as LoggingPlugin;
 //! # use misc::server::plugin::IdentityPlugin as MetricsPlugin;
 //! # use ::hyper::Body;
 //! # use ::hyper::body::Incoming;
 //! use misc::server::plugin::HttpPlugins;
 //! use misc::{MiscService, MiscServiceConfig, MiscServiceBuilder};
 //!
 //! let http_plugins = HttpPlugins::new()
 //!         .push(LoggingPlugin)
 //!         .push(MetricsPlugin);
 //! let config = MiscServiceConfig::builder().build();
 //! let builder: MiscServiceBuilder<Body, _, _, _> = MiscService::builder(config);
 //! let builder: MiscServiceBuilder<::hyper::body::Incoming, _, _, _> = MiscService::builder(config);
 //! ```
 //!
 //! Check out [`crate::server::plugin`] to learn more about plugins.
 //!
 //! ## Handlers
 //!
 //! [`MiscServiceBuilder`] 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;

@@ -137,140 +255,262 @@

↥ 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 [`MiscServiceBuilder`] into [`MiscService`] using either [`MiscServiceBuilder::build`] or [`MiscServiceBuilder::build_unchecked`].
 //!

 //! [`MiscServiceBuilder::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.
 //!
 //! [`MiscServiceBuilder::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.
 //! [`MiscServiceBuilder::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 misc::{MiscService, MiscServiceConfig};
 //! use misc::serve;
 //! use ::tokio::net::TcpListener;
 //!
 //! #[::tokio::main]
 //! pub async fn main() {
 //!    let config = MiscServiceConfig::builder().build();
 //!    let app = MiscService::builder(config)
 //!        .required_header_collection_operation(required_header_collection_operation)
 //!        .required_inner_shape_operation(required_inner_shape_operation)
 //!        .response_code_default_operation(response_code_default_operation)
 //!        .response_code_http_fallback_operation(response_code_http_fallback_operation)
 //!        .response_code_required_operation(response_code_required_operation)
 //!        .type_complexity_operation(type_complexity_operation)
 //!        .build()
 //!        .expect("failed to build an instance of MiscService");
 //!
 //!    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 misc::{input, output, error};
 //!
 //! async fn required_header_collection_operation(input: input::RequiredHeaderCollectionOperationInput) -> Result<output::RequiredHeaderCollectionOperationOutput, error::RequiredHeaderCollectionOperationError> {
 //!     todo!()
 //! }
 //!
 //! async fn required_inner_shape_operation(input: input::RequiredInnerShapeOperationInput) -> Result<output::RequiredInnerShapeOperationOutput, error::RequiredInnerShapeOperationError> {
 //!     todo!()
 //! }
 //!
 //! async fn response_code_default_operation(input: input::ResponseCodeDefaultOperationInput) -> output::ResponseCodeDefaultOperationOutput {
 //!     todo!()
 //! }
 //!
 //! async fn response_code_http_fallback_operation(input: input::ResponseCodeHttpFallbackOperationInput) -> output::ResponseCodeHttpFallbackOperationOutput {
 //!     todo!()
 //! }
 //!
 //! async fn response_code_required_operation(input: input::ResponseCodeRequiredOperationInput) -> output::ResponseCodeRequiredOperationOutput {
 //!     todo!()
 //! }
 //!
 //! async fn type_complexity_operation(input: input::TypeComplexityOperationInput) -> output::TypeComplexityOperationOutput {
 //!     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::{
     MiscService, MiscServiceBuilder, MiscServiceConfig, MiscServiceConfigBuilder,
     MissingOperationsError,
 };
-237
 /// 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::*;
-242
+}

↧ Expand context

-243
 /// Crate version number.
 pub static PKG_VERSION: &str = env!("CARGO_PKG_VERSION");
-246
 /// All error types that operations can return. Documentation on these types is copied from the model.
 pub mod error;
-249
 /// Input structures for operations. Documentation on these types is copied from the model.
 pub mod input;
-252
 /// Data structures used by operation inputs/outputs. Documentation on these types is copied from the model.
 pub mod model;
-255
 /// All operations that this crate can perform.
 pub mod operation;
-258
 /// A collection of types representing each operation defined in the service closure.
 ///
 /// The [plugin system](::aws_smithy_http_server::plugin) makes use of these
 /// [zero-sized types](https://doc.rust-lang.org/nomicon/exotic-sizes.html#zero-sized-types-zsts) (ZSTs) to

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

@@ -11,11 +375,375 @@

↥ Expand context

     type Output = Result<
         crate::input::ResponseCodeDefaultOperationInput,
         ::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::ResponseCodeDefaultOperationInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-33
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-37
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = ResponseCodeDefaultOperationInputFuture;
-40
     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);
-48
+            }
             crate::protocol_serde::shape_response_code_default_operation::de_response_code_default_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,
-58
+                )
             },
         );
         ResponseCodeDefaultOperationInputFuture {
             inner: Box::pin(fut),
-63
+        }
-64
+    }
-65
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::ResponseCodeDefaultOperationOutput
-70
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_response_code_default_operation::ser_response_code_default_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))
-77
+                        }
-78
+                    }
-79
+    }
-80
+}
-81
 #[allow(unreachable_code, unused_variables)]
 #[cfg(test)]
 mod response_code_default_operation_test {
-85
     /// Test ID: ResponseCodeDefaultOperation
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn response_code_default_operation_response() {
         let output = crate::output::ResponseCodeDefaultOperationOutput {};
         use ::aws_smithy_http_server::response::IntoResponse;
         let http_response = output.into_response();
         ::pretty_assertions::assert_eq!(
             http::StatusCode::from_u16(200).expect("invalid expected HTTP status code"),
             ::http_1x::StatusCode::from_u16(200).expect("invalid expected HTTP status code"),
             http_response.status()
         );
-97
+    }
-98
+}
-99
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`ResponseCodeHttpFallbackOperationInput`](crate::input::ResponseCodeHttpFallbackOperationInput) using modelled bindings.
     pub struct ResponseCodeHttpFallbackOperationInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ResponseCodeHttpFallbackOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-105
+    }
-106
+}
-107
 impl std::future::Future for ResponseCodeHttpFallbackOperationInputFuture {
     type Output = Result<
         crate::input::ResponseCodeHttpFallbackOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-113
     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)
-120
+    }
-121
+}
-122
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::ResponseCodeHttpFallbackOperationInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-131
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-135
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = ResponseCodeHttpFallbackOperationInputFuture;
-138
     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);
-146
+            }
             crate::protocol_serde::shape_response_code_http_fallback_operation::de_response_code_http_fallback_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,
-156
+                )
             },
         );
         ResponseCodeHttpFallbackOperationInputFuture {
             inner: Box::pin(fut),
-161
+        }
-162
+    }
-163
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::ResponseCodeHttpFallbackOperationOutput
-168
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_response_code_http_fallback_operation::ser_response_code_http_fallback_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))
-175
+                        }
-176
+                    }
-177
+    }
-178
+}
-179
 #[allow(unreachable_code, unused_variables)]
 #[cfg(test)]
 mod response_code_http_fallback_operation_test {
-183
     /// Test ID: ResponseCodeHttpFallbackOperation
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn response_code_http_fallback_operation_response() {
         let output = crate::output::ResponseCodeHttpFallbackOperationOutput {};
         use ::aws_smithy_http_server::response::IntoResponse;
         let http_response = output.into_response();
         ::pretty_assertions::assert_eq!(
             http::StatusCode::from_u16(201).expect("invalid expected HTTP status code"),
             ::http_1x::StatusCode::from_u16(201).expect("invalid expected HTTP status code"),
             http_response.status()
         );
         let expected_headers = [("Content-Length", "2")];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
             http_response.headers(),
             expected_headers,
         ));
-200
+    }
-201
+}
-202
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`ResponseCodeRequiredOperationInput`](crate::input::ResponseCodeRequiredOperationInput) using modelled bindings.
     pub struct ResponseCodeRequiredOperationInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ResponseCodeRequiredOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-208
+    }
-209
+}
-210
 impl std::future::Future for ResponseCodeRequiredOperationInputFuture {
     type Output = Result<
         crate::input::ResponseCodeRequiredOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-216
     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)
-223
+    }
-224
+}
-225
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::ResponseCodeRequiredOperationInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-234
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-238
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = ResponseCodeRequiredOperationInputFuture;
-241
     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);
-249
+            }
             crate::protocol_serde::shape_response_code_required_operation::de_response_code_required_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,
-259
+                )
             },
         );
         ResponseCodeRequiredOperationInputFuture {
             inner: Box::pin(fut),
-264
+        }
-265
+    }
-266
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::ResponseCodeRequiredOperationOutput
-271
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_response_code_required_operation::ser_response_code_required_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))
-278
+                        }
-279
+                    }
-280
+    }
-281
+}
-282
 #[allow(unreachable_code, unused_variables)]
 #[cfg(test)]
 mod response_code_required_operation_test {
-286
     /// Test ID: ResponseCodeRequiredOperation
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn response_code_required_operation_response() {
         let output = crate::output::ResponseCodeRequiredOperationOutput { response_code: 201 };
         use ::aws_smithy_http_server::response::IntoResponse;
         let http_response = output.into_response();
         ::pretty_assertions::assert_eq!(
             http::StatusCode::from_u16(201).expect("invalid expected HTTP status code"),
             ::http_1x::StatusCode::from_u16(201).expect("invalid expected HTTP status code"),
             http_response.status()
         );
         let expected_headers = [("Content-Length", "2")];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
             http_response.headers(),
             expected_headers,
         ));
-303
+    }
-304
+}
-305
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`RequiredHeaderCollectionOperationInput`](crate::input::RequiredHeaderCollectionOperationInput) using modelled bindings.
     pub struct RequiredHeaderCollectionOperationInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::RequiredHeaderCollectionOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-311
+    }
-312
+}
-313
 impl std::future::Future for RequiredHeaderCollectionOperationInputFuture {
     type Output = Result<
         crate::input::RequiredHeaderCollectionOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-319
     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)
-326
+    }
-327
+}
-328
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::RequiredHeaderCollectionOperationInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-337
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-341
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = RequiredHeaderCollectionOperationInputFuture;
-344
     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);
-352
+            }
             crate::protocol_serde::shape_required_header_collection_operation::de_required_header_collection_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,
-362
+                )
             },
         );
         RequiredHeaderCollectionOperationInputFuture {
             inner: Box::pin(fut),
-367
+        }
-368
+    }
-369
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::RequiredHeaderCollectionOperationOutput
-374
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

@@ -413,413 +473,473 @@

↥ Expand context

     type Output = Result<
         crate::input::RequiredInnerShapeOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-417
     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)
-424
+    }
-425
+}
-426
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::RequiredInnerShapeOperationInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-435
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-439
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = RequiredInnerShapeOperationInputFuture;
-442
     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);
-450
+            }
             crate::protocol_serde::shape_required_inner_shape_operation::de_required_inner_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,
-460
+                )
             },
         );
         RequiredInnerShapeOperationInputFuture {
             inner: Box::pin(fut),
-465
+        }
-466
+    }
-467
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::RequiredInnerShapeOperationOutput
-472
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

@@ -511,511 +571,571 @@

↥ Expand context

     type Output = Result<
         crate::input::TypeComplexityOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-515
     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)
-522
+    }
-523
+}
-524
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::TypeComplexityOperationInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-533
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-537
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = TypeComplexityOperationInputFuture;
-540
     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);
-548
+            }
             crate::protocol_serde::shape_type_complexity_operation::de_type_complexity_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,
-558
+                )
             },
         );
         TypeComplexityOperationInputFuture {
             inner: Box::pin(fut),
-563
+        }
-564
+    }
-565
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::TypeComplexityOperationOutput
-570
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

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

@@ -1,1 +140,142 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_required_header_collection_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::RequiredHeaderCollectionOperationInput,
     ::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::required_header_collection_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_required_header_collection_operation_input::de_required_header_list_header(&headers)? {
                                 input = input.set_required_header_list(value)
-25
+                            }
         if let Some(value) = crate::protocol_serde::shape_required_header_collection_operation_input::de_required_header_set_header(&headers)? {
                                 input = input.set_required_header_set(value)
-28
+                            }
         input.build()?
     })
-31
+}
-32
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_required_header_collection_operation_http_response(
     #[allow(unused_variables)] output: crate::output::RequiredHeaderCollectionOperationOutput,
 ) -> 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_required_header_collection_operation::ser_required_header_collection_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_required_header_collection_operation_output::ser_required_header_collection_operation_output_output_output(&output)?
-53
+        ;
         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)?
     })
-63
+}
-64
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_required_header_collection_operation_http_error(
     error: &crate::error::RequiredHeaderCollectionOperationError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::RequiredHeaderCollectionOperationError::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))?
-97
+            }
-98
+        }
     })
-100
+}
-101
 pub fn ser_required_header_collection_operation_headers(
     input: &crate::output::RequiredHeaderCollectionOperationOutput,
     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,
 > {
     for inner_1 in &input.required_header_list {
         let formatted_2 = ::aws_smithy_http::header::quote_header_value(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(
                     "required_header_list",
                     format!(
                         "`{}` cannot be used as a header value: {}",
                         &header_value, err
                     ),
-120
+                )
             })?;
             builder = builder.header("X-Required-List", header_value);
-123
+        }
-124
+    }
     for inner_3 in &input.required_header_set.0 {
         let formatted_4 = ::aws_smithy_http::header::quote_header_value(inner_3.as_str());
         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(
                     "required_header_set",
                     format!(
                         "`{}` cannot be used as a header value: {}",
                         &header_value, err
                     ),
-136
+                )
             })?;
             builder = builder.header("X-Required-Set", header_value);
-139
+        }

↧ Expand context

tmp-codegen-diff/codegen-server-test/misc/rust-server-codegen/src/protocol_serde/shape_required_inner_shape_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_required_inner_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::RequiredInnerShapeOperationInput,
     ::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::required_inner_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();
         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_required_inner_shape_operation::de_required_inner_shape_operation(bytes.as_ref(), input)?;
-32
+        }
         input.build()?
     })
-35
+}
-36
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_required_inner_shape_operation_http_response(
     #[allow(unused_variables)] output: crate::output::RequiredInnerShapeOperationOutput,
 ) -> 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_required_inner_shape_operation_output::ser_required_inner_shape_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_required_inner_shape_operation_http_error(
     error: &crate::error::RequiredInnerShapeOperationError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::RequiredInnerShapeOperationError::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_required_inner_shape_operation(
     value: &[u8],
     mut builder: crate::input::required_inner_shape_operation_input::Builder,
 ) -> ::std::result::Result<
     crate::input::required_inner_shape_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() {
                     "inner" => {
                         builder = builder.set_inner(
                             crate::protocol_serde::shape_inner_shape::de_inner_shape(tokens)?,

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

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

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_response_code_default_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::ResponseCodeDefaultOperationInput,
     ::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::response_code_default_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();
         input.build()
     })
-24
+}
-25
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_response_code_default_operation_http_response(
     #[allow(unused_variables)] output: crate::output::ResponseCodeDefaultOperationOutput,
 ) -> 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_response_code_default_operation_output::ser_response_code_default_operation_output_output_output(&output)?
-45
+        ;
         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)?
     })
-55
+}

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

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

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_response_code_http_fallback_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::ResponseCodeHttpFallbackOperationInput,
     ::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::response_code_http_fallback_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();
         input.build()
     })
-25
+}
-26
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_response_code_http_fallback_operation_http_response(
     #[allow(unused_variables)] output: crate::output::ResponseCodeHttpFallbackOperationOutput,
 ) -> 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 = 201;
         builder = builder.status(http_status);
         let payload =
             crate::protocol_serde::shape_response_code_http_fallback_operation_output::ser_response_code_http_fallback_operation_output_output_output(&output)?
-46
+        ;
         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)?
     })
-56
+}

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

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

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_response_code_required_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::ResponseCodeRequiredOperationInput,
     ::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::response_code_required_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();
         input.build()
     })
-24
+}
-25
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_response_code_required_operation_http_response(
     #[allow(unused_variables)] output: crate::output::ResponseCodeRequiredOperationOutput,
 ) -> 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 status = output.response_code;
         let http_status: u16 = status.try_into().map_err(::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection::InvalidHttpStatusCode)?;
         builder = builder.status(http_status);
         let payload =
             crate::protocol_serde::shape_response_code_required_operation_output::ser_response_code_required_operation_output_output_output(&output)?
-46
+        ;
         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)?
     })
-56
+}

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

@@ -1,1 +87,90 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_type_complexity_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::TypeComplexityOperationInput,
     ::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::type_complexity_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_type_complexity_operation::de_type_complexity_operation(bytes.as_ref(), input)?;
-32
+        }
         input.build()
     })
-35
+}
-36
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_type_complexity_operation_http_response(
     #[allow(unused_variables)] output: crate::output::TypeComplexityOperationOutput,
 ) -> 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_type_complexity_operation_output::ser_type_complexity_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
 pub(crate) fn de_type_complexity_operation(
     value: &[u8],
     mut builder: crate::input::type_complexity_operation_input::Builder,

↧ Expand context

 ) -> ::std::result::Result<
     crate::input::type_complexity_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() {
                     "list" => {
                         builder = builder
                             .set_list(crate::protocol_serde::shape_list_a::de_list_a(tokens)?);
-88
+                    }
                     _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
-90
+                }

tmp-codegen-diff/codegen-server-test/misc/rust-server-codegen/src/service.rs

@@ -40,40 +101,101 @@

↥ Expand context

     /// # let app: MiscService<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn required_header_collection_operation<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::RequiredHeaderCollectionOperation, HandlerExtractors>,
-46
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::RequiredHeaderCollectionOperation,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::RequiredHeaderCollectionOperation, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::RequiredHeaderCollectionOperation,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::RequiredHeaderCollectionOperation,

-60
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     MiscService<L>,
                                     crate::operation_shape::RequiredHeaderCollectionOperation,
                                     ModelPl::Output
-66
+                                >
                             >::Output
                         >,
-69
                         HttpPl::Output: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
                         HttpPl::Output: ::tower::Service<::http_1x::Request<Body>, Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http_1x::Request<Body>>>::Future: Send + 'static,
-72
-73
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::RequiredHeaderCollectionOperation::from_handler(handler);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
             .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.required_header_collection_operation_custom(svc)

↧ Expand context

-82
+    }
-83
     /// Sets the [`RequiredHeaderCollectionOperation`](crate::operation_shape::RequiredHeaderCollectionOperation) operation.
     ///
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use misc::{MiscService, MiscServiceConfig};
     ///
     /// use misc::{input, output, error};
     ///
     /// async fn handler(input: input::RequiredHeaderCollectionOperationInput) -> Result<output::RequiredHeaderCollectionOperationOutput, error::RequiredHeaderCollectionOperationError> {
     ///     todo!()
     /// }
     ///
     /// let config = MiscServiceConfig::builder().build();
     /// let svc = ::tower::util::service_fn(handler);

@@ -107,107 +187,187 @@

↥ Expand context

     /// # let app: MiscService<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn required_header_collection_operation_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::RequiredHeaderCollectionOperation, ServiceExtractors>,
-113
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::RequiredHeaderCollectionOperation,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::RequiredHeaderCollectionOperation, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::RequiredHeaderCollectionOperation,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::RequiredHeaderCollectionOperation,

-127
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     MiscService<L>,
                                     crate::operation_shape::RequiredHeaderCollectionOperation,
                                     ModelPl::Output
-133
+                                >
                             >::Output
                         >,
-136
                         HttpPl::Output: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
                         HttpPl::Output: ::tower::Service<::http_1x::Request<Body>, Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http_1x::Request<Body>>>::Future: Send + 'static,
-139
-140
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::RequiredHeaderCollectionOperation::from_service(service);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
             .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.required_header_collection_operation_custom(svc)
-149
+    }
-150
     /// Sets the [`RequiredHeaderCollectionOperation`](crate::operation_shape::RequiredHeaderCollectionOperation) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn required_header_collection_operation_custom<S>(mut self, svc: S) -> Self
     where
         S: ::tower::Service<
                 ::http::Request<Body>,
                 Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>,
                 ::http_1x::Request<Body>,
                 Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>,
                 Error = ::std::convert::Infallible,
             > + Clone
             + Send
             + 'static,
         S::Future: Send + 'static,
-163
+    {
         self.required_header_collection_operation =
             Some(::aws_smithy_http_server::routing::Route::new(svc));
         self
-167
+    }

↧ Expand context

-168
     /// Sets the [`RequiredInnerShapeOperation`](crate::operation_shape::RequiredInnerShapeOperation) operation.
     ///
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use misc::{MiscService, MiscServiceConfig};
     ///
     /// use misc::{input, output, error};
     ///
     /// async fn handler(input: input::RequiredInnerShapeOperationInput) -> Result<output::RequiredInnerShapeOperationOutput, error::RequiredInnerShapeOperationError> {
     ///     todo!()
     /// }
     ///
     /// let config = MiscServiceConfig::builder().build();
     /// let app = MiscService::builder(config)
     ///     .required_inner_shape_operation(handler)

@@ -191,191 +252,252 @@

↥ Expand context

     /// # let app: MiscService<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn required_inner_shape_operation<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::RequiredInnerShapeOperation, HandlerExtractors>,
-197
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::RequiredInnerShapeOperation,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::RequiredInnerShapeOperation, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::RequiredInnerShapeOperation,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::RequiredInnerShapeOperation,

-211
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     MiscService<L>,
                                     crate::operation_shape::RequiredInnerShapeOperation,
                                     ModelPl::Output
-217
+                                >
                             >::Output
                         >,
-220
                         HttpPl::Output: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
                         HttpPl::Output: ::tower::Service<::http_1x::Request<Body>, Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http_1x::Request<Body>>>::Future: Send + 'static,
-223
-224
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::RequiredInnerShapeOperation::from_handler(handler);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
             .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.required_inner_shape_operation_custom(svc)

↧ Expand context

-233
+    }
-234
     /// Sets the [`RequiredInnerShapeOperation`](crate::operation_shape::RequiredInnerShapeOperation) operation.
     ///
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use misc::{MiscService, MiscServiceConfig};
     ///
     /// use misc::{input, output, error};
     ///
     /// async fn handler(input: input::RequiredInnerShapeOperationInput) -> Result<output::RequiredInnerShapeOperationOutput, error::RequiredInnerShapeOperationError> {
     ///     todo!()
     /// }
     ///
     /// let config = MiscServiceConfig::builder().build();
     /// let svc = ::tower::util::service_fn(handler);

@@ -258,258 +338,338 @@

↥ Expand context

     /// # let app: MiscService<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn required_inner_shape_operation_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::RequiredInnerShapeOperation, ServiceExtractors>,
-264
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::RequiredInnerShapeOperation,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::RequiredInnerShapeOperation, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::RequiredInnerShapeOperation,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::RequiredInnerShapeOperation,

-278
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     MiscService<L>,
                                     crate::operation_shape::RequiredInnerShapeOperation,
                                     ModelPl::Output
-284
+                                >
                             >::Output
                         >,
-287
                         HttpPl::Output: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
                         HttpPl::Output: ::tower::Service<::http_1x::Request<Body>, Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http_1x::Request<Body>>>::Future: Send + 'static,
-290
-291
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::RequiredInnerShapeOperation::from_service(service);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
             .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.required_inner_shape_operation_custom(svc)
-300
+    }
-301
     /// Sets the [`RequiredInnerShapeOperation`](crate::operation_shape::RequiredInnerShapeOperation) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn required_inner_shape_operation_custom<S>(mut self, svc: S) -> Self
     where
         S: ::tower::Service<
                 ::http::Request<Body>,
                 Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>,
                 ::http_1x::Request<Body>,
                 Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>,
                 Error = ::std::convert::Infallible,
             > + Clone
             + Send
             + 'static,
         S::Future: Send + 'static,
-314
+    {
         self.required_inner_shape_operation =
             Some(::aws_smithy_http_server::routing::Route::new(svc));
         self
-318
+    }

↧ Expand context

-319
     /// Sets the [`ResponseCodeDefaultOperation`](crate::operation_shape::ResponseCodeDefaultOperation) operation.
     ///
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use misc::{MiscService, MiscServiceConfig};
     ///
     /// use misc::{input, output, error};
     ///
     /// async fn handler(input: input::ResponseCodeDefaultOperationInput) -> output::ResponseCodeDefaultOperationOutput {
     ///     todo!()
     /// }
     ///
     /// let config = MiscServiceConfig::builder().build();
     /// let app = MiscService::builder(config)
     ///     .response_code_default_operation(handler)

@@ -342,342 +403,403 @@

↥ Expand context

     /// # let app: MiscService<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn response_code_default_operation<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::ResponseCodeDefaultOperation, HandlerExtractors>,
-348
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::ResponseCodeDefaultOperation,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::ResponseCodeDefaultOperation, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::ResponseCodeDefaultOperation,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::ResponseCodeDefaultOperation,

-362
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     MiscService<L>,
                                     crate::operation_shape::ResponseCodeDefaultOperation,
                                     ModelPl::Output
-368
+                                >
                             >::Output
                         >,
-371
                         HttpPl::Output: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
                         HttpPl::Output: ::tower::Service<::http_1x::Request<Body>, Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http_1x::Request<Body>>>::Future: Send + 'static,
-374
-375
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::ResponseCodeDefaultOperation::from_handler(handler);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
             .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.response_code_default_operation_custom(svc)

↧ Expand context

-384
+    }
-385
     /// Sets the [`ResponseCodeDefaultOperation`](crate::operation_shape::ResponseCodeDefaultOperation) operation.
     ///
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use misc::{MiscService, MiscServiceConfig};
     ///
     /// use misc::{input, output, error};
     ///
     /// async fn handler(input: input::ResponseCodeDefaultOperationInput) -> Result<output::ResponseCodeDefaultOperationOutput, std::convert::Infallible> {
     ///     todo!()
     /// }
     ///
     /// let config = MiscServiceConfig::builder().build();
     /// let svc = ::tower::util::service_fn(handler);

@@ -409,409 +489,489 @@

↥ Expand context

     /// # let app: MiscService<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn response_code_default_operation_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::ResponseCodeDefaultOperation, ServiceExtractors>,
-415
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::ResponseCodeDefaultOperation,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::ResponseCodeDefaultOperation, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::ResponseCodeDefaultOperation,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::ResponseCodeDefaultOperation,

-429
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     MiscService<L>,
                                     crate::operation_shape::ResponseCodeDefaultOperation,
                                     ModelPl::Output
-435
+                                >
                             >::Output
                         >,
-438
                         HttpPl::Output: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
                         HttpPl::Output: ::tower::Service<::http_1x::Request<Body>, Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http_1x::Request<Body>>>::Future: Send + 'static,
-441
-442
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::ResponseCodeDefaultOperation::from_service(service);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
             .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.response_code_default_operation_custom(svc)
-451
+    }
-452
     /// Sets the [`ResponseCodeDefaultOperation`](crate::operation_shape::ResponseCodeDefaultOperation) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn response_code_default_operation_custom<S>(mut self, svc: S) -> Self
     where
         S: ::tower::Service<
                 ::http::Request<Body>,
                 Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>,
                 ::http_1x::Request<Body>,
                 Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>,
                 Error = ::std::convert::Infallible,
             > + Clone
             + Send
             + 'static,
         S::Future: Send + 'static,
-465
+    {
         self.response_code_default_operation =
             Some(::aws_smithy_http_server::routing::Route::new(svc));
         self
-469
+    }

↧ Expand context

-470
     /// Sets the [`ResponseCodeHttpFallbackOperation`](crate::operation_shape::ResponseCodeHttpFallbackOperation) operation.
     ///
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use misc::{MiscService, MiscServiceConfig};
     ///
     /// use misc::{input, output, error};
     ///
     /// async fn handler(input: input::ResponseCodeHttpFallbackOperationInput) -> output::ResponseCodeHttpFallbackOperationOutput {
     ///     todo!()
     /// }
     ///
     /// let config = MiscServiceConfig::builder().build();
     /// let app = MiscService::builder(config)
     ///     .response_code_http_fallback_operation(handler)

@@ -493,493 +554,554 @@

↥ Expand context

     /// # let app: MiscService<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn response_code_http_fallback_operation<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::ResponseCodeHttpFallbackOperation, HandlerExtractors>,
-499
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::ResponseCodeHttpFallbackOperation,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::ResponseCodeHttpFallbackOperation, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::ResponseCodeHttpFallbackOperation,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::ResponseCodeHttpFallbackOperation,

-513
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     MiscService<L>,
                                     crate::operation_shape::ResponseCodeHttpFallbackOperation,
                                     ModelPl::Output
-519
+                                >
                             >::Output
                         >,
-522
                         HttpPl::Output: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
                         HttpPl::Output: ::tower::Service<::http_1x::Request<Body>, Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http_1x::Request<Body>>>::Future: Send + 'static,
-525
-526
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::ResponseCodeHttpFallbackOperation::from_handler(handler);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
             .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.response_code_http_fallback_operation_custom(svc)

↧ Expand context

-535
+    }
-536
     /// Sets the [`ResponseCodeHttpFallbackOperation`](crate::operation_shape::ResponseCodeHttpFallbackOperation) operation.
     ///
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use misc::{MiscService, MiscServiceConfig};
     ///
     /// use misc::{input, output, error};
     ///
     /// async fn handler(input: input::ResponseCodeHttpFallbackOperationInput) -> Result<output::ResponseCodeHttpFallbackOperationOutput, std::convert::Infallible> {
     ///     todo!()
     /// }
     ///
     /// let config = MiscServiceConfig::builder().build();
     /// let svc = ::tower::util::service_fn(handler);

@@ -560,560 +640,640 @@

↥ Expand context

     /// # let app: MiscService<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn response_code_http_fallback_operation_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::ResponseCodeHttpFallbackOperation, ServiceExtractors>,
-566
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::ResponseCodeHttpFallbackOperation,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::ResponseCodeHttpFallbackOperation, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::ResponseCodeHttpFallbackOperation,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::ResponseCodeHttpFallbackOperation,

-580
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     MiscService<L>,
                                     crate::operation_shape::ResponseCodeHttpFallbackOperation,
                                     ModelPl::Output
-586
+                                >
                             >::Output
                         >,
-589
                         HttpPl::Output: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
                         HttpPl::Output: ::tower::Service<::http_1x::Request<Body>, Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http_1x::Request<Body>>>::Future: Send + 'static,
-592
-593
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::ResponseCodeHttpFallbackOperation::from_service(service);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
             .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.response_code_http_fallback_operation_custom(svc)
-602
+    }
-603
     /// Sets the [`ResponseCodeHttpFallbackOperation`](crate::operation_shape::ResponseCodeHttpFallbackOperation) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn response_code_http_fallback_operation_custom<S>(mut self, svc: S) -> Self
     where
         S: ::tower::Service<
                 ::http::Request<Body>,
                 Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>,
                 ::http_1x::Request<Body>,
                 Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>,
                 Error = ::std::convert::Infallible,
             > + Clone
             + Send
             + 'static,
         S::Future: Send + 'static,
-616
+    {
         self.response_code_http_fallback_operation =
             Some(::aws_smithy_http_server::routing::Route::new(svc));
         self
-620
+    }

↧ Expand context

-621
     /// Sets the [`ResponseCodeRequiredOperation`](crate::operation_shape::ResponseCodeRequiredOperation) operation.
     ///
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use misc::{MiscService, MiscServiceConfig};
     ///
     /// use misc::{input, output, error};
     ///
     /// async fn handler(input: input::ResponseCodeRequiredOperationInput) -> output::ResponseCodeRequiredOperationOutput {
     ///     todo!()
     /// }
     ///
     /// let config = MiscServiceConfig::builder().build();
     /// let app = MiscService::builder(config)
     ///     .response_code_required_operation(handler)

@@ -644,644 +705,705 @@

↥ Expand context

     /// # let app: MiscService<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn response_code_required_operation<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::ResponseCodeRequiredOperation, HandlerExtractors>,
-650
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::ResponseCodeRequiredOperation,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::ResponseCodeRequiredOperation, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::ResponseCodeRequiredOperation,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::ResponseCodeRequiredOperation,

-664
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     MiscService<L>,
                                     crate::operation_shape::ResponseCodeRequiredOperation,
                                     ModelPl::Output
-670
+                                >
                             >::Output
                         >,
-673
                         HttpPl::Output: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
                         HttpPl::Output: ::tower::Service<::http_1x::Request<Body>, Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http_1x::Request<Body>>>::Future: Send + 'static,
-676
-677
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::ResponseCodeRequiredOperation::from_handler(handler);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
             .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.response_code_required_operation_custom(svc)

↧ Expand context

-686
+    }
-687
     /// Sets the [`ResponseCodeRequiredOperation`](crate::operation_shape::ResponseCodeRequiredOperation) operation.
     ///
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use misc::{MiscService, MiscServiceConfig};
     ///
     /// use misc::{input, output, error};
     ///
     /// async fn handler(input: input::ResponseCodeRequiredOperationInput) -> Result<output::ResponseCodeRequiredOperationOutput, std::convert::Infallible> {
     ///     todo!()
     /// }
     ///
     /// let config = MiscServiceConfig::builder().build();
     /// let svc = ::tower::util::service_fn(handler);

@@ -711,711 +791,791 @@

↥ Expand context

     /// # let app: MiscService<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn response_code_required_operation_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::ResponseCodeRequiredOperation, ServiceExtractors>,
-717
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::ResponseCodeRequiredOperation,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::ResponseCodeRequiredOperation, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::ResponseCodeRequiredOperation,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::ResponseCodeRequiredOperation,

-731
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     MiscService<L>,
                                     crate::operation_shape::ResponseCodeRequiredOperation,
                                     ModelPl::Output
-737
+                                >
                             >::Output
                         >,
-740
                         HttpPl::Output: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
                         HttpPl::Output: ::tower::Service<::http_1x::Request<Body>, Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http_1x::Request<Body>>>::Future: Send + 'static,
-743
-744
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::ResponseCodeRequiredOperation::from_service(service);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
             .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.response_code_required_operation_custom(svc)
-753
+    }
-754
     /// Sets the [`ResponseCodeRequiredOperation`](crate::operation_shape::ResponseCodeRequiredOperation) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn response_code_required_operation_custom<S>(mut self, svc: S) -> Self
     where
         S: ::tower::Service<
                 ::http::Request<Body>,
                 Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>,
                 ::http_1x::Request<Body>,
                 Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>,
                 Error = ::std::convert::Infallible,
             > + Clone
             + Send
             + 'static,
         S::Future: Send + 'static,
-767
+    {
         self.response_code_required_operation =
             Some(::aws_smithy_http_server::routing::Route::new(svc));
         self
-771
+    }

↧ Expand context

-772
     /// Sets the [`TypeComplexityOperation`](crate::operation_shape::TypeComplexityOperation) operation.
     ///
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use misc::{MiscService, MiscServiceConfig};
     ///
     /// use misc::{input, output, error};
     ///
     /// async fn handler(input: input::TypeComplexityOperationInput) -> output::TypeComplexityOperationOutput {
     ///     todo!()
     /// }
     ///
     /// let config = MiscServiceConfig::builder().build();
     /// let app = MiscService::builder(config)
     ///     .type_complexity_operation(handler)

@@ -795,795 +856,856 @@

↥ Expand context

     /// # let app: MiscService<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn type_complexity_operation<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::TypeComplexityOperation, HandlerExtractors>,
-801
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::TypeComplexityOperation,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::TypeComplexityOperation, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::TypeComplexityOperation,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::TypeComplexityOperation,

-815
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     MiscService<L>,
                                     crate::operation_shape::TypeComplexityOperation,
                                     ModelPl::Output
-821
+                                >
                             >::Output
                         >,
-824
                         HttpPl::Output: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
                         HttpPl::Output: ::tower::Service<::http_1x::Request<Body>, Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http_1x::Request<Body>>>::Future: Send + 'static,
-827
-828
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::TypeComplexityOperation::from_handler(handler);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
             .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.type_complexity_operation_custom(svc)

↧ Expand context

-837
+    }
-838
     /// Sets the [`TypeComplexityOperation`](crate::operation_shape::TypeComplexityOperation) operation.
     ///
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use misc::{MiscService, MiscServiceConfig};
     ///
     /// use misc::{input, output, error};
     ///
     /// async fn handler(input: input::TypeComplexityOperationInput) -> Result<output::TypeComplexityOperationOutput, std::convert::Infallible> {
     ///     todo!()
     /// }
     ///
     /// let config = MiscServiceConfig::builder().build();
     /// let svc = ::tower::util::service_fn(handler);

@@ -862,862 +942,942 @@

↥ Expand context

     /// # let app: MiscService<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn type_complexity_operation_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::TypeComplexityOperation, ServiceExtractors>,
-868
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::TypeComplexityOperation,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::TypeComplexityOperation, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::TypeComplexityOperation,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             MiscService<L>,
                             crate::operation_shape::TypeComplexityOperation,

-882
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     MiscService<L>,
                                     crate::operation_shape::TypeComplexityOperation,
                                     ModelPl::Output
-888
+                                >
                             >::Output
                         >,
-891
                         HttpPl::Output: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
                         HttpPl::Output: ::tower::Service<::http_1x::Request<Body>, Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http_1x::Request<Body>>>::Future: Send + 'static,
-894
-895
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::TypeComplexityOperation::from_service(service);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
             .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.type_complexity_operation_custom(svc)
-904
+    }
-905
     /// Sets the [`TypeComplexityOperation`](crate::operation_shape::TypeComplexityOperation) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn type_complexity_operation_custom<S>(mut self, svc: S) -> Self
     where
         S: ::tower::Service<
                 ::http::Request<Body>,
                 Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>,
                 ::http_1x::Request<Body>,
                 Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>,
                 Error = ::std::convert::Infallible,
             > + Clone
             + Send
             + 'static,
         S::Future: Send + 'static,
-918
+    {
         self.type_complexity_operation = Some(::aws_smithy_http_server::routing::Route::new(svc));
         self
-921
+    }
-922
+}

↧ Expand context

-923
 impl<Body, L, HttpPl, ModelPl> MiscServiceBuilder<Body, L, HttpPl, ModelPl> {
     /// Constructs a [`MiscService`] from the arguments provided to the builder.
     ///
     /// Forgetting to register a handler for one or more operations will result in an error.
     ///
     /// Check out [`MiscServiceBuilder::build_unchecked`] if you'd prefer the service to return status code 500 when an
     /// unspecified route is requested.
     pub fn build(
         self,
     ) -> ::std::result::Result<
         MiscService<
             ::aws_smithy_http_server::routing::RoutingService<
                 ::aws_smithy_http_server::protocol::rest::router::RestRouter<L::Service>,
                 ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
             >,
         >,
         MissingOperationsError,
-941
+    >
     where

@@ -1118,1118 +1253,1253 @@

↥ Expand context

-1118
+}
-1119
 impl std::fmt::Display for MissingOperationsError {
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
         write!(
             f,
             "You must specify a handler for all operations attached to `MiscService`.\n\
                             We are missing handlers for the following operations:\n",
         )?;
         for operation_name in self.operation_names2setter_methods.keys() {
             writeln!(f, "- {}", operation_name.absolute())?;
-1129
+        }
-1130
         writeln!(
             f,
             "\nUse the dedicated methods on `MiscServiceBuilder` to register the missing handlers:"
         )?;
         for setter_name in self.operation_names2setter_methods.values() {
             writeln!(f, "- {}", setter_name)?;
-1137
+        }

         Ok(())
-1139
+    }
-1140
+}
-1141
 impl std::error::Error for MissingOperationsError {}
-1143
 mod request_specs {
     pub(super) fn required_header_collection_operation(
     ) -> ::aws_smithy_http_server::routing::request_spec::RequestSpec {
         ::aws_smithy_http_server::routing::request_spec::RequestSpec::new(
                     ::http::Method::GET,
                     ::http_1x::Method::GET,
                     ::aws_smithy_http_server::routing::request_spec::UriSpec::new(
                         ::aws_smithy_http_server::routing::request_spec::PathAndQuerySpec::new(
                             ::aws_smithy_http_server::routing::request_spec::PathSpec::from_vector_unchecked(vec![
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Literal(String::from("required-header-collection-operation")),
 ]),
                             ::aws_smithy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
 ])
-1156
+                        )
                     ),
-1158
+                )
-1159
+    }
     pub(super) fn required_inner_shape_operation(
     ) -> ::aws_smithy_http_server::routing::request_spec::RequestSpec {
         ::aws_smithy_http_server::routing::request_spec::RequestSpec::new(
                     ::http::Method::POST,
                     ::http_1x::Method::POST,
                     ::aws_smithy_http_server::routing::request_spec::UriSpec::new(
                         ::aws_smithy_http_server::routing::request_spec::PathAndQuerySpec::new(
                             ::aws_smithy_http_server::routing::request_spec::PathSpec::from_vector_unchecked(vec![
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Literal(String::from("requiredInnerShapeOperation")),
 ]),
                             ::aws_smithy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
 ])
-1171
+                        )
                     ),
-1173
+                )
-1174
+    }
     pub(super) fn response_code_default_operation(
     ) -> ::aws_smithy_http_server::routing::request_spec::RequestSpec {
         ::aws_smithy_http_server::routing::request_spec::RequestSpec::new(
                     ::http::Method::GET,
                     ::http_1x::Method::GET,
                     ::aws_smithy_http_server::routing::request_spec::UriSpec::new(
                         ::aws_smithy_http_server::routing::request_spec::PathAndQuerySpec::new(
                             ::aws_smithy_http_server::routing::request_spec::PathSpec::from_vector_unchecked(vec![
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Literal(String::from("responseCodeDefaultOperation")),
 ]),
                             ::aws_smithy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
 ])
-1186
+                        )
                     ),
-1188
+                )
-1189
+    }
     pub(super) fn response_code_http_fallback_operation(
     ) -> ::aws_smithy_http_server::routing::request_spec::RequestSpec {
         ::aws_smithy_http_server::routing::request_spec::RequestSpec::new(
                     ::http::Method::GET,
                     ::http_1x::Method::GET,
                     ::aws_smithy_http_server::routing::request_spec::UriSpec::new(
                         ::aws_smithy_http_server::routing::request_spec::PathAndQuerySpec::new(
                             ::aws_smithy_http_server::routing::request_spec::PathSpec::from_vector_unchecked(vec![
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Literal(String::from("responseCodeHttpFallbackOperation")),
 ]),
                             ::aws_smithy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
 ])
-1201
+                        )
                     ),
-1203
+                )
-1204
+    }
     pub(super) fn response_code_required_operation(
     ) -> ::aws_smithy_http_server::routing::request_spec::RequestSpec {
         ::aws_smithy_http_server::routing::request_spec::RequestSpec::new(
                     ::http::Method::GET,
                     ::http_1x::Method::GET,
                     ::aws_smithy_http_server::routing::request_spec::UriSpec::new(
                         ::aws_smithy_http_server::routing::request_spec::PathAndQuerySpec::new(
                             ::aws_smithy_http_server::routing::request_spec::PathSpec::from_vector_unchecked(vec![
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Literal(String::from("responseCodeRequiredOperation")),
 ]),
                             ::aws_smithy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
 ])
-1216
+                        )
                     ),
-1218
+                )
-1219
+    }
     pub(super) fn type_complexity_operation(
     ) -> ::aws_smithy_http_server::routing::request_spec::RequestSpec {
         ::aws_smithy_http_server::routing::request_spec::RequestSpec::new(
                     ::http::Method::POST,
                     ::http_1x::Method::POST,
                     ::aws_smithy_http_server::routing::request_spec::UriSpec::new(
                         ::aws_smithy_http_server::routing::request_spec::PathAndQuerySpec::new(
                             ::aws_smithy_http_server::routing::request_spec::PathSpec::from_vector_unchecked(vec![
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Literal(String::from("typeComplexityOperation")),
 ]),
                             ::aws_smithy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
 ])
-1231
+                        )
                     ),
-1233
+                )

↧ Expand context

-1234
+    }
-1235
+}
-1236
 /// A service to test miscellaneous aspects of code generation where protocol selection is not relevant. If you want to test something protocol-specific, add it to a separate `\[protocol\]-extras.smithy`.
 ///
 /// See the [root](crate) documentation for more information.
 #[derive(Clone)]
 pub struct MiscService<
     S = ::aws_smithy_http_server::routing::RoutingService<
         ::aws_smithy_http_server::protocol::rest::router::RestRouter<
             ::aws_smithy_http_server::routing::Route<::aws_smithy_http_server::body::BoxBody>,
         >,
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     >,
 > {
     // This is the router wrapped by layers.
     svc: S,
-1251
+}
-1252
 impl MiscService<()> {

@@ -1360,1360 +1421,1421 @@

↥ Expand context

         layer: &L,
     ) -> MiscService<
         ::aws_smithy_http_server::routing::RoutingService<
             ::aws_smithy_http_server::protocol::rest::router::RestRouter<L::Service>,
             ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         >,
-1366
+    >
     where
         L: ::tower::Layer<S>,
-1369
+    {
         MiscService {
             svc: self.svc.map(|s| s.layer(layer)),
-1372
+        }
-1373
+    }
-1374
     /// Applies [`Route::new`](::aws_smithy_http_server::routing::Route::new) to all routes.
     ///
     /// This has the effect of erasing all types accumulated via layers.
     pub fn boxed<B>(
         self,

     ) -> MiscService<
         ::aws_smithy_http_server::routing::RoutingService<
             ::aws_smithy_http_server::protocol::rest::router::RestRouter<
                 ::aws_smithy_http_server::routing::Route<B>,
             >,
             ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         >,
-1387
+    >
     where
         S: ::tower::Service<
             ::http::Request<B>,
             Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>,
             ::http_1x::Request<B>,
             Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>,
             Error = std::convert::Infallible,
         >,
         S: Clone + Send + 'static,
         S::Future: Send + 'static,
-1396
+    {
         self.layer(&::tower::layer::layer_fn(
             ::aws_smithy_http_server::routing::Route::new,
         ))
-1400
+    }
-1401
+}

↧ Expand context

-1402
 impl<S, R> ::tower::Service<R> for MiscService<S>
 where
     S: ::tower::Service<R>,
-1406
+{
     type Response = S::Response;
     type Error = S::Error;
     type Future = S::Future;
-1410
     fn poll_ready(
         &mut self,
         cx: &mut std::task::Context,
     ) -> std::task::Poll<::std::result::Result<(), Self::Error>> {
         self.svc.poll_ready(cx)
-1416
+    }
-1417
     fn call(&mut self, request: R) -> Self::Future {
         self.svc.call(request)
-1420
+    }
-1421
+}

 # Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 [package]
 name = "misc"
 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-http]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-http"
 [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.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-util]
 version = "0.1.3"
 [dependencies.mime]
 version = "0.3"
 [dependencies.pin-project-lite]
 version = "0.2"
 [dependencies.tower]
 version = "0.4"
 [dependencies.tracing]
 version = "0.1"
 [dev-dependencies.aws-smithy-protocol-test]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-protocol-test"
 [dev-dependencies.hyper]
 version = "0.14.12"
 version = "1"
 [dev-dependencies.pretty_assertions]
 version = "1.3.0"
 [dev-dependencies.tokio]
 version = "1.23.1"
 features = ["macros", "test-util", "rt-multi-thread"]
 [dev-dependencies.tracing-test]
 version = "0.2.5"
 features = ["no-env-filter"]
 [features]
 rt-tokio = ["aws-smithy-types/rt-tokio"]

 aws-lambda = ["aws-smithy-http-server/aws-lambda"]
 request-id = ["aws-smithy-http-server/request-id"]
 default = ["rt-tokio", "request-id"]
-56
-57

138 140	`}`
139 141	`Ok(builder)`
140 142	`}`

Server Test

Files changed:

tmp-codegen-diff/codegen-server-test/misc-http0x/rust-server-codegen/src/types.rs

tmp-codegen-diff/codegen-server-test/misc-http0x/rust-server-codegen/src/unconstrained.rs

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

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

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

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

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

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

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

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

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

tmp-codegen-diff/codegen-server-test/misc/rust-server-codegen/src/service.rs

tmp-codegen-diff/codegen-server-test/naming_test_casing-http0x/rust-server-codegen/Cargo.toml

tmp-codegen-diff/codegen-server-test/naming_test_casing-http0x/rust-server-codegen/src/constrained.rs

tmp-codegen-diff/codegen-server-test/naming_test_casing-http0x/rust-server-codegen/src/error.rs

tmp-codegen-diff/codegen-server-test/naming_test_casing-http0x/rust-server-codegen/src/input.rs

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub use ::aws_smithy_types::date_time::Format as DateTimeFormat;
 pub use ::aws_smithy_types::error::display::DisplayErrorContext;
 pub use ::aws_smithy_types::Blob;
 pub use ::aws_smithy_types::DateTime;

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
-+
 pub(crate) mod header_set_unconstrained {
-+
     #[derive(Debug, Clone)]
     pub(crate) struct HeaderSetUnconstrained(pub(crate) std::vec::Vec<::std::string::String>);
-+
     impl From<HeaderSetUnconstrained>
         for crate::constrained::MaybeConstrained<crate::model::HeaderSet>
-+
+    {
         fn from(value: HeaderSetUnconstrained) -> Self {
             Self::Unconstrained(value)
-+
+        }
-+
+    }
     impl std::convert::TryFrom<HeaderSetUnconstrained> for crate::model::HeaderSet {
         type Error = crate::model::header_set::ConstraintViolation;
         fn try_from(value: HeaderSetUnconstrained) -> std::result::Result<Self, Self::Error> {
             let inner = value.0;
             Self::try_from(inner)
-+
+        }
-+
+    }
-+
+}

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /*
  * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
  * SPDX-License-Identifier: Apache-2.0
  */
-+
 pub(crate) trait Constrained {
     type Unconstrained;
-+
+}
-+
 #[derive(Debug, Clone)]
 #[allow(dead_code)]
 pub(crate) enum MaybeConstrained<T: Constrained> {
     Constrained(T),
     Unconstrained(T::Unconstrained),
-+
+}

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(missing_docs)] // documentation missing in model
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct DoNothingInput {}
 impl DoNothingInput {
     /// Creates a new builder-style object to manufacture [`DoNothingInput`](crate::input::DoNothingInput).
     pub fn builder() -> crate::input::do_nothing_input::Builder {
         crate::input::do_nothing_input::Builder::default()
-+
+    }
-+
+}
 impl crate::constrained::Constrained for crate::input::DoNothingInput {
     type Unconstrained = crate::input::do_nothing_input::Builder;
-+
+}
 /// See [`DoNothingInput`](crate::input::DoNothingInput).
 pub mod do_nothing_input {
-+
     impl ::std::convert::From<Builder> for crate::input::DoNothingInput {
         fn from(builder: Builder) -> Self {
             builder.build()
-+
+        }
-+
+    }
     /// A builder for [`DoNothingInput`](crate::input::DoNothingInput).
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {}
     impl Builder {
         /// Consumes the builder and constructs a [`DoNothingInput`](crate::input::DoNothingInput).
         pub fn build(self) -> crate::input::DoNothingInput {
             self.build_enforcing_all_constraints()
-+
+        }
         fn build_enforcing_all_constraints(self) -> crate::input::DoNothingInput {
             crate::input::DoNothingInput {}
-+
+        }
-+
+    }
-+
+}