Server Test

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

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

 #![allow(rustdoc::invalid_html_tags)]
 #![forbid(unsafe_code)]
 #![cfg_attr(docsrs, feature(doc_cfg))]
 //! Confounds model generation machinery with lots of problematic names
-23
 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 //! A fast and customizable Rust implementation of the Config Smithy service.
 //!
 //! # Using Config
 //!
 //! The primary entrypoint is [`Config`]: 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 [`Config::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 naming_test_ops::{Config, ConfigConfig};
 //! use naming_test_ops::serve;
 //! use ::tokio::net::TcpListener;
 //!
 //! # let app = Config::builder(
 //! #     ConfigConfig::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 naming_test_ops::server::routing::LambdaHandler;
 //! use naming_test_ops::Config;
 //!
 //! # async fn dummy() {
 //! # let app = Config::builder(
 //! #     ConfigConfig::builder()
 //! #         .build()
 //! # ).build_unchecked();
 //! let handler = LambdaHandler::new(app);
 //! lambda_http::run(handler).await.unwrap();
 //! # }
 //! ```
 //!
 //! # Building the Config
 //!
 //! To construct [`Config`] we use [`ConfigBuilder`] returned by [`Config::builder`].
 //!
 //! ## Plugins
 //!
 //! The [`Config::builder`] method, returning [`ConfigBuilder`],
 //! 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 naming_test_ops::server::plugin::IdentityPlugin as LoggingPlugin;
 //! # use naming_test_ops::server::plugin::IdentityPlugin as MetricsPlugin;
 //! # use ::hyper::Body;
 //! # use ::hyper::body::Incoming;
 //! use naming_test_ops::server::plugin::HttpPlugins;
 //! use naming_test_ops::{Config, ConfigConfig, ConfigBuilder};
 //!
 //! let http_plugins = HttpPlugins::new()
 //!         .push(LoggingPlugin)
 //!         .push(MetricsPlugin);
 //! let config = ConfigConfig::builder().build();
 //! let builder: ConfigBuilder<Body, _, _, _> = Config::builder(config);
 //! let builder: ConfigBuilder<::hyper::body::Incoming, _, _, _> = Config::builder(config);
 //! ```
 //!
 //! Check out [`crate::server::plugin`] to learn more about plugins.
 //!
 //! ## Handlers
 //!
 //! [`ConfigBuilder`] provides a setter method for each operation in your Smithy model. The setter methods expect an async function as input, matching the signature for the corresponding operation in your Smithy model.
 //! We call these async functions **handlers**. This is where your application business logic lives.
 //!
 //! Every handler must take an `Input`, and optional [`extractor arguments`](crate::server::request), while returning:

↧ Expand context

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

@@ -135,138 +258,265 @@

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

 //! [`ConfigBuilder::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.
 //!
 //! [`ConfigBuilder::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.
 //! [`ConfigBuilder::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 naming_test_ops::{Config, ConfigConfig};
 //! use naming_test_ops::serve;
 //! use ::tokio::net::TcpListener;
 //!
 //! #[::tokio::main]
 //! pub async fn main() {
 //!    let config = ConfigConfig::builder().build();
 //!    let app = Config::builder(config)
 //!        .err_collisions(err_collisions)
 //!        .r#match(r#match)
 //!        .option(option)
 //!        .reserved_words_as_members(reserved_words_as_members)
 //!        .result(result)
 //!        .rpc_echo(rpc_echo)
 //!        .structure_name_punning(structure_name_punning)
 //!        .build()
 //!        .expect("failed to build an instance of Config");
 //!
 //!    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 naming_test_ops::{input, output, error};
 //!
 //! async fn err_collisions(input: input::ErrCollisionsInput) -> Result<output::ErrCollisionsOutput, error::ErrCollisionsError> {
 //!     todo!()
 //! }
 //!
 //! async fn r#match(input: input::MatchInput) -> Result<output::MatchOutput, error::MatchError> {
 //!     todo!()
 //! }
 //!
 //! async fn option(input: input::OptionInput) -> output::OptionOutput {
 //!     todo!()
 //! }
 //!
 //! async fn reserved_words_as_members(input: input::ReservedWordsAsMembersInput) -> Result<output::ReservedWordsAsMembersOutput, error::ReservedWordsAsMembersError> {
 //!     todo!()
 //! }
 //!
 //! async fn result(input: input::ResultInput) -> output::ResultOutput {
 //!     todo!()
 //! }
 //!
 //! async fn rpc_echo(input: input::RpcEchoInput) -> Result<output::RpcEchoOutput, error::RPCEchoError> {
 //!     todo!()
 //! }
 //!
 //! async fn structure_name_punning(input: input::StructureNamePunningInput) -> output::StructureNamePunningOutput {
 //!     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::{
     Config, ConfigBuilder, ConfigConfig, ConfigConfigBuilder, MissingOperationsError,
 };
-239
 /// 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::*;
-244
+}
-245

↧ Expand context

 /// Crate version number.
 pub static PKG_VERSION: &str = env!("CARGO_PKG_VERSION");
-248
 /// All error types that operations can return. Documentation on these types is copied from the model.
 pub mod error;
-251
 /// Input structures for operations. Documentation on these types is copied from the model.
 pub mod input;
-254
 /// Data structures used by operation inputs/outputs. Documentation on these types is copied from the model.
 pub mod model;
-257
 /// All operations that this crate can perform.
 pub mod operation;
-260
 /// 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
 /// parameterize [`Plugin`](::aws_smithy_http_server::plugin::Plugin) implementations. Their traits, such as

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

@@ -11,11 +71,71 @@

↥ Expand context

     type Output = Result<
         crate::input::RpcEchoInput,
         ::aws_smithy_http_server::protocol::aws_json::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::aws_json_11::AwsJson1_1,
         B,
     > for crate::input::RpcEchoInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-33
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-37
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = RpcEchoInputFuture;
-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_X_AMZ_JSON_1_1,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-48
+            }
             crate::protocol_serde::shape_rpc_echo::de_rpc_echo_http_request(request).await
         };
         use ::futures_util::future::TryFutureExt;

↧ Expand context

         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
             },
         );
         RpcEchoInputFuture {
             inner: Box::pin(fut),
-60
+        }
-61
+    }
-62
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::output::RpcEchoOutput
-67
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_rpc_echo::ser_rpc_echo_http_response(self) {
             Ok(response) => response,
             Err(e) => {

@@ -120,120 +180,180 @@

↥ Expand context

     type Output = Result<
         crate::input::MatchInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-124
     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)
-131
+    }
-132
+}
-133
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
         B,
     > for crate::input::MatchInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-142
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-146
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = MatchInputFuture;
-149
     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_X_AMZ_JSON_1_1,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-157
+            }
             crate::protocol_serde::shape_match::de_match_http_request(request).await
         };
         use ::futures_util::future::TryFutureExt;

↧ Expand context

         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
             },
         );
         MatchInputFuture {
             inner: Box::pin(fut),
-169
+        }
-170
+    }
-171
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::output::MatchOutput
-176
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_match::ser_match_http_response(self) {
             Ok(response) => response,
             Err(e) => {

@@ -229,229 +289,289 @@

↥ Expand context

     type Output = Result<
         crate::input::OptionInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-233
     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)
-240
+    }
-241
+}
-242
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
         B,
     > for crate::input::OptionInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-251
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-255
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = OptionInputFuture;
-258
     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_X_AMZ_JSON_1_1,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-266
+            }
             crate::protocol_serde::shape_option::de_option_http_request(request).await
         };
         use ::futures_util::future::TryFutureExt;

↧ Expand context

         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
             },
         );
         OptionInputFuture {
             inner: Box::pin(fut),
-278
+        }
-279
+    }
-280
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::output::OptionOutput
-285
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_option::ser_option_http_response(self) {
             Ok(response) => response,
             Err(e) => {

@@ -312,312 +372,372 @@

↥ Expand context

     type Output = Result<
         crate::input::ResultInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-316
     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)
-323
+    }
-324
+}
-325
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
         B,
     > for crate::input::ResultInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-334
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-338
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = ResultInputFuture;
-341
     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_X_AMZ_JSON_1_1,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-349
+            }
             crate::protocol_serde::shape_result::de_result_http_request(request).await
         };
         use ::futures_util::future::TryFutureExt;

↧ Expand context

         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
             },
         );
         ResultInputFuture {
             inner: Box::pin(fut),
-361
+        }
-362
+    }
-363
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::output::ResultOutput
-368
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_result::ser_result_http_response(self) {
             Ok(response) => response,
             Err(e) => {

@@ -395,395 +455,455 @@

↥ Expand context

     type Output = Result<
         crate::input::ErrCollisionsInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-399
     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)
-406
+    }
-407
+}
-408
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
         B,
     > for crate::input::ErrCollisionsInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-417
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-421
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = ErrCollisionsInputFuture;
-424
     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_X_AMZ_JSON_1_1,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-432
+            }
             crate::protocol_serde::shape_err_collisions::de_err_collisions_http_request(request)
                 .await
         };

↧ Expand context

         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
             },
         );
         ErrCollisionsInputFuture {
             inner: Box::pin(fut),
-445
+        }
-446
+    }
-447
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::output::ErrCollisionsOutput
-452
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_err_collisions::ser_err_collisions_http_response(self) {
             Ok(response) => response,

@@ -505,505 +628,633 @@

↥ Expand context

     type Output = Result<
         crate::input::StructureNamePunningInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-509
     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)
-516
+    }
-517
+}
-518
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
         B,
     > for crate::input::StructureNamePunningInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-527
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-531
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = StructureNamePunningInputFuture;
-534
     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_X_AMZ_JSON_1_1,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-542
+            }
             crate::protocol_serde::shape_structure_name_punning::de_structure_name_punning_http_request(request)
                             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
             },
         );
         StructureNamePunningInputFuture {
             inner: Box::pin(fut),
-555
+        }
-556
+    }
-557
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::output::StructureNamePunningOutput
-562
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_structure_name_punning::ser_structure_name_punning_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::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-569
+                        }
-570
+                    }
-571
+    }
-572
+}
-573
 #[allow(unreachable_code, unused_variables)]
 #[cfg(test)]
 mod structure_name_punning_test {
-577
     /// Test ID: structure_punning
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn structure_punning_request() {
         #[allow(unused_mut)]
         let mut http_request = http::Request::builder()
         let mut http_request = ::http_1x::Request::builder()
             .uri("/")
             .method("POST")
             .header("Content-Type", "application/x-amz-json-1.1")
             .header("X-Amz-Target", "Config.StructureNamePunning")
             .body(::aws_smithy_http_server::body::Body::from(
                 ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                     "{\"regular_string\": \"hello!\"}".as_bytes(),
                     ::aws_smithy_protocol_test::MediaType::from("application/json"),
             .body(::aws_smithy_http_server::body::boxed(
                 ::http_body_util::Full::new(::bytes::Bytes::copy_from_slice(
                     &::aws_smithy_protocol_test::decode_body_data(
                         "{\"regular_string\": \"hello!\"}".as_bytes(),
                         ::aws_smithy_protocol_test::MediaType::from("application/json"),
                     ),
                 )),
             ))
             .unwrap();
         #[allow(unused_mut)]
         let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
         let config = crate::service::ConfigConfig::builder().build();
         let service = crate::service::Config::builder::<::hyper::body::Body, _, _, _>(config)
         let service =
             crate::service::Config::builder::<::aws_smithy_http_server::body::BoxBody, _, _, _>(
                 config,
-+
+            )
             .structure_name_punning(move |input: crate::input::StructureNamePunningInput| {
                 let sender = sender.clone();
                 async move {
                     let result = {
                         let expected = crate::input::StructureNamePunningInput {
                             regular_string: ::std::option::Option::Some("hello!".to_owned()),
                             punned_vec: ::std::option::Option::None,
                         };
                         ::pretty_assertions::assert_eq!(input, expected);
                         let output = crate::output::StructureNamePunningOutput {};

↧ Expand context

                         output
                     };
                     sender.send(()).await.expect("receiver dropped early");
                     result
-618
+                }
             })
             .build_unchecked();
         let http_response = ::tower::ServiceExt::oneshot(service, http_request)
             .await
             .expect("unable to make an HTTP request");
         assert!(
             receiver.recv().await.is_some(),
             "we expected operation handler to be invoked but it was not entered"
         );
-628
+    }
-629
+}
-630
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`ReservedWordsAsMembersInput`](crate::input::ReservedWordsAsMembersInput) using modelled bindings.

@@ -635,640 +695,700 @@

↥ Expand context

     type Output = Result<
         crate::input::ReservedWordsAsMembersInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-644
     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)
-651
+    }
-652
+}
-653
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
         B,
     > for crate::input::ReservedWordsAsMembersInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-662
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-666
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = ReservedWordsAsMembersInputFuture;
-669
     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_X_AMZ_JSON_1_1,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-677
+            }
             crate::protocol_serde::shape_reserved_words_as_members::de_reserved_words_as_members_http_request(request)
                             .await
         };

↧ Expand context

         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
             },
         );
         ReservedWordsAsMembersInputFuture {
             inner: Box::pin(fut),
-690
+        }
-691
+    }
-692
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::output::ReservedWordsAsMembersOutput
-697
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_reserved_words_as_members::ser_reserved_words_as_members_http_response(self) {
                         Ok(response) => response,

@@ -701,706 +776,786 @@

↥ Expand context

-706
+    }
-707
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::error::ReservedWordsAsMembersError
-712
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_reserved_words_as_members::ser_reserved_words_as_members_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response
             },
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-722
+            }
-723
+        }
-724
+    }
-725
+}

-726
 #[allow(unreachable_code, unused_variables)]
 #[cfg(test)]
 mod reserved_words_as_members_test {
-730
     /// Test ID: reserved_words
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn reserved_words_request() {
         #[allow(unused_mut)]
         let mut http_request = http::Request::builder()
         let mut http_request = ::http_1x::Request::builder()
             .uri("/")
             .method("POST")
             .header("Content-Type", "application/x-amz-json-1.1")
             .header("X-Amz-Target", "Config.ReservedWordsAsMembers")
             .body(::aws_smithy_http_server::body::Body::from(
                 ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                     "{\"as\": 5, \"async\": true}".as_bytes(),
                     ::aws_smithy_protocol_test::MediaType::from("application/json"),
             .body(::aws_smithy_http_server::body::boxed(
                 ::http_body_util::Full::new(::bytes::Bytes::copy_from_slice(
                     &::aws_smithy_protocol_test::decode_body_data(
                         "{\"as\": 5, \"async\": true}".as_bytes(),
                         ::aws_smithy_protocol_test::MediaType::from("application/json"),
                     ),
                 )),
             ))
             .unwrap();
         #[allow(unused_mut)]
         let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
         let config = crate::service::ConfigConfig::builder().build();
         let service = crate::service::Config::builder::<::hyper::body::Body, _, _, _>(config)
         let service =
             crate::service::Config::builder::<::aws_smithy_http_server::body::BoxBody, _, _, _>(
                 config,
-+
+            )
             .reserved_words_as_members(move |input: crate::input::ReservedWordsAsMembersInput| {
                 let sender = sender.clone();
                 async move {
                     let result = {
                         let expected = crate::input::ReservedWordsAsMembersInput {
                             r#as: ::std::option::Option::Some(5),
                             r#async: ::std::option::Option::Some(true),
                             r#enum: ::std::option::Option::None,
                             self_: ::std::option::Option::None,
                             crate_: ::std::option::Option::None,

↧ Expand context

                             super_: ::std::option::Option::None,
                             build_value: ::std::option::Option::None,
                             default_value: ::std::option::Option::None,
                             send: ::std::option::Option::None,
                         };
                         ::pretty_assertions::assert_eq!(input, expected);
                         let output = crate::output::ReservedWordsAsMembersOutput {};
                         Ok(output)
                     };
                     sender.send(()).await.expect("receiver dropped early");
                     result
-778
+                }
             })
             .build_unchecked();
         let http_response = ::tower::ServiceExt::oneshot(service, http_request)
             .await
             .expect("unable to make an HTTP request");
         assert!(
             receiver.recv().await.is_some(),
             "we expected operation handler to be invoked but it was not entered"

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

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

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_err_collisions_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::ErrCollisionsInput,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::err_collisions_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_err_collisions_http_response(
     #[allow(unused_variables)] output: crate::output::ErrCollisionsOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::aws_json::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/x-amz-json-1.1",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload = "";
         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)?
     })
-53
+}
-54
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_err_collisions_http_error(
     error: &crate::error::ErrCollisionsError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::aws_json::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::ErrCollisionsError::CollidingError(output) => {
                 let payload =
                     crate::protocol_serde::shape_colliding_error::ser_colliding_error_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/x-amz-json-1.1",
                 );
                 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))?
-85
+            }
             crate::error::ErrCollisionsError::CollidingException(output) => {
                 let payload = crate::protocol_serde::shape_colliding_exception::ser_colliding_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/x-amz-json-1.1",
                 );
                 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))?
-104
+            }
-105
+        }
     })
-107
+}

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

@@ -1,1 +114,117 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_match_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::MatchInput,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::match_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/x-amz-json-1.1"),
             )?;
             input = crate::protocol_serde::shape_match::de_match(bytes.as_ref(), input)?;
-32
+        }
         input.build()?
     })
-35
+}
-36
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_match_http_response(
     #[allow(unused_variables)] output: crate::output::MatchOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::aws_json::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/x-amz-json-1.1",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload = "";
         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)?
     })
-64
+}
-65
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_match_http_error(
     error: &crate::error::MatchError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::aws_json::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::MatchError::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/x-amz-json-1.1",
                 );
                 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))?
-93
+            }
-94
+        }
     })
-96
+}
-97

↧ Expand context

 pub(crate) fn de_match(
     value: &[u8],
     mut builder: crate::input::match_input::Builder,
 ) -> ::std::result::Result<
     crate::input::match_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() {
                     "as" => {
                         builder = builder.set_as(
                             ::aws_smithy_json::deserialize::token::expect_number_or_null(

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

@@ -1,1 +86,89 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_option_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::OptionInput,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::option_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/x-amz-json-1.1"),
             )?;
             input = crate::protocol_serde::shape_option::de_option(bytes.as_ref(), input)?;
-32
+        }
         input.build()
     })
-35
+}
-36
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_option_http_response(
     #[allow(unused_variables)] output: crate::output::OptionOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::aws_json::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/x-amz-json-1.1",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload =
             crate::protocol_serde::shape_option_output::ser_option_output_output_output(&output)?;
         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)?
     })
-65
+}
-66
 pub(crate) fn de_option(
     value: &[u8],
     mut builder: crate::input::option_input::Builder,

↧ Expand context

 ) -> ::std::result::Result<
     crate::input::option_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() {
                     "pv_member" => {
                         builder = builder.set_pv_member(
                             ::aws_smithy_json::deserialize::token::expect_bool_or_null(
                                 tokens.next(),
                             )?,
                         );

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

@@ -1,1 +114,117 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_reserved_words_as_members_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::ReservedWordsAsMembersInput,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::reserved_words_as_members_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/x-amz-json-1.1"),
             )?;
             input = crate::protocol_serde::shape_reserved_words_as_members::de_reserved_words_as_members(bytes.as_ref(), input)?;
-32
+        }
         input.build()?
     })
-35
+}
-36
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_reserved_words_as_members_http_response(
     #[allow(unused_variables)] output: crate::output::ReservedWordsAsMembersOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::aws_json::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/x-amz-json-1.1",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload = "";
         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)?
     })
-64
+}
-65
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_reserved_words_as_members_http_error(
     error: &crate::error::ReservedWordsAsMembersError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::aws_json::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::ReservedWordsAsMembersError::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/x-amz-json-1.1",
                 );
                 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))?
-93
+            }
-94
+        }
     })
-96
+}
-97

↧ Expand context

 pub(crate) fn de_reserved_words_as_members(
     value: &[u8],
     mut builder: crate::input::reserved_words_as_members_input::Builder,
 ) -> ::std::result::Result<
     crate::input::reserved_words_as_members_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() {
                     "as" => {
                         builder = builder.set_as(
                             ::aws_smithy_json::deserialize::token::expect_number_or_null(

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

@@ -1,1 +86,89 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_result_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::ResultInput,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::result_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/x-amz-json-1.1"),
             )?;
             input = crate::protocol_serde::shape_result::de_result(bytes.as_ref(), input)?;
-32
+        }
         input.build()
     })
-35
+}
-36
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_result_http_response(
     #[allow(unused_variables)] output: crate::output::ResultOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::aws_json::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/x-amz-json-1.1",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload =
             crate::protocol_serde::shape_result_output::ser_result_output_output_output(&output)?;
         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)?
     })
-65
+}
-66
 pub(crate) fn de_result(
     value: &[u8],
     mut builder: crate::input::result_input::Builder,

↧ Expand context

 ) -> ::std::result::Result<
     crate::input::result_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() {
                     "pv_member" => {
                         builder = builder.set_pv_member(
                             ::aws_smithy_json::deserialize::token::expect_bool_or_null(
                                 tokens.next(),
                             )?,
                         );

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

@@ -1,1 +114,117 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_rpc_echo_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::RpcEchoInput,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::rpc_echo_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/x-amz-json-1.1"),
             )?;
             input = crate::protocol_serde::shape_rpc_echo::de_rpc_echo(bytes.as_ref(), input)?;
-32
+        }
         input.build()?
     })
-35
+}
-36
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_rpc_echo_http_response(
     #[allow(unused_variables)] output: crate::output::RpcEchoOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::aws_json::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/x-amz-json-1.1",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload = "";
         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)?
     })
-64
+}
-65
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_rpc_echo_http_error(
     error: &crate::error::RPCEchoError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::aws_json::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::RPCEchoError::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/x-amz-json-1.1",
                 );
                 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))?
-93
+            }
-94
+        }
     })
-96
+}
-97

↧ Expand context

 pub(crate) fn de_rpc_echo(
     value: &[u8],
     mut builder: crate::input::rpc_echo_input::Builder,
 ) -> ::std::result::Result<
     crate::input::rpc_echo_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() {
                     "as" => {
                         builder = builder.set_as(
                             ::aws_smithy_json::deserialize::token::expect_number_or_null(

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

@@ -1,1 +88,91 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_structure_name_punning_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::StructureNamePunningInput,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::structure_name_punning_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/x-amz-json-1.1"),
             )?;
             input = crate::protocol_serde::shape_structure_name_punning::de_structure_name_punning(
                 bytes.as_ref(),
                 input,
             )?;
-35
+        }
         input.build()
     })
-38
+}
-39
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_structure_name_punning_http_response(
     #[allow(unused_variables)] output: crate::output::StructureNamePunningOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::aws_json::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/x-amz-json-1.1",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload = "";
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             ::http_1x::header::CONTENT_LENGTH,
             content_length,
         );
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         builder.body(body)?
     })
-67
+}
-68
 pub(crate) fn de_structure_name_punning(
     value: &[u8],
     mut builder: crate::input::structure_name_punning_input::Builder,

↧ Expand context

 ) -> ::std::result::Result<
     crate::input::structure_name_punning_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() {
                     "regular_string" => {
                         builder = builder.set_regular_string(
                             ::aws_smithy_json::deserialize::token::expect_string_or_null(
                                 tokens.next(),
                             )?
                             .map(|s| s.to_unescaped().map(|u| u.into_owned()))

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

@@ -41,41 +102,102 @@

↥ Expand context

     /// # let app: Config<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>> = app;
     /// ```
     ///
                     pub fn err_collisions<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::ErrCollisions, HandlerExtractors>,
-47
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::ErrCollisions,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::ErrCollisions, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::ErrCollisions,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::ErrCollisions,

-61
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     Config<L>,
                                     crate::operation_shape::ErrCollisions,
                                     ModelPl::Output
-67
+                                >
                             >::Output
                         >,
-70
                         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,
-73
-74
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::ErrCollisions::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.err_collisions_custom(svc)

↧ Expand context

-83
+    }
-84
     /// Sets the [`ErrCollisions`](crate::operation_shape::ErrCollisions) 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 naming_test_ops::{Config, ConfigConfig};
     ///
     /// use naming_test_ops::{input, output, error};
     ///
     /// async fn handler(input: input::ErrCollisionsInput) -> Result<output::ErrCollisionsOutput, error::ErrCollisionsError> {
     ///     todo!()
     /// }
     ///
     /// let config = ConfigConfig::builder().build();
     /// let svc = ::tower::util::service_fn(handler);

@@ -108,108 +188,188 @@

↥ Expand context

     /// # let app: Config<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>> = app;
     /// ```
     ///
                     pub fn err_collisions_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::ErrCollisions, ServiceExtractors>,
-114
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::ErrCollisions,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::ErrCollisions, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::ErrCollisions,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::ErrCollisions,

-128
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     Config<L>,
                                     crate::operation_shape::ErrCollisions,
                                     ModelPl::Output
-134
+                                >
                             >::Output
                         >,
-137
                         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,
-140
-141
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::ErrCollisions::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.err_collisions_custom(svc)
-150
+    }
-151
     /// Sets the [`ErrCollisions`](crate::operation_shape::ErrCollisions) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn err_collisions_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,
-164
+    {
         self.err_collisions = Some(::aws_smithy_http_server::routing::Route::new(svc));
         self
-167
+    }
-168

↧ Expand context

     /// Sets the [`Match`](crate::operation_shape::Match) 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 naming_test_ops::{Config, ConfigConfig};
     ///
     /// use naming_test_ops::{input, output, error};
     ///
     /// async fn handler(input: input::MatchInput) -> Result<output::MatchOutput, error::MatchError> {
     ///     todo!()
     /// }
     ///
     /// let config = ConfigConfig::builder().build();
     /// let app = Config::builder(config)
     ///     .r#match(handler)
     ///     /* Set other handlers */

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

↥ Expand context

     /// # let app: Config<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>> = app;
     /// ```
     ///
                     pub fn r#match<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::Match, HandlerExtractors>,
-197
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::Match,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::Match, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::Match,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::Match,

-211
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     Config<L>,
                                     crate::operation_shape::Match,
                                     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::Match::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.r#match_custom(svc)

↧ Expand context

-233
+    }
-234
     /// Sets the [`Match`](crate::operation_shape::Match) 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 naming_test_ops::{Config, ConfigConfig};
     ///
     /// use naming_test_ops::{input, output, error};
     ///
     /// async fn handler(input: input::MatchInput) -> Result<output::MatchOutput, error::MatchError> {
     ///     todo!()
     /// }
     ///
     /// let config = ConfigConfig::builder().build();
     /// let svc = ::tower::util::service_fn(handler);

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

↥ Expand context

     /// # let app: Config<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>> = app;
     /// ```
     ///
                     pub fn r#match_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::Match, ServiceExtractors>,
-264
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::Match,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::Match, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::Match,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::Match,

-278
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     Config<L>,
                                     crate::operation_shape::Match,
                                     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::Match::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.r#match_custom(svc)
-300
+    }
-301
     /// Sets the [`Match`](crate::operation_shape::Match) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn r#match_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.r#match = Some(::aws_smithy_http_server::routing::Route::new(svc));
         self
-317
+    }
-318

↧ Expand context

     /// Sets the [`Option`](crate::operation_shape::Option) 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 naming_test_ops::{Config, ConfigConfig};
     ///
     /// use naming_test_ops::{input, output, error};
     ///
     /// async fn handler(input: input::OptionInput) -> output::OptionOutput {
     ///     todo!()
     /// }
     ///
     /// let config = ConfigConfig::builder().build();
     /// let app = Config::builder(config)
     ///     .option(handler)
     ///     /* Set other handlers */

@@ -341,341 +402,402 @@

↥ Expand context

     /// # let app: Config<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>> = app;
     /// ```
     ///
                     pub fn option<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::Option, HandlerExtractors>,
-347
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::Option,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::Option, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::Option,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::Option,

-361
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     Config<L>,
                                     crate::operation_shape::Option,
                                     ModelPl::Output
-367
+                                >
                             >::Output
                         >,
-370
                         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,
-373
-374
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::Option::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.option_custom(svc)

↧ Expand context

-383
+    }
-384
     /// Sets the [`Option`](crate::operation_shape::Option) 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 naming_test_ops::{Config, ConfigConfig};
     ///
     /// use naming_test_ops::{input, output, error};
     ///
     /// async fn handler(input: input::OptionInput) -> Result<output::OptionOutput, std::convert::Infallible> {
     ///     todo!()
     /// }
     ///
     /// let config = ConfigConfig::builder().build();
     /// let svc = ::tower::util::service_fn(handler);

@@ -408,408 +488,488 @@

↥ Expand context

     /// # let app: Config<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>> = app;
     /// ```
     ///
                     pub fn option_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::Option, ServiceExtractors>,
-414
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::Option,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::Option, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::Option,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::Option,

-428
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     Config<L>,
                                     crate::operation_shape::Option,
                                     ModelPl::Output
-434
+                                >
                             >::Output
                         >,
-437
                         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,
-440
-441
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::Option::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.option_custom(svc)
-450
+    }
-451
     /// Sets the [`Option`](crate::operation_shape::Option) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn option_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,
-464
+    {
         self.option = Some(::aws_smithy_http_server::routing::Route::new(svc));
         self
-467
+    }
-468

↧ Expand context

     /// Sets the [`ReservedWordsAsMembers`](crate::operation_shape::ReservedWordsAsMembers) 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 naming_test_ops::{Config, ConfigConfig};
     ///
     /// use naming_test_ops::{input, output, error};
     ///
     /// async fn handler(input: input::ReservedWordsAsMembersInput) -> Result<output::ReservedWordsAsMembersOutput, error::ReservedWordsAsMembersError> {
     ///     todo!()
     /// }
     ///
     /// let config = ConfigConfig::builder().build();
     /// let app = Config::builder(config)
     ///     .reserved_words_as_members(handler)
     ///     /* Set other handlers */

@@ -491,491 +552,552 @@

↥ Expand context

     /// # let app: Config<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>> = app;
     /// ```
     ///
                     pub fn reserved_words_as_members<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::ReservedWordsAsMembers, HandlerExtractors>,
-497
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::ReservedWordsAsMembers,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::ReservedWordsAsMembers, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::ReservedWordsAsMembers,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::ReservedWordsAsMembers,

-511
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     Config<L>,
                                     crate::operation_shape::ReservedWordsAsMembers,
                                     ModelPl::Output
-517
+                                >
                             >::Output
                         >,
-520
                         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,
-523
-524
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::ReservedWordsAsMembers::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.reserved_words_as_members_custom(svc)

↧ Expand context

-533
+    }
-534
     /// Sets the [`ReservedWordsAsMembers`](crate::operation_shape::ReservedWordsAsMembers) 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 naming_test_ops::{Config, ConfigConfig};
     ///
     /// use naming_test_ops::{input, output, error};
     ///
     /// async fn handler(input: input::ReservedWordsAsMembersInput) -> Result<output::ReservedWordsAsMembersOutput, error::ReservedWordsAsMembersError> {
     ///     todo!()
     /// }
     ///
     /// let config = ConfigConfig::builder().build();
     /// let svc = ::tower::util::service_fn(handler);

@@ -558,558 +638,638 @@

↥ Expand context

     /// # let app: Config<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>> = app;
     /// ```
     ///
                     pub fn reserved_words_as_members_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::ReservedWordsAsMembers, ServiceExtractors>,
-564
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::ReservedWordsAsMembers,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::ReservedWordsAsMembers, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::ReservedWordsAsMembers,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::ReservedWordsAsMembers,

-578
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     Config<L>,
                                     crate::operation_shape::ReservedWordsAsMembers,
                                     ModelPl::Output
-584
+                                >
                             >::Output
                         >,
-587
                         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,
-590
-591
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::ReservedWordsAsMembers::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.reserved_words_as_members_custom(svc)
-600
+    }
-601
     /// Sets the [`ReservedWordsAsMembers`](crate::operation_shape::ReservedWordsAsMembers) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn reserved_words_as_members_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,
-614
+    {
         self.reserved_words_as_members = Some(::aws_smithy_http_server::routing::Route::new(svc));
         self
-617
+    }
-618

↧ Expand context

     /// Sets the [`Result`](crate::operation_shape::Result) 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 naming_test_ops::{Config, ConfigConfig};
     ///
     /// use naming_test_ops::{input, output, error};
     ///
     /// async fn handler(input: input::ResultInput) -> output::ResultOutput {
     ///     todo!()
     /// }
     ///
     /// let config = ConfigConfig::builder().build();
     /// let app = Config::builder(config)
     ///     .result(handler)
     ///     /* Set other handlers */

@@ -641,641 +702,702 @@

↥ Expand context

     /// # let app: Config<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>> = app;
     /// ```
     ///
                     pub fn result<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::Result, HandlerExtractors>,
-647
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::Result,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::Result, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::Result,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::Result,

-661
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     Config<L>,
                                     crate::operation_shape::Result,
                                     ModelPl::Output
-667
+                                >
                             >::Output
                         >,
-670
                         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,
-673
-674
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::Result::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.result_custom(svc)

↧ Expand context

-683
+    }
-684
     /// Sets the [`Result`](crate::operation_shape::Result) 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 naming_test_ops::{Config, ConfigConfig};
     ///
     /// use naming_test_ops::{input, output, error};
     ///
     /// async fn handler(input: input::ResultInput) -> Result<output::ResultOutput, std::convert::Infallible> {
     ///     todo!()
     /// }
     ///
     /// let config = ConfigConfig::builder().build();
     /// let svc = ::tower::util::service_fn(handler);

@@ -708,708 +788,788 @@

↥ Expand context

     /// # let app: Config<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>> = app;
     /// ```
     ///
                     pub fn result_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::Result, ServiceExtractors>,
-714
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::Result,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::Result, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::Result,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::Result,

-728
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     Config<L>,
                                     crate::operation_shape::Result,
                                     ModelPl::Output
-734
+                                >
                             >::Output
                         >,
-737
                         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,
-740
-741
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::Result::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.result_custom(svc)
-750
+    }
-751
     /// Sets the [`Result`](crate::operation_shape::Result) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn result_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,
-764
+    {
         self.result = Some(::aws_smithy_http_server::routing::Route::new(svc));
         self
-767
+    }
-768

↧ Expand context

     /// Sets the [`RpcEcho`](crate::operation_shape::RpcEcho) 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 naming_test_ops::{Config, ConfigConfig};
     ///
     /// use naming_test_ops::{input, output, error};
     ///
     /// async fn handler(input: input::RpcEchoInput) -> Result<output::RpcEchoOutput, error::RPCEchoError> {
     ///     todo!()
     /// }
     ///
     /// let config = ConfigConfig::builder().build();
     /// let app = Config::builder(config)
     ///     .rpc_echo(handler)
     ///     /* Set other handlers */

@@ -791,791 +852,852 @@

↥ Expand context

     /// # let app: Config<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>> = app;
     /// ```
     ///
                     pub fn rpc_echo<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::RpcEcho, HandlerExtractors>,
-797
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::RpcEcho,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::RpcEcho, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::RpcEcho,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::RpcEcho,

-811
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     Config<L>,
                                     crate::operation_shape::RpcEcho,
                                     ModelPl::Output
-817
+                                >
                             >::Output
                         >,
-820
                         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,
-823
-824
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::RpcEcho::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.rpc_echo_custom(svc)

↧ Expand context

-833
+    }
-834
     /// Sets the [`RpcEcho`](crate::operation_shape::RpcEcho) 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 naming_test_ops::{Config, ConfigConfig};
     ///
     /// use naming_test_ops::{input, output, error};
     ///
     /// async fn handler(input: input::RpcEchoInput) -> Result<output::RpcEchoOutput, error::RPCEchoError> {
     ///     todo!()
     /// }
     ///
     /// let config = ConfigConfig::builder().build();
     /// let svc = ::tower::util::service_fn(handler);

@@ -858,858 +938,938 @@

↥ Expand context

     /// # let app: Config<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>> = app;
     /// ```
     ///
                     pub fn rpc_echo_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::RpcEcho, ServiceExtractors>,
-864
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::RpcEcho,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::RpcEcho, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::RpcEcho,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::RpcEcho,

-878
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     Config<L>,
                                     crate::operation_shape::RpcEcho,
                                     ModelPl::Output
-884
+                                >
                             >::Output
                         >,
-887
                         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,
-890
-891
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::RpcEcho::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.rpc_echo_custom(svc)
-900
+    }
-901
     /// Sets the [`RpcEcho`](crate::operation_shape::RpcEcho) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn rpc_echo_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,
-914
+    {
         self.rpc_echo = Some(::aws_smithy_http_server::routing::Route::new(svc));
         self
-917
+    }
-918

↧ Expand context

     /// Sets the [`StructureNamePunning`](crate::operation_shape::StructureNamePunning) 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 naming_test_ops::{Config, ConfigConfig};
     ///
     /// use naming_test_ops::{input, output, error};
     ///
     /// async fn handler(input: input::StructureNamePunningInput) -> output::StructureNamePunningOutput {
     ///     todo!()
     /// }
     ///
     /// let config = ConfigConfig::builder().build();
     /// let app = Config::builder(config)
     ///     .structure_name_punning(handler)
     ///     /* Set other handlers */

@@ -941,941 +1002,1002 @@

↥ Expand context

     /// # let app: Config<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>> = app;
     /// ```
     ///
                     pub fn structure_name_punning<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::StructureNamePunning, HandlerExtractors>,
-947
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::StructureNamePunning,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::StructureNamePunning, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::StructureNamePunning,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::StructureNamePunning,

-961
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     Config<L>,
                                     crate::operation_shape::StructureNamePunning,
                                     ModelPl::Output
-967
+                                >
                             >::Output
                         >,
-970
                         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,
-973
-974
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::StructureNamePunning::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.structure_name_punning_custom(svc)

↧ Expand context

-983
+    }
-984
     /// Sets the [`StructureNamePunning`](crate::operation_shape::StructureNamePunning) 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 naming_test_ops::{Config, ConfigConfig};
     ///
     /// use naming_test_ops::{input, output, error};
     ///
     /// async fn handler(input: input::StructureNamePunningInput) -> Result<output::StructureNamePunningOutput, std::convert::Infallible> {
     ///     todo!()
     /// }
     ///
     /// let config = ConfigConfig::builder().build();
     /// let svc = ::tower::util::service_fn(handler);

@@ -1008,1008 +1088,1088 @@

↥ Expand context

     /// # let app: Config<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>> = app;
     /// ```
     ///
                     pub fn structure_name_punning_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::StructureNamePunning, ServiceExtractors>,
-1014
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::StructureNamePunning,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::StructureNamePunning, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::StructureNamePunning,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             Config<L>,
                             crate::operation_shape::StructureNamePunning,

-1028
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     Config<L>,
                                     crate::operation_shape::StructureNamePunning,
                                     ModelPl::Output
-1034
+                                >
                             >::Output
                         >,
-1037
                         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,
-1040
-1041
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::StructureNamePunning::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.structure_name_punning_custom(svc)
-1050
+    }
-1051
     /// Sets the [`StructureNamePunning`](crate::operation_shape::StructureNamePunning) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn structure_name_punning_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,
-1064
+    {
         self.structure_name_punning = Some(::aws_smithy_http_server::routing::Route::new(svc));
         self
-1067
+    }
-1068
+}

↧ Expand context

-1069
 impl<Body, L, HttpPl, ModelPl> ConfigBuilder<Body, L, HttpPl, ModelPl> {
     /// Constructs a [`Config`] from the arguments provided to the builder.
     ///
     /// Forgetting to register a handler for one or more operations will result in an error.
     ///
     /// Check out [`ConfigBuilder::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<
         Config<
             ::aws_smithy_http_server::routing::RoutingService<
                 ::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<L::Service>,
                 ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
             >,
         >,
         MissingOperationsError,
-1087
+    >
     where

@@ -1440,1440 +1501,1501 @@

↥ Expand context

         layer: &L,
     ) -> Config<
         ::aws_smithy_http_server::routing::RoutingService<
             ::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<L::Service>,
             ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
         >,
-1446
+    >
     where
         L: ::tower::Layer<S>,
-1449
+    {
         Config {
             svc: self.svc.map(|s| s.layer(layer)),
-1452
+        }
-1453
+    }
-1454
     /// 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,

     ) -> Config<
         ::aws_smithy_http_server::routing::RoutingService<
             ::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<
                 ::aws_smithy_http_server::routing::Route<B>,
             >,
             ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
         >,
-1467
+    >
     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,
-1476
+    {
         self.layer(&::tower::layer::layer_fn(
             ::aws_smithy_http_server::routing::Route::new,
         ))
-1480
+    }
-1481
+}

↧ Expand context

-1482
 impl<S, R> ::tower::Service<R> for Config<S>
 where
     S: ::tower::Service<R>,
-1486
+{
     type Response = S::Response;
     type Error = S::Error;
     type Future = S::Future;
-1490
     fn poll_ready(
         &mut self,
         cx: &mut std::task::Context,
     ) -> std::task::Poll<::std::result::Result<(), Self::Error>> {
         self.svc.poll_ready(cx)
-1496
+    }
-1497
     fn call(&mut self, request: R) -> Self::Future {
         self.svc.call(request)
-1500
+    }
-1501
+}

 # Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 [package]
 name = "naming_test_ops"
 version = "0.0.1"
 authors = ["protocoltest@example.com"]
 description = "test"
 edition = "2021"
-8
 [package.metadata.smithy]

 codegen-version = "ci"
 protocol = "aws.protocols#awsJson1_1"
 [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"
 features = ["http-1x"]
 [dev-dependencies.bytes]
 version = "1.4.0"
 [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"]
-59
-60

Server Test

Files changed:

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

tmp-codegen-diff/codegen-server-test/naming_test_structs-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.
 /*
  * 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 StructsInput {
     #[allow(missing_docs)] // documentation missing in model
     pub result: ::std::option::Option<crate::model::Result>,
     #[allow(missing_docs)] // documentation missing in model
     pub result_list: ::std::option::Option<::std::vec::Vec<crate::model::Result>>,
     #[allow(missing_docs)] // documentation missing in model
     pub option: ::std::option::Option<crate::model::Option>,
     #[allow(missing_docs)] // documentation missing in model
     pub option_list: ::std::option::Option<::std::vec::Vec<crate::model::Result>>,
     #[allow(missing_docs)] // documentation missing in model
     pub something_else: ::std::option::Option<crate::model::SomethingElse>,
-+
+}
 impl StructsInput {
     #[allow(missing_docs)] // documentation missing in model
     pub fn result(&self) -> ::std::option::Option<&crate::model::Result> {
         self.result.as_ref()
-+
+    }
     #[allow(missing_docs)] // documentation missing in model
     pub fn result_list(&self) -> ::std::option::Option<&[crate::model::Result]> {
         self.result_list.as_deref()
-+
+    }
     #[allow(missing_docs)] // documentation missing in model
     pub fn option(&self) -> ::std::option::Option<&crate::model::Option> {
         self.option.as_ref()
-+
+    }
     #[allow(missing_docs)] // documentation missing in model
     pub fn option_list(&self) -> ::std::option::Option<&[crate::model::Result]> {
         self.option_list.as_deref()
-+
+    }
     #[allow(missing_docs)] // documentation missing in model
     pub fn something_else(&self) -> ::std::option::Option<&crate::model::SomethingElse> {
         self.something_else.as_ref()
-+
+    }
-+
+}
 impl StructsInput {
     /// Creates a new builder-style object to manufacture [`StructsInput`](crate::input::StructsInput).
     pub fn builder() -> crate::input::structs_input::Builder {
         crate::input::structs_input::Builder::default()
-+
+    }
-+
+}
 impl crate::constrained::Constrained for crate::input::StructsInput {
     type Unconstrained = crate::input::structs_input::Builder;
-+
+}
 /// See [`StructsInput`](crate::input::StructsInput).
 pub mod structs_input {
-+
     impl ::std::convert::From<Builder> for crate::input::StructsInput {
         fn from(builder: Builder) -> Self {
             builder.build()
-+
+        }
-+
+    }
     /// A builder for [`StructsInput`](crate::input::StructsInput).
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {
         pub(crate) result: ::std::option::Option<crate::model::Result>,
         pub(crate) result_list: ::std::option::Option<::std::vec::Vec<crate::model::Result>>,
         pub(crate) option: ::std::option::Option<crate::model::Option>,
         pub(crate) option_list: ::std::option::Option<::std::vec::Vec<crate::model::Result>>,
         pub(crate) something_else: ::std::option::Option<crate::model::SomethingElse>,
-+
+    }
     impl Builder {
         #[allow(missing_docs)] // documentation missing in model
         pub fn result(mut self, input: ::std::option::Option<crate::model::Result>) -> Self {
             self.result = input;
             self
-+
+        }
         #[allow(missing_docs)] // documentation missing in model
         pub(crate) fn set_result(
             mut self,
             input: Option<impl ::std::convert::Into<crate::model::Result>>,
         ) -> Self {
             self.result = input.map(|v| v.into());
             self
-+
+        }
         #[allow(missing_docs)] // documentation missing in model
         pub fn result_list(
             mut self,
             input: ::std::option::Option<::std::vec::Vec<crate::model::Result>>,
         ) -> Self {
             self.result_list = input;
             self
-+
+        }
         #[allow(missing_docs)] // documentation missing in model
         pub(crate) fn set_result_list(
             mut self,
             input: Option<impl ::std::convert::Into<::std::vec::Vec<crate::model::Result>>>,
         ) -> Self {
             self.result_list = input.map(|v| v.into());
             self
-+
+        }
         #[allow(missing_docs)] // documentation missing in model
         pub fn option(mut self, input: ::std::option::Option<crate::model::Option>) -> Self {
             self.option = input;
             self
-+
+        }
         #[allow(missing_docs)] // documentation missing in model
         pub(crate) fn set_option(
             mut self,
             input: Option<impl ::std::convert::Into<crate::model::Option>>,
         ) -> Self {
             self.option = input.map(|v| v.into());
             self
-+
+        }
         #[allow(missing_docs)] // documentation missing in model
         pub fn option_list(
             mut self,
             input: ::std::option::Option<::std::vec::Vec<crate::model::Result>>,
         ) -> Self {
             self.option_list = input;
             self
-+
+        }
         #[allow(missing_docs)] // documentation missing in model
         pub(crate) fn set_option_list(
             mut self,
             input: Option<impl ::std::convert::Into<::std::vec::Vec<crate::model::Result>>>,
         ) -> Self {
             self.option_list = input.map(|v| v.into());
             self
-+
+        }
         #[allow(missing_docs)] // documentation missing in model
         pub fn something_else(
             mut self,
             input: ::std::option::Option<crate::model::SomethingElse>,
         ) -> Self {
             self.something_else = input;
             self
-+
+        }
         #[allow(missing_docs)] // documentation missing in model
         pub(crate) fn set_something_else(
             mut self,
             input: Option<impl ::std::convert::Into<crate::model::SomethingElse>>,
         ) -> Self {
             self.something_else = input.map(|v| v.into());
             self
-+
+        }
         /// Consumes the builder and constructs a [`StructsInput`](crate::input::StructsInput).
         pub fn build(self) -> crate::input::StructsInput {
             self.build_enforcing_all_constraints()
-+
+        }
         fn build_enforcing_all_constraints(self) -> crate::input::StructsInput {
             crate::input::StructsInput {
                 result: self.result,
                 result_list: self.result_list,
                 option: self.option,
                 option_list: self.option_list,
                 something_else: self.something_else,
-+
+            }
-+
+        }
-+
+    }
-+
+}