Server Test Python

rev. 3c756f73b1f83a0eed4275d9d1e22df0b10b66fb (ignoring whitespace)

Files changed:

tmp-codegen-diff/codegen-server-test-python/ebs/rust-server-codegen-python/src/protocol_serde/shape_start_snapshot.rs

@@ -1,1 +324,324 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_start_snapshot_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::StartSnapshotInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::start_snapshot_input_internal::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?;
         if !bytes.is_empty() {
             ::aws_smithy_http_server::protocol::content_type_header_classifier_smithy(
             ::aws_smithy_legacy_http_server::protocol::content_type_header_classifier_smithy(
                 &headers,
                 Some("application/json"),
             )?;
             input = crate::protocol_serde::shape_start_snapshot::de_start_snapshot(
                 bytes.as_ref(),
                 input,
             )?;
-32
+        }
         input.build()?
     })
-35
+}
-36
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_start_snapshot_http_response(
     #[allow(unused_variables)] output: crate::output::StartSnapshotOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
     ::aws_smithy_legacy_http_server::response::Response,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
         builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/json",
         );
         let http_status: u16 = 201;
         builder = builder.status(http_status);
         let payload =
             crate::protocol_serde::shape_start_snapshot_output::ser_start_snapshot_output_output_output(&output)?
-56
+        ;
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
         builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             content_length,
         );
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         let body = ::aws_smithy_legacy_http_server::body::to_boxed(payload);
         builder.body(body)?
     })
-66
+}
-67
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_start_snapshot_http_error(
     error: &crate::error::StartSnapshotError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
     ::aws_smithy_legacy_http_server::response::Response,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::StartSnapshotError::InternalServerException(output) => {
                 let payload = crate::protocol_serde::shape_internal_server_exception::ser_internal_server_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/json",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "InternalServerException",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(500)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
-100
+            }
             crate::error::StartSnapshotError::ResourceNotFoundException(output) => {
                 let payload = crate::protocol_serde::shape_resource_not_found_exception::ser_resource_not_found_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/json",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "ResourceNotFoundException",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(404)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
-124
+            }
             crate::error::StartSnapshotError::AccessDeniedException(output) => {
                 let payload = crate::protocol_serde::shape_access_denied_exception::ser_access_denied_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/json",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "AccessDeniedException",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(403)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
-148
+            }
             crate::error::StartSnapshotError::ConflictException(output) => {
                 let payload =
                     crate::protocol_serde::shape_conflict_exception::ser_conflict_exception_error(
                         output,
                     )?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/json",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "ConflictException",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(503)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
-175
+            }
             crate::error::StartSnapshotError::RequestThrottledException(output) => {
                 let payload = crate::protocol_serde::shape_request_throttled_exception::ser_request_throttled_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/json",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "RequestThrottledException",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
-199
+            }
             crate::error::StartSnapshotError::ServiceQuotaExceededException(output) => {
                 let payload = crate::protocol_serde::shape_service_quota_exceeded_exception::ser_service_quota_exceeded_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/json",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "ServiceQuotaExceededException",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(402)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
-223
+            }
             crate::error::StartSnapshotError::ConcurrentLimitExceededException(output) => {
                 let payload = crate::protocol_serde::shape_concurrent_limit_exceeded_exception::ser_concurrent_limit_exceeded_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/json",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "ConcurrentLimitExceededException",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
-247
+            }
             crate::error::StartSnapshotError::ValidationException(output) => {
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/json",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "ValidationException",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
-271
+            }
             crate::error::StartSnapshotError::InternalServerError(output) => {
                 let payload = crate::protocol_serde::shape_internal_server_error::ser_internal_server_error_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/json",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "InternalServerError",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(500)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
-295
+            }
-296
+        }
     })
-298
+}
-299
 pub(crate) fn de_start_snapshot(
     value: &[u8],
     mut builder: crate::input::start_snapshot_input_internal::Builder,
 ) -> ::std::result::Result<
     crate::input::start_snapshot_input_internal::Builder,

↧ Expand context

     ::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() {
                     "ClientToken" => {
                         builder = builder.set_client_token(
                             ::aws_smithy_json::deserialize::token::expect_string_or_null(
                                 tokens.next(),
                             )?
                             .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                             .transpose()?,
                         );

tmp-codegen-diff/codegen-server-test-python/ebs/rust-server-codegen-python/src/python_operation_adaptor.rs

@@ -1,1 +288,300 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /// Python handler for operation `StartSnapshot`.
 pub(crate) async fn start_snapshot(
     input: crate::input::StartSnapshotInput,
     state: ::aws_smithy_http_server::Extension<::aws_smithy_http_server_python::context::PyContext>,
     state: ::aws_smithy_legacy_http_server::Extension<
         ::aws_smithy_http_server_python::context::PyContext,
     >,
     handler: ::aws_smithy_http_server_python::PyHandler,
 ) -> std::result::Result<crate::output::StartSnapshotOutput, crate::error::StartSnapshotError> {
     // Async block used to run the handler and catch any Python error.
     let result = if handler.is_coroutine {
         ::tracing::trace!(
             name = "start_snapshot",
             "executing python handler coroutine"
         );
         let result = ::pyo3::Python::with_gil(|py| {
             let pyhandler: &::pyo3::types::PyFunction = handler.extract(py)?;
             let coroutine = if handler.args == 1 {
                 pyhandler.call1((input,))?
             } else {
                 pyhandler.call1((input, ::pyo3::ToPyObject::to_object(&state.0, py)))?
             };
             ::pyo3_asyncio::tokio::into_future(coroutine)
         })?;
         result.await.and_then(|r| {
             ::pyo3::Python::with_gil(|py| r.extract::<crate::output::StartSnapshotOutput>(py))
         })
     } else {
         ::tracing::trace!(name = "start_snapshot", "executing python handler function");
         ::pyo3::Python::with_gil(|py| {
             let pyhandler: &::pyo3::types::PyFunction = handler.extract(py)?;
             let output = if handler.args == 1 {
                 pyhandler.call1((input,))?
             } else {
                 pyhandler.call1((input, ::pyo3::ToPyObject::to_object(&state.0, py)))?
             };
             output.extract::<crate::output::StartSnapshotOutput>()
         })
     };
     // Catch and record a Python traceback.
     result.map_err(|e| {
         let rich_py_err =
             ::aws_smithy_http_server_python::rich_py_err(::pyo3::Python::with_gil(|py| {
                 e.clone_ref(py)
             }));
         ::tracing::error!(error = ?rich_py_err, "handler error");
         e.into()
     })
-49
+}
-50
 /// Python handler for operation `PutSnapshotBlock`.
 pub(crate) async fn put_snapshot_block(
     input: crate::input::PutSnapshotBlockInput,
     state: ::aws_smithy_http_server::Extension<::aws_smithy_http_server_python::context::PyContext>,
     state: ::aws_smithy_legacy_http_server::Extension<
         ::aws_smithy_http_server_python::context::PyContext,
     >,
     handler: ::aws_smithy_http_server_python::PyHandler,
 ) -> std::result::Result<crate::output::PutSnapshotBlockOutput, crate::error::PutSnapshotBlockError>
-59
+{
     // Async block used to run the handler and catch any Python error.
     let result = if handler.is_coroutine {
         ::tracing::trace!(
             name = "put_snapshot_block",
             "executing python handler coroutine"
         );
         let result = ::pyo3::Python::with_gil(|py| {
             let pyhandler: &::pyo3::types::PyFunction = handler.extract(py)?;
             let coroutine = if handler.args == 1 {
                 pyhandler.call1((input,))?
             } else {
                 pyhandler.call1((input, ::pyo3::ToPyObject::to_object(&state.0, py)))?
             };
             ::pyo3_asyncio::tokio::into_future(coroutine)
         })?;
         result.await.and_then(|r| {
             ::pyo3::Python::with_gil(|py| r.extract::<crate::output::PutSnapshotBlockOutput>(py))
         })
     } else {
         ::tracing::trace!(
             name = "put_snapshot_block",
             "executing python handler function"
         );
         ::pyo3::Python::with_gil(|py| {
             let pyhandler: &::pyo3::types::PyFunction = handler.extract(py)?;
             let output = if handler.args == 1 {
                 pyhandler.call1((input,))?
             } else {
                 pyhandler.call1((input, ::pyo3::ToPyObject::to_object(&state.0, py)))?
             };
             output.extract::<crate::output::PutSnapshotBlockOutput>()
         })
     };
     // Catch and record a Python traceback.
     result.map_err(|e| {
         let rich_py_err =
             ::aws_smithy_http_server_python::rich_py_err(::pyo3::Python::with_gil(|py| {
                 e.clone_ref(py)
             }));
         ::tracing::error!(error = ?rich_py_err, "handler error");
         e.into()
     })
-102
+}
-103
 /// Python handler for operation `ListSnapshotBlocks`.
 pub(crate) async fn list_snapshot_blocks(
     input: crate::input::ListSnapshotBlocksInput,
     state: ::aws_smithy_http_server::Extension<::aws_smithy_http_server_python::context::PyContext>,
     state: ::aws_smithy_legacy_http_server::Extension<
         ::aws_smithy_http_server_python::context::PyContext,
     >,
     handler: ::aws_smithy_http_server_python::PyHandler,
 ) -> std::result::Result<
     crate::output::ListSnapshotBlocksOutput,
     crate::error::ListSnapshotBlocksError,
 > {
     // Async block used to run the handler and catch any Python error.
     let result = if handler.is_coroutine {
         ::tracing::trace!(
             name = "list_snapshot_blocks",
             "executing python handler coroutine"
         );
         let result = ::pyo3::Python::with_gil(|py| {
             let pyhandler: &::pyo3::types::PyFunction = handler.extract(py)?;
             let coroutine = if handler.args == 1 {
                 pyhandler.call1((input,))?
             } else {
                 pyhandler.call1((input, ::pyo3::ToPyObject::to_object(&state.0, py)))?
             };
             ::pyo3_asyncio::tokio::into_future(coroutine)
         })?;
         result.await.and_then(|r| {
             ::pyo3::Python::with_gil(|py| r.extract::<crate::output::ListSnapshotBlocksOutput>(py))
         })
     } else {
         ::tracing::trace!(
             name = "list_snapshot_blocks",
             "executing python handler function"
         );
         ::pyo3::Python::with_gil(|py| {
             let pyhandler: &::pyo3::types::PyFunction = handler.extract(py)?;
             let output = if handler.args == 1 {
                 pyhandler.call1((input,))?
             } else {
                 pyhandler.call1((input, ::pyo3::ToPyObject::to_object(&state.0, py)))?
             };
             output.extract::<crate::output::ListSnapshotBlocksOutput>()
         })
     };
     // Catch and record a Python traceback.
     result.map_err(|e| {
         let rich_py_err =
             ::aws_smithy_http_server_python::rich_py_err(::pyo3::Python::with_gil(|py| {
                 e.clone_ref(py)
             }));
         ::tracing::error!(error = ?rich_py_err, "handler error");
         e.into()
     })
-157
+}
-158
 /// Python handler for operation `ListChangedBlocks`.
 pub(crate) async fn list_changed_blocks(
     input: crate::input::ListChangedBlocksInput,
     state: ::aws_smithy_http_server::Extension<::aws_smithy_http_server_python::context::PyContext>,
     state: ::aws_smithy_legacy_http_server::Extension<
         ::aws_smithy_http_server_python::context::PyContext,
     >,
     handler: ::aws_smithy_http_server_python::PyHandler,
 ) -> std::result::Result<crate::output::ListChangedBlocksOutput, crate::error::ListChangedBlocksError>
-167
+{
     // Async block used to run the handler and catch any Python error.
     let result = if handler.is_coroutine {
         ::tracing::trace!(
             name = "list_changed_blocks",
             "executing python handler coroutine"
         );
         let result = ::pyo3::Python::with_gil(|py| {
             let pyhandler: &::pyo3::types::PyFunction = handler.extract(py)?;
             let coroutine = if handler.args == 1 {
                 pyhandler.call1((input,))?
             } else {
                 pyhandler.call1((input, ::pyo3::ToPyObject::to_object(&state.0, py)))?
             };
             ::pyo3_asyncio::tokio::into_future(coroutine)
         })?;
         result.await.and_then(|r| {
             ::pyo3::Python::with_gil(|py| r.extract::<crate::output::ListChangedBlocksOutput>(py))
         })
     } else {
         ::tracing::trace!(
             name = "list_changed_blocks",
             "executing python handler function"
         );
         ::pyo3::Python::with_gil(|py| {
             let pyhandler: &::pyo3::types::PyFunction = handler.extract(py)?;
             let output = if handler.args == 1 {
                 pyhandler.call1((input,))?
             } else {
                 pyhandler.call1((input, ::pyo3::ToPyObject::to_object(&state.0, py)))?
             };
             output.extract::<crate::output::ListChangedBlocksOutput>()
         })
     };
     // Catch and record a Python traceback.
     result.map_err(|e| {
         let rich_py_err =
             ::aws_smithy_http_server_python::rich_py_err(::pyo3::Python::with_gil(|py| {
                 e.clone_ref(py)
             }));
         ::tracing::error!(error = ?rich_py_err, "handler error");
         e.into()
     })
-210
+}
-211
 /// Python handler for operation `GetSnapshotBlock`.
 pub(crate) async fn get_snapshot_block(
     input: crate::input::GetSnapshotBlockInput,
     state: ::aws_smithy_http_server::Extension<::aws_smithy_http_server_python::context::PyContext>,
     state: ::aws_smithy_legacy_http_server::Extension<
         ::aws_smithy_http_server_python::context::PyContext,
     >,
     handler: ::aws_smithy_http_server_python::PyHandler,
 ) -> std::result::Result<crate::output::GetSnapshotBlockOutput, crate::error::GetSnapshotBlockError>
-220
+{
     // Async block used to run the handler and catch any Python error.
     let result = if handler.is_coroutine {
         ::tracing::trace!(
             name = "get_snapshot_block",
             "executing python handler coroutine"
         );
         let result = ::pyo3::Python::with_gil(|py| {
             let pyhandler: &::pyo3::types::PyFunction = handler.extract(py)?;
             let coroutine = if handler.args == 1 {
                 pyhandler.call1((input,))?
             } else {
                 pyhandler.call1((input, ::pyo3::ToPyObject::to_object(&state.0, py)))?
             };
             ::pyo3_asyncio::tokio::into_future(coroutine)
         })?;
         result.await.and_then(|r| {
             ::pyo3::Python::with_gil(|py| r.extract::<crate::output::GetSnapshotBlockOutput>(py))
         })
     } else {
         ::tracing::trace!(
             name = "get_snapshot_block",
             "executing python handler function"
         );
         ::pyo3::Python::with_gil(|py| {
             let pyhandler: &::pyo3::types::PyFunction = handler.extract(py)?;
             let output = if handler.args == 1 {
                 pyhandler.call1((input,))?
             } else {
                 pyhandler.call1((input, ::pyo3::ToPyObject::to_object(&state.0, py)))?
             };
             output.extract::<crate::output::GetSnapshotBlockOutput>()
         })
     };
     // Catch and record a Python traceback.
     result.map_err(|e| {
         let rich_py_err =
             ::aws_smithy_http_server_python::rich_py_err(::pyo3::Python::with_gil(|py| {
                 e.clone_ref(py)
             }));
         ::tracing::error!(error = ?rich_py_err, "handler error");
         e.into()
     })
-263
+}
-264
 /// Python handler for operation `CompleteSnapshot`.
 pub(crate) async fn complete_snapshot(
     input: crate::input::CompleteSnapshotInput,
     state: ::aws_smithy_http_server::Extension<::aws_smithy_http_server_python::context::PyContext>,
     state: ::aws_smithy_legacy_http_server::Extension<
         ::aws_smithy_http_server_python::context::PyContext,
     >,
     handler: ::aws_smithy_http_server_python::PyHandler,
 ) -> std::result::Result<crate::output::CompleteSnapshotOutput, crate::error::CompleteSnapshotError>
-273
+{
     // Async block used to run the handler and catch any Python error.
     let result = if handler.is_coroutine {
         ::tracing::trace!(
             name = "complete_snapshot",
             "executing python handler coroutine"
         );
         let result = ::pyo3::Python::with_gil(|py| {

↧ Expand context

             let pyhandler: &::pyo3::types::PyFunction = handler.extract(py)?;
             let coroutine = if handler.args == 1 {
                 pyhandler.call1((input,))?
             } else {
                 pyhandler.call1((input, ::pyo3::ToPyObject::to_object(&state.0, py)))?
             };
             ::pyo3_asyncio::tokio::into_future(coroutine)
         })?;
         result.await.and_then(|r| {
             ::pyo3::Python::with_gil(|py| r.extract::<crate::output::CompleteSnapshotOutput>(py))
         })
     } else {
         ::tracing::trace!(
             name = "complete_snapshot",
             "executing python handler function"
         );
         ::pyo3::Python::with_gil(|py| {
             let pyhandler: &::pyo3::types::PyFunction = handler.extract(py)?;
             let output = if handler.args == 1 {
                 pyhandler.call1((input,))?

tmp-codegen-diff/codegen-server-test-python/ebs/rust-server-codegen-python/src/python_server_application.rs

@@ -91,91 +152,152 @@

↥ Expand context

-91
+        }
-92
+    }
-93
+}
 impl Clone for App {
     fn clone(&self) -> Self {
         Self {
             handlers: self.handlers.clone(),
             middlewares: self.middlewares.clone(),
             context: self.context.clone(),
             workers: ::parking_lot::Mutex::new(vec![]),
-101
+        }
-102
+    }
-103
+}
 impl ::aws_smithy_http_server_python::PyApp for App {
     fn workers(&self) -> &::parking_lot::Mutex<Vec<::pyo3::PyObject>> {
         &self.workers
-107
+    }
     fn context(&self) -> &Option<::pyo3::PyObject> {
         &self.context
-110
+    }

     fn handlers(
         &mut self,
     ) -> &mut ::std::collections::HashMap<String, ::aws_smithy_http_server_python::PyHandler> {
         &mut self.handlers
-115
+    }
     fn build_service(
         &mut self,
         event_loop: &::pyo3::PyAny,
     ) -> ::pyo3::PyResult<
         ::tower::util::BoxCloneService<
             ::http::Request<::aws_smithy_http_server::body::Body>,
             ::http::Response<::aws_smithy_http_server::body::BoxBody>,
             ::http::Request<::aws_smithy_legacy_http_server::body::Body>,
             ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>,
             std::convert::Infallible,
         >,
     > {
         let builder = crate::service::Ebs::builder_without_plugins();
         let complete_snapshot_locals = ::pyo3_asyncio::TaskLocals::new(event_loop);
         let handler = self
             .handlers
             .get("complete_snapshot")
             .expect("Python handler for operation `complete_snapshot` not found")
             .clone();

↧ Expand context

         let builder = builder.complete_snapshot(move |input, state| {
             ::pyo3_asyncio::tokio::scope(
                 complete_snapshot_locals.clone(),
                 crate::python_operation_adaptor::complete_snapshot(input, state, handler.clone()),
-137
+            )
         });
         let get_snapshot_block_locals = ::pyo3_asyncio::TaskLocals::new(event_loop);
         let handler = self
             .handlers
             .get("get_snapshot_block")
             .expect("Python handler for operation `get_snapshot_block` not found")
             .clone();
         let builder = builder.get_snapshot_block(move |input, state| {
             ::pyo3_asyncio::tokio::scope(
                 get_snapshot_block_locals.clone(),
                 crate::python_operation_adaptor::get_snapshot_block(input, state, handler.clone()),
-149
+            )
         });
         let list_changed_blocks_locals = ::pyo3_asyncio::TaskLocals::new(event_loop);
         let handler = self

@@ -185,185 +245,245 @@

↥ Expand context

         let builder = builder.put_snapshot_block(move |input, state| {
             ::pyo3_asyncio::tokio::scope(
                 put_snapshot_block_locals.clone(),
                 crate::python_operation_adaptor::put_snapshot_block(input, state, handler.clone()),
-189
+            )
         });
         let start_snapshot_locals = ::pyo3_asyncio::TaskLocals::new(event_loop);
         let handler = self
             .handlers
             .get("start_snapshot")
             .expect("Python handler for operation `start_snapshot` not found")
             .clone();
         let builder = builder.start_snapshot(move |input, state| {
             ::pyo3_asyncio::tokio::scope(
                 start_snapshot_locals.clone(),
                 crate::python_operation_adaptor::start_snapshot(input, state, handler.clone()),
-201
+            )
         });
         let mut service = ::tower::util::BoxCloneService::new(builder.build().expect("one or more operations do not have a registered handler; this is a bug in the Python code generator, please file a bug report under https://github.com/smithy-lang/smithy-rs/issues"));
-204

-205
+        {
             use ::tower::Layer;
             ::tracing::trace!("adding middlewares to rust python router");
             let mut middlewares = self.middlewares.clone();
             // Reverse the middlewares, so they run with same order as they defined
             middlewares.reverse();
             for handler in middlewares {
                 ::tracing::trace!(name = &handler.name, "adding python middleware");
                 let locals = ::pyo3_asyncio::TaskLocals::new(event_loop);
                 let layer = ::aws_smithy_http_server_python::PyMiddlewareLayer::<
                     ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
                     ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
                 >::new(handler, locals);
                 service = ::tower::util::BoxCloneService::new(layer.layer(service));
-218
+            }
-219
+        }
         Ok(service)
-221
+    }
-222
+}
 #[::pyo3::pymethods]
 impl App {
     /// Create a new [App].

↧ Expand context

     #[new]
     pub fn new() -> Self {
         Self::default()
-229
+    }
-230
     /// Register a context object that will be shared between handlers.
     ///
     /// :param context Ctx:
     /// :rtype None:
     #[pyo3(text_signature = "($self, context)")]
     pub fn context(&mut self, context: ::pyo3::PyObject) {
         self.context = Some(context);
-238
+    }
-239
     /// Register a Python function to be executed inside a Tower middleware layer.
     ///
     /// :param func typing.Callable\[\[ebs.middleware.Request, typing.Callable\[\[ebs.middleware.Request\], typing.Awaitable\[ebs.middleware.Response\]\]\], typing.Awaitable\[ebs.middleware.Response\]\]:
     /// :rtype None:
     #[pyo3(text_signature = "($self, func)")]
     pub fn middleware(

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

@@ -1,1 +1661,1690 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /// The service builder for [`Ebs`].
 ///
 /// Constructed via [`Ebs::builder`].
 pub struct EbsBuilder<Body, L, HttpPl, ModelPl> {
     complete_snapshot: Option<::aws_smithy_http_server::routing::Route<Body>>,
     get_snapshot_block: Option<::aws_smithy_http_server::routing::Route<Body>>,
     list_changed_blocks: Option<::aws_smithy_http_server::routing::Route<Body>>,
     list_snapshot_blocks: Option<::aws_smithy_http_server::routing::Route<Body>>,
     put_snapshot_block: Option<::aws_smithy_http_server::routing::Route<Body>>,
     start_snapshot: Option<::aws_smithy_http_server::routing::Route<Body>>,
     complete_snapshot: Option<::aws_smithy_legacy_http_server::routing::Route<Body>>,
     get_snapshot_block: Option<::aws_smithy_legacy_http_server::routing::Route<Body>>,
     list_changed_blocks: Option<::aws_smithy_legacy_http_server::routing::Route<Body>>,
     list_snapshot_blocks: Option<::aws_smithy_legacy_http_server::routing::Route<Body>>,
     put_snapshot_block: Option<::aws_smithy_legacy_http_server::routing::Route<Body>>,
     start_snapshot: Option<::aws_smithy_legacy_http_server::routing::Route<Body>>,
     layer: L,
     http_plugin: HttpPl,
     model_plugin: ModelPl,
-15
+}
-16
 impl<Body, L, HttpPl, ModelPl> EbsBuilder<Body, L, HttpPl, ModelPl> {
     /// Sets the [`CompleteSnapshot`](crate::operation_shape::CompleteSnapshot) 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.
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_legacy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_legacy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use ebs::{Ebs, EbsConfig};
     ///
     /// use ebs::{input, output, error};
     ///
     /// async fn handler(input: input::CompleteSnapshotInput) -> Result<output::CompleteSnapshotOutput, error::CompleteSnapshotError> {
     ///     todo!()
     /// }
     ///
     /// let config = EbsConfig::builder().build();
     /// let app = Ebs::builder(config)
     ///     .complete_snapshot(handler)
     ///     /* Set other handlers */
     ///     .build()
     ///     .unwrap();
     /// # let app: Ebs<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// # let app: Ebs<::aws_smithy_legacy_http_server::routing::RoutingService<::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<::aws_smithy_legacy_http_server::routing::Route>, ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn complete_snapshot<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::CompleteSnapshot, HandlerExtractors>,
                         HandlerType: ::aws_smithy_legacy_http_server::operation::Handler<crate::operation_shape::CompleteSnapshot, HandlerExtractors>,
-46
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                         ModelPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::CompleteSnapshot,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::CompleteSnapshot, HandlerType>
                             ::aws_smithy_legacy_http_server::operation::IntoService<crate::operation_shape::CompleteSnapshot, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                         ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::CompleteSnapshot,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                         HttpPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::CompleteSnapshot,
-60
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                 ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_legacy_http_server::plugin::Plugin<
                                     Ebs<L>,
                                     crate::operation_shape::CompleteSnapshot,
                                     ModelPl::Output
-66
+                                >
                             >::Output
                         >,
-69
                         HttpPl::Output: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         HttpPl::Output: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
-72
-73
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         use ::aws_smithy_legacy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_legacy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::CompleteSnapshot::from_handler(handler);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
         let svc =
             ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
                 .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.complete_snapshot_custom(svc)
-83
+    }
-84
     /// Sets the [`CompleteSnapshot`](crate::operation_shape::CompleteSnapshot) 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.
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_legacy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_legacy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use ebs::{Ebs, EbsConfig};
     ///
     /// use ebs::{input, output, error};
     ///
     /// async fn handler(input: input::CompleteSnapshotInput) -> Result<output::CompleteSnapshotOutput, error::CompleteSnapshotError> {
     ///     todo!()
     /// }
     ///
     /// let config = EbsConfig::builder().build();
     /// let svc = ::tower::util::service_fn(handler);
     /// let app = Ebs::builder(config)
     ///     .complete_snapshot_service(svc)
     ///     /* Set other handlers */
     ///     .build()
     ///     .unwrap();
     /// # let app: Ebs<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// # let app: Ebs<::aws_smithy_legacy_http_server::routing::RoutingService<::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<::aws_smithy_legacy_http_server::routing::Route>, ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn complete_snapshot_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::CompleteSnapshot, ServiceExtractors>,
                         S: ::aws_smithy_legacy_http_server::operation::OperationService<crate::operation_shape::CompleteSnapshot, ServiceExtractors>,
-114
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                         ModelPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::CompleteSnapshot,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::CompleteSnapshot, S>
                             ::aws_smithy_legacy_http_server::operation::Normalize<crate::operation_shape::CompleteSnapshot, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                         ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::CompleteSnapshot,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                         HttpPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::CompleteSnapshot,
-128
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                 ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_legacy_http_server::plugin::Plugin<
                                     Ebs<L>,
                                     crate::operation_shape::CompleteSnapshot,
                                     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: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
-140
-141
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         use ::aws_smithy_legacy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_legacy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::CompleteSnapshot::from_service(service);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
         let svc =
             ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
                 .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.complete_snapshot_custom(svc)
-151
+    }
-152
     /// Sets the [`CompleteSnapshot`](crate::operation_shape::CompleteSnapshot) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn complete_snapshot_custom<S>(mut self, svc: S) -> Self
     where
         S: ::tower::Service<
                 ::http::Request<Body>,
                 Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>,
                 Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>,
                 Error = ::std::convert::Infallible,
             > + Clone
             + Send
             + 'static,
         S::Future: Send + 'static,
-165
+    {
         self.complete_snapshot = Some(::aws_smithy_http_server::routing::Route::new(svc));
         self.complete_snapshot = Some(::aws_smithy_legacy_http_server::routing::Route::new(svc));
         self
-168
+    }
-169
     /// Sets the [`GetSnapshotBlock`](crate::operation_shape::GetSnapshotBlock) 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.
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_legacy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_legacy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use ebs::{Ebs, EbsConfig};
     ///
     /// use ebs::{input, output, error};
     ///
     /// async fn handler(input: input::GetSnapshotBlockInput) -> Result<output::GetSnapshotBlockOutput, error::GetSnapshotBlockError> {
     ///     todo!()
     /// }
     ///
     /// let config = EbsConfig::builder().build();
     /// let app = Ebs::builder(config)
     ///     .get_snapshot_block(handler)
     ///     /* Set other handlers */
     ///     .build()
     ///     .unwrap();
     /// # let app: Ebs<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// # let app: Ebs<::aws_smithy_legacy_http_server::routing::RoutingService<::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<::aws_smithy_legacy_http_server::routing::Route>, ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn get_snapshot_block<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::GetSnapshotBlock, HandlerExtractors>,
                         HandlerType: ::aws_smithy_legacy_http_server::operation::Handler<crate::operation_shape::GetSnapshotBlock, HandlerExtractors>,
-198
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                         ModelPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::GetSnapshotBlock,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::GetSnapshotBlock, HandlerType>
                             ::aws_smithy_legacy_http_server::operation::IntoService<crate::operation_shape::GetSnapshotBlock, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                         ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::GetSnapshotBlock,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                         HttpPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::GetSnapshotBlock,
-212
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                 ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_legacy_http_server::plugin::Plugin<
                                     Ebs<L>,
                                     crate::operation_shape::GetSnapshotBlock,
                                     ModelPl::Output
-218
+                                >
                             >::Output
                         >,
-221
                         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: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
-224
-225
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         use ::aws_smithy_legacy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_legacy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::GetSnapshotBlock::from_handler(handler);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
         let svc =
             ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
                 .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.get_snapshot_block_custom(svc)
-235
+    }
-236
     /// Sets the [`GetSnapshotBlock`](crate::operation_shape::GetSnapshotBlock) 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.
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_legacy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_legacy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use ebs::{Ebs, EbsConfig};
     ///
     /// use ebs::{input, output, error};
     ///
     /// async fn handler(input: input::GetSnapshotBlockInput) -> Result<output::GetSnapshotBlockOutput, error::GetSnapshotBlockError> {
     ///     todo!()
     /// }
     ///
     /// let config = EbsConfig::builder().build();
     /// let svc = ::tower::util::service_fn(handler);
     /// let app = Ebs::builder(config)
     ///     .get_snapshot_block_service(svc)
     ///     /* Set other handlers */
     ///     .build()
     ///     .unwrap();
     /// # let app: Ebs<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// # let app: Ebs<::aws_smithy_legacy_http_server::routing::RoutingService<::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<::aws_smithy_legacy_http_server::routing::Route>, ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn get_snapshot_block_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::GetSnapshotBlock, ServiceExtractors>,
                         S: ::aws_smithy_legacy_http_server::operation::OperationService<crate::operation_shape::GetSnapshotBlock, ServiceExtractors>,
-266
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                         ModelPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::GetSnapshotBlock,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::GetSnapshotBlock, S>
                             ::aws_smithy_legacy_http_server::operation::Normalize<crate::operation_shape::GetSnapshotBlock, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                         ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::GetSnapshotBlock,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                         HttpPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::GetSnapshotBlock,
-280
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                 ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_legacy_http_server::plugin::Plugin<
                                     Ebs<L>,
                                     crate::operation_shape::GetSnapshotBlock,
                                     ModelPl::Output
-286
+                                >
                             >::Output
                         >,
-289
                         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: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
-292
-293
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         use ::aws_smithy_legacy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_legacy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::GetSnapshotBlock::from_service(service);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
         let svc =
             ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
                 .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.get_snapshot_block_custom(svc)
-303
+    }
-304
     /// Sets the [`GetSnapshotBlock`](crate::operation_shape::GetSnapshotBlock) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn get_snapshot_block_custom<S>(mut self, svc: S) -> Self
     where
         S: ::tower::Service<
                 ::http::Request<Body>,
                 Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>,
                 Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>,
                 Error = ::std::convert::Infallible,
             > + Clone
             + Send
             + 'static,
         S::Future: Send + 'static,
-317
+    {
         self.get_snapshot_block = Some(::aws_smithy_http_server::routing::Route::new(svc));
         self.get_snapshot_block = Some(::aws_smithy_legacy_http_server::routing::Route::new(svc));
         self
-320
+    }
-321
     /// Sets the [`ListChangedBlocks`](crate::operation_shape::ListChangedBlocks) 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.
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_legacy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_legacy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use ebs::{Ebs, EbsConfig};
     ///
     /// use ebs::{input, output, error};
     ///
     /// async fn handler(input: input::ListChangedBlocksInput) -> Result<output::ListChangedBlocksOutput, error::ListChangedBlocksError> {
     ///     todo!()
     /// }
     ///
     /// let config = EbsConfig::builder().build();
     /// let app = Ebs::builder(config)
     ///     .list_changed_blocks(handler)
     ///     /* Set other handlers */
     ///     .build()
     ///     .unwrap();
     /// # let app: Ebs<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// # let app: Ebs<::aws_smithy_legacy_http_server::routing::RoutingService<::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<::aws_smithy_legacy_http_server::routing::Route>, ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn list_changed_blocks<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::ListChangedBlocks, HandlerExtractors>,
                         HandlerType: ::aws_smithy_legacy_http_server::operation::Handler<crate::operation_shape::ListChangedBlocks, HandlerExtractors>,
-350
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                         ModelPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::ListChangedBlocks,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::ListChangedBlocks, HandlerType>
                             ::aws_smithy_legacy_http_server::operation::IntoService<crate::operation_shape::ListChangedBlocks, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                         ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::ListChangedBlocks,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                         HttpPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::ListChangedBlocks,
-364
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                 ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_legacy_http_server::plugin::Plugin<
                                     Ebs<L>,
                                     crate::operation_shape::ListChangedBlocks,
                                     ModelPl::Output
-370
+                                >
                             >::Output
                         >,
-373
                         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: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
-376
-377
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         use ::aws_smithy_legacy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_legacy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::ListChangedBlocks::from_handler(handler);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
         let svc =
             ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
                 .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.list_changed_blocks_custom(svc)
-387
+    }
-388
     /// Sets the [`ListChangedBlocks`](crate::operation_shape::ListChangedBlocks) 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.
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_legacy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_legacy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use ebs::{Ebs, EbsConfig};
     ///
     /// use ebs::{input, output, error};
     ///
     /// async fn handler(input: input::ListChangedBlocksInput) -> Result<output::ListChangedBlocksOutput, error::ListChangedBlocksError> {
     ///     todo!()
     /// }
     ///
     /// let config = EbsConfig::builder().build();
     /// let svc = ::tower::util::service_fn(handler);
     /// let app = Ebs::builder(config)
     ///     .list_changed_blocks_service(svc)
     ///     /* Set other handlers */
     ///     .build()
     ///     .unwrap();
     /// # let app: Ebs<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// # let app: Ebs<::aws_smithy_legacy_http_server::routing::RoutingService<::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<::aws_smithy_legacy_http_server::routing::Route>, ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn list_changed_blocks_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::ListChangedBlocks, ServiceExtractors>,
                         S: ::aws_smithy_legacy_http_server::operation::OperationService<crate::operation_shape::ListChangedBlocks, ServiceExtractors>,
-418
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                         ModelPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::ListChangedBlocks,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::ListChangedBlocks, S>
                             ::aws_smithy_legacy_http_server::operation::Normalize<crate::operation_shape::ListChangedBlocks, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                         ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::ListChangedBlocks,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                         HttpPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::ListChangedBlocks,
-432
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                 ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_legacy_http_server::plugin::Plugin<
                                     Ebs<L>,
                                     crate::operation_shape::ListChangedBlocks,
                                     ModelPl::Output
-438
+                                >
                             >::Output
                         >,
-441
                         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: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
-444
-445
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         use ::aws_smithy_legacy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_legacy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::ListChangedBlocks::from_service(service);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
         let svc =
             ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
                 .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.list_changed_blocks_custom(svc)
-455
+    }
-456
     /// Sets the [`ListChangedBlocks`](crate::operation_shape::ListChangedBlocks) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn list_changed_blocks_custom<S>(mut self, svc: S) -> Self
     where
         S: ::tower::Service<
                 ::http::Request<Body>,
                 Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>,
                 Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>,
                 Error = ::std::convert::Infallible,
             > + Clone
             + Send
             + 'static,
         S::Future: Send + 'static,
-469
+    {
         self.list_changed_blocks = Some(::aws_smithy_http_server::routing::Route::new(svc));
         self.list_changed_blocks = Some(::aws_smithy_legacy_http_server::routing::Route::new(svc));
         self
-472
+    }
-473
     /// Sets the [`ListSnapshotBlocks`](crate::operation_shape::ListSnapshotBlocks) 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.
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_legacy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_legacy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use ebs::{Ebs, EbsConfig};
     ///
     /// use ebs::{input, output, error};
     ///
     /// async fn handler(input: input::ListSnapshotBlocksInput) -> Result<output::ListSnapshotBlocksOutput, error::ListSnapshotBlocksError> {
     ///     todo!()
     /// }
     ///
     /// let config = EbsConfig::builder().build();
     /// let app = Ebs::builder(config)
     ///     .list_snapshot_blocks(handler)
     ///     /* Set other handlers */
     ///     .build()
     ///     .unwrap();
     /// # let app: Ebs<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// # let app: Ebs<::aws_smithy_legacy_http_server::routing::RoutingService<::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<::aws_smithy_legacy_http_server::routing::Route>, ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn list_snapshot_blocks<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::ListSnapshotBlocks, HandlerExtractors>,
                         HandlerType: ::aws_smithy_legacy_http_server::operation::Handler<crate::operation_shape::ListSnapshotBlocks, HandlerExtractors>,
-502
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                         ModelPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::ListSnapshotBlocks,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::ListSnapshotBlocks, HandlerType>
                             ::aws_smithy_legacy_http_server::operation::IntoService<crate::operation_shape::ListSnapshotBlocks, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                         ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::ListSnapshotBlocks,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                         HttpPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::ListSnapshotBlocks,
-516
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                 ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_legacy_http_server::plugin::Plugin<
                                     Ebs<L>,
                                     crate::operation_shape::ListSnapshotBlocks,
                                     ModelPl::Output
-522
+                                >
                             >::Output
                         >,
-525
                         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: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
-528
-529
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         use ::aws_smithy_legacy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_legacy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::ListSnapshotBlocks::from_handler(handler);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
         let svc =
             ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
                 .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.list_snapshot_blocks_custom(svc)
-539
+    }
-540
     /// Sets the [`ListSnapshotBlocks`](crate::operation_shape::ListSnapshotBlocks) 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.
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_legacy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_legacy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use ebs::{Ebs, EbsConfig};
     ///
     /// use ebs::{input, output, error};
     ///
     /// async fn handler(input: input::ListSnapshotBlocksInput) -> Result<output::ListSnapshotBlocksOutput, error::ListSnapshotBlocksError> {
     ///     todo!()
     /// }
     ///
     /// let config = EbsConfig::builder().build();
     /// let svc = ::tower::util::service_fn(handler);
     /// let app = Ebs::builder(config)
     ///     .list_snapshot_blocks_service(svc)
     ///     /* Set other handlers */
     ///     .build()
     ///     .unwrap();
     /// # let app: Ebs<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// # let app: Ebs<::aws_smithy_legacy_http_server::routing::RoutingService<::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<::aws_smithy_legacy_http_server::routing::Route>, ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn list_snapshot_blocks_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::ListSnapshotBlocks, ServiceExtractors>,
                         S: ::aws_smithy_legacy_http_server::operation::OperationService<crate::operation_shape::ListSnapshotBlocks, ServiceExtractors>,
-570
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                         ModelPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::ListSnapshotBlocks,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::ListSnapshotBlocks, S>
                             ::aws_smithy_legacy_http_server::operation::Normalize<crate::operation_shape::ListSnapshotBlocks, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                         ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::ListSnapshotBlocks,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                         HttpPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::ListSnapshotBlocks,
-584
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                 ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_legacy_http_server::plugin::Plugin<
                                     Ebs<L>,
                                     crate::operation_shape::ListSnapshotBlocks,
                                     ModelPl::Output
-590
+                                >
                             >::Output
                         >,
-593
                         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: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
-596
-597
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         use ::aws_smithy_legacy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_legacy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::ListSnapshotBlocks::from_service(service);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
         let svc =
             ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
                 .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.list_snapshot_blocks_custom(svc)
-607
+    }
-608
     /// Sets the [`ListSnapshotBlocks`](crate::operation_shape::ListSnapshotBlocks) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn list_snapshot_blocks_custom<S>(mut self, svc: S) -> Self
     where
         S: ::tower::Service<
                 ::http::Request<Body>,
                 Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>,
                 Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>,
                 Error = ::std::convert::Infallible,
             > + Clone
             + Send
             + 'static,
         S::Future: Send + 'static,
-621
+    {
         self.list_snapshot_blocks = Some(::aws_smithy_http_server::routing::Route::new(svc));
         self.list_snapshot_blocks = Some(::aws_smithy_legacy_http_server::routing::Route::new(svc));
         self
-624
+    }
-625
     /// Sets the [`PutSnapshotBlock`](crate::operation_shape::PutSnapshotBlock) 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.
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_legacy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_legacy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use ebs::{Ebs, EbsConfig};
     ///
     /// use ebs::{input, output, error};
     ///
     /// async fn handler(input: input::PutSnapshotBlockInput) -> Result<output::PutSnapshotBlockOutput, error::PutSnapshotBlockError> {
     ///     todo!()
     /// }
     ///
     /// let config = EbsConfig::builder().build();
     /// let app = Ebs::builder(config)
     ///     .put_snapshot_block(handler)
     ///     /* Set other handlers */
     ///     .build()
     ///     .unwrap();
     /// # let app: Ebs<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// # let app: Ebs<::aws_smithy_legacy_http_server::routing::RoutingService<::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<::aws_smithy_legacy_http_server::routing::Route>, ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn put_snapshot_block<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::PutSnapshotBlock, HandlerExtractors>,
                         HandlerType: ::aws_smithy_legacy_http_server::operation::Handler<crate::operation_shape::PutSnapshotBlock, HandlerExtractors>,
-654
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                         ModelPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::PutSnapshotBlock,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::PutSnapshotBlock, HandlerType>
                             ::aws_smithy_legacy_http_server::operation::IntoService<crate::operation_shape::PutSnapshotBlock, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                         ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::PutSnapshotBlock,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                         HttpPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::PutSnapshotBlock,
-668
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                 ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_legacy_http_server::plugin::Plugin<
                                     Ebs<L>,
                                     crate::operation_shape::PutSnapshotBlock,
                                     ModelPl::Output
-674
+                                >
                             >::Output
                         >,
-677
                         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: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
-680
-681
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         use ::aws_smithy_legacy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_legacy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::PutSnapshotBlock::from_handler(handler);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
         let svc =
             ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
                 .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.put_snapshot_block_custom(svc)
-691
+    }
-692
     /// Sets the [`PutSnapshotBlock`](crate::operation_shape::PutSnapshotBlock) 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.
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_legacy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_legacy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use ebs::{Ebs, EbsConfig};
     ///
     /// use ebs::{input, output, error};
     ///
     /// async fn handler(input: input::PutSnapshotBlockInput) -> Result<output::PutSnapshotBlockOutput, error::PutSnapshotBlockError> {
     ///     todo!()
     /// }
     ///
     /// let config = EbsConfig::builder().build();
     /// let svc = ::tower::util::service_fn(handler);
     /// let app = Ebs::builder(config)
     ///     .put_snapshot_block_service(svc)
     ///     /* Set other handlers */
     ///     .build()
     ///     .unwrap();
     /// # let app: Ebs<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// # let app: Ebs<::aws_smithy_legacy_http_server::routing::RoutingService<::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<::aws_smithy_legacy_http_server::routing::Route>, ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn put_snapshot_block_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::PutSnapshotBlock, ServiceExtractors>,
                         S: ::aws_smithy_legacy_http_server::operation::OperationService<crate::operation_shape::PutSnapshotBlock, ServiceExtractors>,
-722
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                         ModelPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::PutSnapshotBlock,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::PutSnapshotBlock, S>
                             ::aws_smithy_legacy_http_server::operation::Normalize<crate::operation_shape::PutSnapshotBlock, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                         ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::PutSnapshotBlock,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                         HttpPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::PutSnapshotBlock,
-736
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                 ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_legacy_http_server::plugin::Plugin<
                                     Ebs<L>,
                                     crate::operation_shape::PutSnapshotBlock,
                                     ModelPl::Output
-742
+                                >
                             >::Output
                         >,
-745
                         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: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
-748
-749
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         use ::aws_smithy_legacy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_legacy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::PutSnapshotBlock::from_service(service);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
         let svc =
             ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
                 .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.put_snapshot_block_custom(svc)
-759
+    }
-760
     /// Sets the [`PutSnapshotBlock`](crate::operation_shape::PutSnapshotBlock) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn put_snapshot_block_custom<S>(mut self, svc: S) -> Self
     where
         S: ::tower::Service<
                 ::http::Request<Body>,
                 Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>,
                 Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>,
                 Error = ::std::convert::Infallible,
             > + Clone
             + Send
             + 'static,
         S::Future: Send + 'static,
-773
+    {
         self.put_snapshot_block = Some(::aws_smithy_http_server::routing::Route::new(svc));
         self.put_snapshot_block = Some(::aws_smithy_legacy_http_server::routing::Route::new(svc));
         self
-776
+    }
-777
     /// Sets the [`StartSnapshot`](crate::operation_shape::StartSnapshot) 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.
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_legacy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_legacy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use ebs::{Ebs, EbsConfig};
     ///
     /// use ebs::{input, output, error};
     ///
     /// async fn handler(input: input::StartSnapshotInput) -> Result<output::StartSnapshotOutput, error::StartSnapshotError> {
     ///     todo!()
     /// }
     ///
     /// let config = EbsConfig::builder().build();
     /// let app = Ebs::builder(config)
     ///     .start_snapshot(handler)
     ///     /* Set other handlers */
     ///     .build()
     ///     .unwrap();
     /// # let app: Ebs<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// # let app: Ebs<::aws_smithy_legacy_http_server::routing::RoutingService<::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<::aws_smithy_legacy_http_server::routing::Route>, ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn start_snapshot<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::StartSnapshot, HandlerExtractors>,
                         HandlerType: ::aws_smithy_legacy_http_server::operation::Handler<crate::operation_shape::StartSnapshot, HandlerExtractors>,
-806
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                         ModelPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::StartSnapshot,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::StartSnapshot, HandlerType>
                             ::aws_smithy_legacy_http_server::operation::IntoService<crate::operation_shape::StartSnapshot, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                         ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::StartSnapshot,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                         HttpPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::StartSnapshot,
-820
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                 ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_legacy_http_server::plugin::Plugin<
                                     Ebs<L>,
                                     crate::operation_shape::StartSnapshot,
                                     ModelPl::Output
-826
+                                >
                             >::Output
                         >,
-829
                         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: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
-832
-833
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         use ::aws_smithy_legacy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_legacy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::StartSnapshot::from_handler(handler);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
         let svc =
             ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
                 .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.start_snapshot_custom(svc)
-843
+    }
-844
     /// Sets the [`StartSnapshot`](crate::operation_shape::StartSnapshot) 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.
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_legacy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_legacy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use ebs::{Ebs, EbsConfig};
     ///
     /// use ebs::{input, output, error};
     ///
     /// async fn handler(input: input::StartSnapshotInput) -> Result<output::StartSnapshotOutput, error::StartSnapshotError> {
     ///     todo!()
     /// }
     ///
     /// let config = EbsConfig::builder().build();
     /// let svc = ::tower::util::service_fn(handler);
     /// let app = Ebs::builder(config)
     ///     .start_snapshot_service(svc)
     ///     /* Set other handlers */
     ///     .build()
     ///     .unwrap();
     /// # let app: Ebs<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// # let app: Ebs<::aws_smithy_legacy_http_server::routing::RoutingService<::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<::aws_smithy_legacy_http_server::routing::Route>, ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn start_snapshot_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::StartSnapshot, ServiceExtractors>,
                         S: ::aws_smithy_legacy_http_server::operation::OperationService<crate::operation_shape::StartSnapshot, ServiceExtractors>,
-874
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                         ModelPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::StartSnapshot,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::StartSnapshot, S>
                             ::aws_smithy_legacy_http_server::operation::Normalize<crate::operation_shape::StartSnapshot, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                         ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::StartSnapshot,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                         HttpPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             Ebs<L>,
                             crate::operation_shape::StartSnapshot,
-888
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                 ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_legacy_http_server::plugin::Plugin<
                                     Ebs<L>,
                                     crate::operation_shape::StartSnapshot,
                                     ModelPl::Output
-894
+                                >
                             >::Output
                         >,
-897
                         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: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
-900
-901
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         use ::aws_smithy_legacy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_legacy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::StartSnapshot::from_service(service);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
         let svc =
             ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
                 .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.start_snapshot_custom(svc)
-911
+    }
-912
     /// Sets the [`StartSnapshot`](crate::operation_shape::StartSnapshot) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn start_snapshot_custom<S>(mut self, svc: S) -> Self
     where
         S: ::tower::Service<
                 ::http::Request<Body>,
                 Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>,
                 Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>,
                 Error = ::std::convert::Infallible,
             > + Clone
             + Send
             + 'static,
         S::Future: Send + 'static,
-925
+    {
         self.start_snapshot = Some(::aws_smithy_http_server::routing::Route::new(svc));
         self.start_snapshot = Some(::aws_smithy_legacy_http_server::routing::Route::new(svc));
         self
-928
+    }
-929
+}
-930
 impl<Body, L, HttpPl, ModelPl> EbsBuilder<Body, L, HttpPl, ModelPl> {
     /// Constructs a [`Ebs`] from the arguments provided to the builder.
     ///
     /// Forgetting to register a handler for one or more operations will result in an error.
     ///
     /// Check out [`EbsBuilder::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<
         Ebs<
             ::aws_smithy_http_server::routing::RoutingService<
                 ::aws_smithy_http_server::protocol::rest::router::RestRouter<L::Service>,
                 ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
             ::aws_smithy_legacy_http_server::routing::RoutingService<
                 ::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<L::Service>,
                 ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
             >,
         >,
         MissingOperationsError,
-948
+    >
     where
         L: ::tower::Layer<::aws_smithy_http_server::routing::Route<Body>>,
         L: ::tower::Layer<::aws_smithy_legacy_http_server::routing::Route<Body>>,
-951
+    {
         let router = {
             use ::aws_smithy_http_server::operation::OperationShape;
             use ::aws_smithy_legacy_http_server::operation::OperationShape;
             let mut missing_operation_names = std::collections::HashMap::new();
             if self.complete_snapshot.is_none() {
                 missing_operation_names.insert(
                     crate::operation_shape::CompleteSnapshot::ID,
                     ".complete_snapshot()",
                 );
-960
+            }
             if self.get_snapshot_block.is_none() {
                 missing_operation_names.insert(
                     crate::operation_shape::GetSnapshotBlock::ID,
                     ".get_snapshot_block()",
                 );
-966
+            }
             if self.list_changed_blocks.is_none() {
                 missing_operation_names.insert(
                     crate::operation_shape::ListChangedBlocks::ID,
                     ".list_changed_blocks()",
                 );
-972
+            }
             if self.list_snapshot_blocks.is_none() {
                 missing_operation_names.insert(
                     crate::operation_shape::ListSnapshotBlocks::ID,
                     ".list_snapshot_blocks()",
                 );
-978
+            }
             if self.put_snapshot_block.is_none() {
                 missing_operation_names.insert(
                     crate::operation_shape::PutSnapshotBlock::ID,
                     ".put_snapshot_block()",
                 );
-984
+            }
             if self.start_snapshot.is_none() {
                 missing_operation_names.insert(
                     crate::operation_shape::StartSnapshot::ID,
                     ".start_snapshot()",
                 );
-990
+            }
             if !missing_operation_names.is_empty() {
                 return Err(MissingOperationsError {
                     operation_names2setter_methods: missing_operation_names,
                 });
-995
+            }
             let unexpected_error_msg = "this should never panic since we are supposed to check beforehand that a handler has been registered for this operation; please file a bug report under https://github.com/smithy-lang/smithy-rs/issues";
-997
             crate::model::SnapshotId::compile_regex();
             crate::model::Description::compile_regex();
             crate::model::OwnerId::compile_regex();
             crate::model::KmsKeyArn::compile_regex();
             crate::model::TagValue::compile_regex();
             crate::model::TagKey::compile_regex();
             crate::model::IdempotencyToken::compile_regex();
             crate::model::Checksum::compile_regex();
             crate::model::BlockToken::compile_regex();
             crate::model::PageToken::compile_regex();
-1008
             ::aws_smithy_http_server::protocol::rest::router::RestRouter::from_iter([
             ::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter::from_iter([
-1010
+                (
                     request_specs::complete_snapshot(),
                     self.complete_snapshot.expect(unexpected_error_msg),
                 ),
-1014
+                (
                     request_specs::get_snapshot_block(),
                     self.get_snapshot_block.expect(unexpected_error_msg),
                 ),
-1018
+                (
                     request_specs::list_changed_blocks(),
                     self.list_changed_blocks.expect(unexpected_error_msg),
                 ),
-1022
+                (
                     request_specs::list_snapshot_blocks(),
                     self.list_snapshot_blocks.expect(unexpected_error_msg),
                 ),
-1026
+                (
                     request_specs::put_snapshot_block(),
                     self.put_snapshot_block.expect(unexpected_error_msg),
                 ),
-1030
+                (
                     request_specs::start_snapshot(),
                     self.start_snapshot.expect(unexpected_error_msg),
                 ),
             ])
         };
         let svc = ::aws_smithy_http_server::routing::RoutingService::new(router);
         let svc = ::aws_smithy_legacy_http_server::routing::RoutingService::new(router);
         let svc = svc.map(|s| s.layer(self.layer));
         Ok(Ebs { svc })
-1039
+    }
-1040
     /// Constructs a [`Ebs`] from the arguments provided to the builder.
     /// Operations without a handler default to returning 500 Internal Server Error to the caller.
     ///
     /// Check out [`EbsBuilder::build`] if you'd prefer the builder to fail if one or more operations do
     /// not have a registered handler.
     pub fn build_unchecked(self) -> Ebs<L::Service>
     where
         Body: Send + 'static,
         L: ::tower::Layer<
             ::aws_smithy_http_server::routing::RoutingService<
                 ::aws_smithy_http_server::protocol::rest::router::RestRouter<
                     ::aws_smithy_http_server::routing::Route<Body>,
             ::aws_smithy_legacy_http_server::routing::RoutingService<
                 ::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<
                     ::aws_smithy_legacy_http_server::routing::Route<Body>,
                 >,
                 ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
                 ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
             >,
         >,
-1057
+    {
         let router = ::aws_smithy_http_server::protocol::rest::router::RestRouter::from_iter([
         let router =
             ::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter::from_iter([
-1060
+                (
                     request_specs::complete_snapshot(),
                     self.complete_snapshot.unwrap_or_else(|| {
                     let svc = ::aws_smithy_http_server::operation::MissingFailure::<
                         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
                         let svc = ::aws_smithy_legacy_http_server::operation::MissingFailure::<
                             ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
                         >::default();
                     ::aws_smithy_http_server::routing::Route::new(svc)
                         ::aws_smithy_legacy_http_server::routing::Route::new(svc)
                     }),
                 ),
-1069
+                (
                     request_specs::get_snapshot_block(),
                     self.get_snapshot_block.unwrap_or_else(|| {
                     let svc = ::aws_smithy_http_server::operation::MissingFailure::<
                         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
                         let svc = ::aws_smithy_legacy_http_server::operation::MissingFailure::<
                             ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
                         >::default();
                     ::aws_smithy_http_server::routing::Route::new(svc)
                         ::aws_smithy_legacy_http_server::routing::Route::new(svc)
                     }),
                 ),
-1078
+                (
                     request_specs::list_changed_blocks(),
                     self.list_changed_blocks.unwrap_or_else(|| {
                     let svc = ::aws_smithy_http_server::operation::MissingFailure::<
                         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
                         let svc = ::aws_smithy_legacy_http_server::operation::MissingFailure::<
                             ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
                         >::default();
                     ::aws_smithy_http_server::routing::Route::new(svc)
                         ::aws_smithy_legacy_http_server::routing::Route::new(svc)
                     }),
                 ),
-1087
+                (
                     request_specs::list_snapshot_blocks(),
                     self.list_snapshot_blocks.unwrap_or_else(|| {
                     let svc = ::aws_smithy_http_server::operation::MissingFailure::<
                         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
                         let svc = ::aws_smithy_legacy_http_server::operation::MissingFailure::<
                             ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
                         >::default();
                     ::aws_smithy_http_server::routing::Route::new(svc)
                         ::aws_smithy_legacy_http_server::routing::Route::new(svc)
                     }),
                 ),
-1096
+                (
                     request_specs::put_snapshot_block(),
                     self.put_snapshot_block.unwrap_or_else(|| {
                     let svc = ::aws_smithy_http_server::operation::MissingFailure::<
                         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
                         let svc = ::aws_smithy_legacy_http_server::operation::MissingFailure::<
                             ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
                         >::default();
                     ::aws_smithy_http_server::routing::Route::new(svc)
                         ::aws_smithy_legacy_http_server::routing::Route::new(svc)
                     }),
                 ),
-1105
+                (
                     request_specs::start_snapshot(),
                     self.start_snapshot.unwrap_or_else(|| {
                     let svc = ::aws_smithy_http_server::operation::MissingFailure::<
                         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
                         let svc = ::aws_smithy_legacy_http_server::operation::MissingFailure::<
                             ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
                         >::default();
                     ::aws_smithy_http_server::routing::Route::new(svc)
                         ::aws_smithy_legacy_http_server::routing::Route::new(svc)
                     }),
                 ),
             ]);
         let svc = self
             .layer
             .layer(::aws_smithy_http_server::routing::RoutingService::new(
                 router,
             ));
             .layer(::aws_smithy_legacy_http_server::routing::RoutingService::new(router));
         Ebs { svc }
-1119
+    }
-1120
+}
-1121
 /// The error encountered when calling the [`EbsBuilder::build`] method if one or more operation handlers are not
 /// specified.
 #[derive(Debug)]
 pub struct MissingOperationsError {
     operation_names2setter_methods:
         std::collections::HashMap<::aws_smithy_http_server::shape_id::ShapeId, &'static str>,
         std::collections::HashMap<::aws_smithy_legacy_http_server::shape_id::ShapeId, &'static str>,
-1128
+}
-1129
 impl std::fmt::Display for MissingOperationsError {
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
         write!(
             f,
             "You must specify a handler for all operations attached to `Ebs`.\n\
                             We are missing handlers for the following operations:\n",
         )?;
         for operation_name in self.operation_names2setter_methods.keys() {
             writeln!(f, "- {}", operation_name.absolute())?;
-1139
+        }
-1140
         writeln!(
             f,
             "\nUse the dedicated methods on `EbsBuilder` to register the missing handlers:"
         )?;
         for setter_name in self.operation_names2setter_methods.values() {
             writeln!(f, "- {}", setter_name)?;
-1147
+        }
         Ok(())
-1149
+    }
-1150
+}
-1151
 impl std::error::Error for MissingOperationsError {}
-1153
 mod request_specs {
     pub(super) fn complete_snapshot() -> ::aws_smithy_http_server::routing::request_spec::RequestSpec
--
+    {
         ::aws_smithy_http_server::routing::request_spec::RequestSpec::new(
     pub(super) fn complete_snapshot(
     ) -> ::aws_smithy_legacy_http_server::routing::request_spec::RequestSpec {
         ::aws_smithy_legacy_http_server::routing::request_spec::RequestSpec::new(
                     ::http::Method::POST,
                     ::aws_smithy_http_server::routing::request_spec::UriSpec::new(
                         ::aws_smithy_http_server::routing::request_spec::PathAndQuerySpec::new(
                             ::aws_smithy_http_server::routing::request_spec::PathSpec::from_vector_unchecked(vec![
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Literal(String::from("snapshots")),
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Literal(String::from("completion")),
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Label,
                     ::aws_smithy_legacy_http_server::routing::request_spec::UriSpec::new(
                         ::aws_smithy_legacy_http_server::routing::request_spec::PathAndQuerySpec::new(
                             ::aws_smithy_legacy_http_server::routing::request_spec::PathSpec::from_vector_unchecked(vec![
     ::aws_smithy_legacy_http_server::routing::request_spec::PathSegment::Literal(String::from("snapshots")),
     ::aws_smithy_legacy_http_server::routing::request_spec::PathSegment::Literal(String::from("completion")),
     ::aws_smithy_legacy_http_server::routing::request_spec::PathSegment::Label,
 ]),
                             ::aws_smithy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
                             ::aws_smithy_legacy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
 ])
-1168
+                        )
                     ),
-1170
+                )
-1171
+    }
     pub(super) fn get_snapshot_block(
     ) -> ::aws_smithy_http_server::routing::request_spec::RequestSpec {
         ::aws_smithy_http_server::routing::request_spec::RequestSpec::new(
     ) -> ::aws_smithy_legacy_http_server::routing::request_spec::RequestSpec {
         ::aws_smithy_legacy_http_server::routing::request_spec::RequestSpec::new(
                     ::http::Method::GET,
                     ::aws_smithy_http_server::routing::request_spec::UriSpec::new(
                         ::aws_smithy_http_server::routing::request_spec::PathAndQuerySpec::new(
                             ::aws_smithy_http_server::routing::request_spec::PathSpec::from_vector_unchecked(vec![
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Literal(String::from("snapshots")),
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Label,
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Literal(String::from("blocks")),
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Label,
                     ::aws_smithy_legacy_http_server::routing::request_spec::UriSpec::new(
                         ::aws_smithy_legacy_http_server::routing::request_spec::PathAndQuerySpec::new(
                             ::aws_smithy_legacy_http_server::routing::request_spec::PathSpec::from_vector_unchecked(vec![
     ::aws_smithy_legacy_http_server::routing::request_spec::PathSegment::Literal(String::from("snapshots")),
     ::aws_smithy_legacy_http_server::routing::request_spec::PathSegment::Label,
     ::aws_smithy_legacy_http_server::routing::request_spec::PathSegment::Literal(String::from("blocks")),
     ::aws_smithy_legacy_http_server::routing::request_spec::PathSegment::Label,
 ]),
                             ::aws_smithy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
                             ::aws_smithy_legacy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
 ])
-1186
+                        )
                     ),
-1188
+                )
-1189
+    }
     pub(super) fn list_changed_blocks(
     ) -> ::aws_smithy_http_server::routing::request_spec::RequestSpec {
         ::aws_smithy_http_server::routing::request_spec::RequestSpec::new(
     ) -> ::aws_smithy_legacy_http_server::routing::request_spec::RequestSpec {
         ::aws_smithy_legacy_http_server::routing::request_spec::RequestSpec::new(
                     ::http::Method::GET,
                     ::aws_smithy_http_server::routing::request_spec::UriSpec::new(
                         ::aws_smithy_http_server::routing::request_spec::PathAndQuerySpec::new(
                             ::aws_smithy_http_server::routing::request_spec::PathSpec::from_vector_unchecked(vec![
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Literal(String::from("snapshots")),
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Label,
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Literal(String::from("changedblocks")),
                     ::aws_smithy_legacy_http_server::routing::request_spec::UriSpec::new(
                         ::aws_smithy_legacy_http_server::routing::request_spec::PathAndQuerySpec::new(
                             ::aws_smithy_legacy_http_server::routing::request_spec::PathSpec::from_vector_unchecked(vec![
     ::aws_smithy_legacy_http_server::routing::request_spec::PathSegment::Literal(String::from("snapshots")),
     ::aws_smithy_legacy_http_server::routing::request_spec::PathSegment::Label,
     ::aws_smithy_legacy_http_server::routing::request_spec::PathSegment::Literal(String::from("changedblocks")),
 ]),
                             ::aws_smithy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
                             ::aws_smithy_legacy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
 ])
-1203
+                        )
                     ),
-1205
+                )
-1206
+    }
     pub(super) fn list_snapshot_blocks(
     ) -> ::aws_smithy_http_server::routing::request_spec::RequestSpec {
         ::aws_smithy_http_server::routing::request_spec::RequestSpec::new(
     ) -> ::aws_smithy_legacy_http_server::routing::request_spec::RequestSpec {
         ::aws_smithy_legacy_http_server::routing::request_spec::RequestSpec::new(
                     ::http::Method::GET,
                     ::aws_smithy_http_server::routing::request_spec::UriSpec::new(
                         ::aws_smithy_http_server::routing::request_spec::PathAndQuerySpec::new(
                             ::aws_smithy_http_server::routing::request_spec::PathSpec::from_vector_unchecked(vec![
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Literal(String::from("snapshots")),
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Label,
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Literal(String::from("blocks")),
                     ::aws_smithy_legacy_http_server::routing::request_spec::UriSpec::new(
                         ::aws_smithy_legacy_http_server::routing::request_spec::PathAndQuerySpec::new(
                             ::aws_smithy_legacy_http_server::routing::request_spec::PathSpec::from_vector_unchecked(vec![
     ::aws_smithy_legacy_http_server::routing::request_spec::PathSegment::Literal(String::from("snapshots")),
     ::aws_smithy_legacy_http_server::routing::request_spec::PathSegment::Label,
     ::aws_smithy_legacy_http_server::routing::request_spec::PathSegment::Literal(String::from("blocks")),
 ]),
                             ::aws_smithy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
                             ::aws_smithy_legacy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
 ])
-1220
+                        )
                     ),
-1222
+                )
-1223
+    }
     pub(super) fn put_snapshot_block(
     ) -> ::aws_smithy_http_server::routing::request_spec::RequestSpec {
         ::aws_smithy_http_server::routing::request_spec::RequestSpec::new(
     ) -> ::aws_smithy_legacy_http_server::routing::request_spec::RequestSpec {
         ::aws_smithy_legacy_http_server::routing::request_spec::RequestSpec::new(
                     ::http::Method::PUT,
                     ::aws_smithy_http_server::routing::request_spec::UriSpec::new(
                         ::aws_smithy_http_server::routing::request_spec::PathAndQuerySpec::new(
                             ::aws_smithy_http_server::routing::request_spec::PathSpec::from_vector_unchecked(vec![
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Literal(String::from("snapshots")),
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Label,
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Literal(String::from("blocks")),
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Label,
                     ::aws_smithy_legacy_http_server::routing::request_spec::UriSpec::new(
                         ::aws_smithy_legacy_http_server::routing::request_spec::PathAndQuerySpec::new(
                             ::aws_smithy_legacy_http_server::routing::request_spec::PathSpec::from_vector_unchecked(vec![
     ::aws_smithy_legacy_http_server::routing::request_spec::PathSegment::Literal(String::from("snapshots")),
     ::aws_smithy_legacy_http_server::routing::request_spec::PathSegment::Label,
     ::aws_smithy_legacy_http_server::routing::request_spec::PathSegment::Literal(String::from("blocks")),
     ::aws_smithy_legacy_http_server::routing::request_spec::PathSegment::Label,
 ]),
                             ::aws_smithy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
                             ::aws_smithy_legacy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
 ])
-1238
+                        )
                     ),
-1240
+                )
-1241
+    }
     pub(super) fn start_snapshot() -> ::aws_smithy_http_server::routing::request_spec::RequestSpec {
         ::aws_smithy_http_server::routing::request_spec::RequestSpec::new(
     pub(super) fn start_snapshot(
     ) -> ::aws_smithy_legacy_http_server::routing::request_spec::RequestSpec {
         ::aws_smithy_legacy_http_server::routing::request_spec::RequestSpec::new(
                     ::http::Method::POST,
                     ::aws_smithy_http_server::routing::request_spec::UriSpec::new(
                         ::aws_smithy_http_server::routing::request_spec::PathAndQuerySpec::new(
                             ::aws_smithy_http_server::routing::request_spec::PathSpec::from_vector_unchecked(vec![
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Literal(String::from("snapshots")),
                     ::aws_smithy_legacy_http_server::routing::request_spec::UriSpec::new(
                         ::aws_smithy_legacy_http_server::routing::request_spec::PathAndQuerySpec::new(
                             ::aws_smithy_legacy_http_server::routing::request_spec::PathSpec::from_vector_unchecked(vec![
     ::aws_smithy_legacy_http_server::routing::request_spec::PathSegment::Literal(String::from("snapshots")),
 ]),
                             ::aws_smithy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
                             ::aws_smithy_legacy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
 ])
-1253
+                        )
                     ),
-1255
+                )
-1256
+    }
-1257
+}
-1258
 /// <p>You can use the Amazon Elastic Block Store (Amazon EBS) direct APIs to create EBS snapshots, write data directly to your snapshots, read data on your snapshots, and identify the differences or changes between two snapshots. If you’re an independent software vendor (ISV) who offers backup services for Amazon EBS, the EBS direct APIs make it more efficient and cost-effective to track incremental changes on your EBS volumes through snapshots. This can be done without having to create new volumes from snapshots, and then use Amazon Elastic Compute Cloud (Amazon EC2) instances to compare the differences.</p>
 /// <p>You can create incremental snapshots directly from data on-premises into EBS volumes and the cloud to use for quick disaster recovery. With the ability to write and read snapshots, you can write your on-premises data to an EBS snapshot during a disaster. Then after recovery, you can restore it back to AWS or on-premises from the snapshot. You no longer need to build and maintain complex mechanisms to copy data to and from Amazon EBS.</p>
 /// <p>This API reference provides detailed information about the actions, data types, parameters, and errors of the EBS direct APIs. For more information about the elements that make up the EBS direct APIs, and examples of how to use them effectively, see <a href="https://docs.aws.amazon.com/AWSEC2/latest/UserGuide/ebs-accessing-snapshot.html">Accessing the Contents of an EBS Snapshot</a> in the <i>Amazon Elastic Compute Cloud User Guide</i>. For more information about the supported AWS Regions, endpoints, and service quotas for the EBS direct APIs, see <a href="https://docs.aws.amazon.com/general/latest/gr/ebs-service.html">Amazon Elastic Block Store Endpoints and Quotas</a> in the <i>AWS General Reference</i>.</p>
 ///
 /// See the [root](crate) documentation for more information.
 #[derive(Clone)]
 pub struct Ebs<
     S = ::aws_smithy_http_server::routing::RoutingService<
         ::aws_smithy_http_server::protocol::rest::router::RestRouter<
             ::aws_smithy_http_server::routing::Route<::aws_smithy_http_server::body::BoxBody>,
     S = ::aws_smithy_legacy_http_server::routing::RoutingService<
         ::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<
             ::aws_smithy_legacy_http_server::routing::Route<
                 ::aws_smithy_legacy_http_server::body::BoxBody,
             >,
         >,
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
     >,
 > {
     // This is the router wrapped by layers.
     svc: S,
-1277
+}
-1278
 impl Ebs<()> {
     /// Constructs a builder for [`Ebs`].
     /// You must specify a configuration object holding any plugins and layers that should be applied
     /// to the operations in this service.
     pub fn builder<
         Body,
         L,
         HttpPl: ::aws_smithy_http_server::plugin::HttpMarker,
         ModelPl: ::aws_smithy_http_server::plugin::ModelMarker,
         HttpPl: ::aws_smithy_legacy_http_server::plugin::HttpMarker,
         ModelPl: ::aws_smithy_legacy_http_server::plugin::ModelMarker,
     >(
         config: EbsConfig<L, HttpPl, ModelPl>,
     ) -> EbsBuilder<Body, L, HttpPl, ModelPl> {
         EbsBuilder {
             complete_snapshot: None,
             get_snapshot_block: None,
             list_changed_blocks: None,
             list_snapshot_blocks: None,
             put_snapshot_block: None,
             start_snapshot: None,
             layer: config.layers,
             http_plugin: config.http_plugins,
             model_plugin: config.model_plugins,
-1301
+        }
-1302
+    }
-1303
     /// Constructs a builder for [`Ebs`].
     /// You must specify what plugins should be applied to the operations in this service.
     ///
     /// Use [`Ebs::builder_without_plugins`] if you don't need to apply plugins.
     ///
     /// Check out [`HttpPlugins`](::aws_smithy_http_server::plugin::HttpPlugins) and
     /// [`ModelPlugins`](::aws_smithy_http_server::plugin::ModelPlugins) if you need to apply
     /// Check out [`HttpPlugins`](::aws_smithy_legacy_http_server::plugin::HttpPlugins) and
     /// [`ModelPlugins`](::aws_smithy_legacy_http_server::plugin::ModelPlugins) if you need to apply
     /// multiple plugins.
     #[deprecated(
         since = "0.57.0",
         note = "please use the `builder` constructor and register plugins on the `EbsConfig` object instead; see https://github.com/smithy-lang/smithy-rs/discussions/3096"
     )]
     pub fn builder_with_plugins<
         Body,
         HttpPl: ::aws_smithy_http_server::plugin::HttpMarker,
         ModelPl: ::aws_smithy_http_server::plugin::ModelMarker,
         HttpPl: ::aws_smithy_legacy_http_server::plugin::HttpMarker,
         ModelPl: ::aws_smithy_legacy_http_server::plugin::ModelMarker,
     >(
         http_plugin: HttpPl,
         model_plugin: ModelPl,
     ) -> EbsBuilder<Body, ::tower::layer::util::Identity, HttpPl, ModelPl> {
         EbsBuilder {
             complete_snapshot: None,
             get_snapshot_block: None,
             list_changed_blocks: None,
             list_snapshot_blocks: None,
             put_snapshot_block: None,
             start_snapshot: None,
             layer: ::tower::layer::util::Identity::new(),
             http_plugin,
             model_plugin,
-1334
+        }
-1335
+    }
-1336
     /// Constructs a builder for [`Ebs`].
     ///
     /// Use [`Ebs::builder_with_plugins`] if you need to specify plugins.
     #[deprecated(
         since = "0.57.0",
         note = "please use the `builder` constructor instead; see https://github.com/smithy-lang/smithy-rs/discussions/3096"
     )]
     pub fn builder_without_plugins<Body>() -> EbsBuilder<
         Body,
         ::tower::layer::util::Identity,
         ::aws_smithy_http_server::plugin::IdentityPlugin,
         ::aws_smithy_http_server::plugin::IdentityPlugin,
         ::aws_smithy_legacy_http_server::plugin::IdentityPlugin,
         ::aws_smithy_legacy_http_server::plugin::IdentityPlugin,
     > {
         Self::builder_with_plugins(
             ::aws_smithy_http_server::plugin::IdentityPlugin,
             ::aws_smithy_http_server::plugin::IdentityPlugin,
             ::aws_smithy_legacy_http_server::plugin::IdentityPlugin,
             ::aws_smithy_legacy_http_server::plugin::IdentityPlugin,
-1353
+        )
-1354
+    }
-1355
+}
-1356
 impl<S> Ebs<S> {
     /// Converts [`Ebs`] into a [`MakeService`](tower::make::MakeService).
     pub fn into_make_service(self) -> ::aws_smithy_http_server::routing::IntoMakeService<Self> {
         ::aws_smithy_http_server::routing::IntoMakeService::new(self)
     pub fn into_make_service(
         self,
     ) -> ::aws_smithy_legacy_http_server::routing::IntoMakeService<Self> {
         ::aws_smithy_legacy_http_server::routing::IntoMakeService::new(self)
-1363
+    }
-1364
     /// Converts [`Ebs`] into a [`MakeService`](tower::make::MakeService) with [`ConnectInfo`](::aws_smithy_http_server::request::connect_info::ConnectInfo).
     /// Converts [`Ebs`] into a [`MakeService`](tower::make::MakeService) with [`ConnectInfo`](::aws_smithy_legacy_http_server::request::connect_info::ConnectInfo).
     pub fn into_make_service_with_connect_info<C>(
         self,
     ) -> ::aws_smithy_http_server::routing::IntoMakeServiceWithConnectInfo<Self, C> {
         ::aws_smithy_http_server::routing::IntoMakeServiceWithConnectInfo::new(self)
     ) -> ::aws_smithy_legacy_http_server::routing::IntoMakeServiceWithConnectInfo<Self, C> {
         ::aws_smithy_legacy_http_server::routing::IntoMakeServiceWithConnectInfo::new(self)
-1370
+    }
-1371
+}
-1372
 impl<S>
     Ebs<
         ::aws_smithy_http_server::routing::RoutingService<
             ::aws_smithy_http_server::protocol::rest::router::RestRouter<S>,
             ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         ::aws_smithy_legacy_http_server::routing::RoutingService<
             ::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<S>,
             ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
         >,
-1379
+    >
-1380
+{
     /// Applies a [`Layer`](::tower::Layer) uniformly to all routes.
     #[deprecated(
         since = "0.57.0",
         note = "please add layers to the `EbsConfig` object instead; see https://github.com/smithy-lang/smithy-rs/discussions/3096"
     )]
     pub fn layer<L>(
         self,
         layer: &L,
     ) -> Ebs<
         ::aws_smithy_http_server::routing::RoutingService<
             ::aws_smithy_http_server::protocol::rest::router::RestRouter<L::Service>,
             ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         ::aws_smithy_legacy_http_server::routing::RoutingService<
             ::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<L::Service>,
             ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
         >,
-1394
+    >
     where
         L: ::tower::Layer<S>,
-1397
+    {
         Ebs {
             svc: self.svc.map(|s| s.layer(layer)),
-1400
+        }
-1401
+    }
-1402
     /// Applies [`Route::new`](::aws_smithy_http_server::routing::Route::new) to all routes.
     /// Applies [`Route::new`](::aws_smithy_legacy_http_server::routing::Route::new) to all routes.
     ///
     /// This has the effect of erasing all types accumulated via layers.
     pub fn boxed<B>(
         self,
     ) -> Ebs<
         ::aws_smithy_http_server::routing::RoutingService<
             ::aws_smithy_http_server::protocol::rest::router::RestRouter<
                 ::aws_smithy_http_server::routing::Route<B>,
         ::aws_smithy_legacy_http_server::routing::RoutingService<
             ::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<
                 ::aws_smithy_legacy_http_server::routing::Route<B>,
             >,
             ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
             ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
         >,
-1415
+    >
     where
         S: ::tower::Service<
             ::http::Request<B>,
             Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>,
             Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>,
             Error = std::convert::Infallible,
         >,
         S: Clone + Send + 'static,
         S::Future: Send + 'static,
-1424
+    {
         self.layer(&::tower::layer::layer_fn(
             ::aws_smithy_http_server::routing::Route::new,
             ::aws_smithy_legacy_http_server::routing::Route::new,
         ))
-1428
+    }
-1429
+}
-1430
 impl<S, R> ::tower::Service<R> for Ebs<S>
 where
     S: ::tower::Service<R>,
-1434
+{
     type Response = S::Response;
     type Error = S::Error;
     type Future = S::Future;
-1438
     fn poll_ready(
         &mut self,
         cx: &mut std::task::Context,
     ) -> std::task::Poll<::std::result::Result<(), Self::Error>> {
         self.svc.poll_ready(cx)
-1444
+    }
-1445
     fn call(&mut self, request: R) -> Self::Future {
         self.svc.call(request)
-1448
+    }
-1449
+}
-1450
 /// An enumeration of all [operations](https://smithy.io/2.0/spec/service-types.html#operation) in Ebs.
 #[allow(clippy::enum_variant_names)]
 #[derive(Debug, PartialEq, Eq, Clone, Copy)]
 pub enum Operation {
     CompleteSnapshot,
     GetSnapshotBlock,
     ListChangedBlocks,
     ListSnapshotBlocks,
     PutSnapshotBlock,
     StartSnapshot,
-1461
+}
-1462
 impl Operation {
     /// Returns the [operations](https://smithy.io/2.0/spec/service-types.html#operation) [`ShapeId`](::aws_smithy_http_server::shape_id::ShapeId).
     pub fn shape_id(&self) -> ::aws_smithy_http_server::shape_id::ShapeId {
     /// Returns the [operations](https://smithy.io/2.0/spec/service-types.html#operation) [`ShapeId`](::aws_smithy_legacy_http_server::shape_id::ShapeId).
     pub fn shape_id(&self) -> ::aws_smithy_legacy_http_server::shape_id::ShapeId {
         match self {
             Operation::CompleteSnapshot => ::aws_smithy_http_server::shape_id::ShapeId::new(
             Operation::CompleteSnapshot => ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
                 "com.amazonaws.ebs#CompleteSnapshot",
                 "com.amazonaws.ebs",
                 "CompleteSnapshot",
             ),
             Operation::GetSnapshotBlock => ::aws_smithy_http_server::shape_id::ShapeId::new(
             Operation::GetSnapshotBlock => ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
                 "com.amazonaws.ebs#GetSnapshotBlock",
                 "com.amazonaws.ebs",
                 "GetSnapshotBlock",
             ),
             Operation::ListChangedBlocks => ::aws_smithy_http_server::shape_id::ShapeId::new(
             Operation::ListChangedBlocks => {
                 ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
                     "com.amazonaws.ebs#ListChangedBlocks",
                     "com.amazonaws.ebs",
                     "ListChangedBlocks",
             ),
             Operation::ListSnapshotBlocks => ::aws_smithy_http_server::shape_id::ShapeId::new(
-+
+                )
-+
+            }
             Operation::ListSnapshotBlocks => {
                 ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
                     "com.amazonaws.ebs#ListSnapshotBlocks",
                     "com.amazonaws.ebs",
                     "ListSnapshotBlocks",
             ),
             Operation::PutSnapshotBlock => ::aws_smithy_http_server::shape_id::ShapeId::new(
-+
+                )
-+
+            }
             Operation::PutSnapshotBlock => ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
                 "com.amazonaws.ebs#PutSnapshotBlock",
                 "com.amazonaws.ebs",
                 "PutSnapshotBlock",
             ),
             Operation::StartSnapshot => ::aws_smithy_http_server::shape_id::ShapeId::new(
             Operation::StartSnapshot => ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
                 "com.amazonaws.ebs#StartSnapshot",
                 "com.amazonaws.ebs",
                 "StartSnapshot",
             ),
-1501
+        }
-1502
+    }
-1503
+}
 impl<L>
     ::aws_smithy_http_server::service::ContainsOperation<crate::operation_shape::CompleteSnapshot>
     for Ebs<L>
     ::aws_smithy_legacy_http_server::service::ContainsOperation<
         crate::operation_shape::CompleteSnapshot,
     > for Ebs<L>
-1508
+{
     const VALUE: Operation = Operation::CompleteSnapshot;
-1510
+}
 impl<L>
     ::aws_smithy_http_server::service::ContainsOperation<crate::operation_shape::GetSnapshotBlock>
     for Ebs<L>
     ::aws_smithy_legacy_http_server::service::ContainsOperation<
         crate::operation_shape::GetSnapshotBlock,
     > for Ebs<L>
-1515
+{
     const VALUE: Operation = Operation::GetSnapshotBlock;
-1517
+}
 impl<L>
     ::aws_smithy_http_server::service::ContainsOperation<crate::operation_shape::ListChangedBlocks>
     for Ebs<L>
     ::aws_smithy_legacy_http_server::service::ContainsOperation<
         crate::operation_shape::ListChangedBlocks,
     > for Ebs<L>
-1522
+{
     const VALUE: Operation = Operation::ListChangedBlocks;
-1524
+}
 impl<L>
     ::aws_smithy_http_server::service::ContainsOperation<crate::operation_shape::ListSnapshotBlocks>
     for Ebs<L>
     ::aws_smithy_legacy_http_server::service::ContainsOperation<
         crate::operation_shape::ListSnapshotBlocks,
     > for Ebs<L>
-1529
+{
     const VALUE: Operation = Operation::ListSnapshotBlocks;
-1531
+}
 impl<L>
     ::aws_smithy_http_server::service::ContainsOperation<crate::operation_shape::PutSnapshotBlock>
     for Ebs<L>
     ::aws_smithy_legacy_http_server::service::ContainsOperation<
         crate::operation_shape::PutSnapshotBlock,
     > for Ebs<L>
-1536
+{
     const VALUE: Operation = Operation::PutSnapshotBlock;
-1538
+}
 impl<L> ::aws_smithy_http_server::service::ContainsOperation<crate::operation_shape::StartSnapshot>
     for Ebs<L>
 impl<L>
     ::aws_smithy_legacy_http_server::service::ContainsOperation<
         crate::operation_shape::StartSnapshot,
     > for Ebs<L>
-1543
+{
     const VALUE: Operation = Operation::StartSnapshot;
-1545
+}
-1546
 impl<S> ::aws_smithy_http_server::service::ServiceShape for Ebs<S> {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
 impl<S> ::aws_smithy_legacy_http_server::service::ServiceShape for Ebs<S> {
     const ID: ::aws_smithy_legacy_http_server::shape_id::ShapeId =
         ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
             "com.amazonaws.ebs#Ebs",
             "com.amazonaws.ebs",
             "Ebs",
         );
-1554
     const VERSION: Option<&'static str> = Some("2019-11-02");
-1556
     type Protocol = ::aws_smithy_http_server::protocol::rest_json_1::RestJson1;
     type Protocol = ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1;
-1558
     type Operations = Operation;
-1560
+}
 /// Configuration for the [`Ebs`]. This is the central place where to register and
 /// configure [`::tower::Layer`]s, HTTP plugins, and model plugins.
 ///
 /// ```rust,no_run
 /// # use ebs::EbsConfig;
 /// # use ::aws_smithy_http_server::plugin::IdentityPlugin;
 /// # use ::aws_smithy_legacy_http_server::plugin::IdentityPlugin;
 /// # use ::tower::layer::util::Identity;
 /// # let authentication_plugin = IdentityPlugin;
 /// # let authorization_plugin = IdentityPlugin;
 /// # let server_request_id_provider_layer = Identity::new();
 /// let config = EbsConfig::builder()
 ///     // Layers get executed first...
 ///     .layer(server_request_id_provider_layer)
 ///     // ...then HTTP plugins...
 ///     .http_plugin(authentication_plugin)
 ///     // ...and right after deserialization, model plugins.
 ///     .model_plugin(authorization_plugin)
 ///     .build();
 /// ```
 ///
 /// See the [`plugin`] system for details.
 ///
 /// [`plugin`]: ::aws_smithy_http_server::plugin
 /// [`plugin`]: ::aws_smithy_legacy_http_server::plugin
 #[derive(::std::fmt::Debug)]
 pub struct EbsConfig<L, H, M> {
     layers: L,
     http_plugins: H,
     model_plugins: M,
-1589
+}
-1590
 impl EbsConfig<(), (), ()> {
     /// Returns a builder to construct the configuration.
     pub fn builder() -> EbsConfigBuilder<
         ::tower::layer::util::Identity,
         ::aws_smithy_http_server::plugin::IdentityPlugin,
         ::aws_smithy_http_server::plugin::IdentityPlugin,
         ::aws_smithy_legacy_http_server::plugin::IdentityPlugin,
         ::aws_smithy_legacy_http_server::plugin::IdentityPlugin,
     > {
         EbsConfigBuilder {
             layers: ::tower::layer::util::Identity::new(),
             http_plugins: ::aws_smithy_http_server::plugin::IdentityPlugin,
             model_plugins: ::aws_smithy_http_server::plugin::IdentityPlugin,
             http_plugins: ::aws_smithy_legacy_http_server::plugin::IdentityPlugin,
             model_plugins: ::aws_smithy_legacy_http_server::plugin::IdentityPlugin,
-1602
+        }
-1603
+    }
-1604
+}
-1605
 /// Builder returned by [`EbsConfig::builder()`].
 #[derive(::std::fmt::Debug)]
 pub struct EbsConfigBuilder<L, H, M> {
     pub(crate) layers: L,
     pub(crate) http_plugins: H,
     pub(crate) model_plugins: M,
-1612
+}
-1613
 impl<L, H, M> EbsConfigBuilder<L, H, M> {
     /// Add a [`::tower::Layer`] to the service.
     pub fn layer<NewLayer>(
         self,
         layer: NewLayer,
     ) -> EbsConfigBuilder<::tower::layer::util::Stack<NewLayer, L>, H, M> {
         EbsConfigBuilder {
             layers: ::tower::layer::util::Stack::new(layer, self.layers),
             http_plugins: self.http_plugins,
             model_plugins: self.model_plugins,
-1624
+        }
-1625
+    }
-1626
     /// Add a HTTP [plugin] to the service.
     ///
     /// [plugin]: ::aws_smithy_http_server::plugin
     /// [plugin]: ::aws_smithy_legacy_http_server::plugin
     // We eagerly require `NewPlugin: HttpMarker`, despite not really needing it, because compiler
     // errors get _substantially_ better if the user makes a mistake.
     pub fn http_plugin<NewPlugin: ::aws_smithy_http_server::plugin::HttpMarker>(
     pub fn http_plugin<NewPlugin: ::aws_smithy_legacy_http_server::plugin::HttpMarker>(
         self,
         http_plugin: NewPlugin,
     ) -> EbsConfigBuilder<L, ::aws_smithy_http_server::plugin::PluginStack<NewPlugin, H>, M> {
     ) -> EbsConfigBuilder<L, ::aws_smithy_legacy_http_server::plugin::PluginStack<NewPlugin, H>, M>
-+
+    {
         EbsConfigBuilder {
             layers: self.layers,
             http_plugins: ::aws_smithy_http_server::plugin::PluginStack::new(
             http_plugins: ::aws_smithy_legacy_http_server::plugin::PluginStack::new(
                 http_plugin,
                 self.http_plugins,
             ),
             model_plugins: self.model_plugins,
-1644
+        }
-1645
+    }
-1646
     /// Add a model [plugin] to the service.
     ///
     /// [plugin]: ::aws_smithy_http_server::plugin
     /// [plugin]: ::aws_smithy_legacy_http_server::plugin
     // We eagerly require `NewPlugin: ModelMarker`, despite not really needing it, because compiler
     // errors get _substantially_ better if the user makes a mistake.
     pub fn model_plugin<NewPlugin: ::aws_smithy_http_server::plugin::ModelMarker>(
     pub fn model_plugin<NewPlugin: ::aws_smithy_legacy_http_server::plugin::ModelMarker>(
         self,
         model_plugin: NewPlugin,
     ) -> EbsConfigBuilder<L, H, ::aws_smithy_http_server::plugin::PluginStack<NewPlugin, M>> {
     ) -> EbsConfigBuilder<L, H, ::aws_smithy_legacy_http_server::plugin::PluginStack<NewPlugin, M>>
-+
+    {
         EbsConfigBuilder {
             layers: self.layers,
             http_plugins: self.http_plugins,
             model_plugins: ::aws_smithy_http_server::plugin::PluginStack::new(
             model_plugins: ::aws_smithy_legacy_http_server::plugin::PluginStack::new(
                 model_plugin,
                 self.model_plugins,
             ),
-1664
+        }
-1665
+    }
-1666
     /// Build the configuration.
     pub fn build(self) -> super::EbsConfig<L, H, M> {
         super::EbsConfig {
             layers: self.layers,

↧ Expand context

             http_plugins: self.http_plugins,
             model_plugins: self.model_plugins,
-1673
+        }
-1674
+    }
-1675
+}
 /// A macro to help with scoping [plugins](crate::server::plugin) to a subset of all operations.
 ///
 /// In contrast to [`crate::server::scope`](crate::server::scope), this macro has knowledge
 /// of the service and any operations _not_ specified will be placed in the opposing group.
 ///
 /// # Example
 ///
 /// ```rust
 /// scope! {
 ///     /// Includes [`CompleteSnapshot`], excluding all other operations.
 ///     struct ScopeA {
 ///         includes: [CompleteSnapshot]
 ///     }
 /// }
 ///

tmp-codegen-diff/codegen-server-test-python/json_rpc10/rust-server-codegen-python/Cargo.toml

@@ -1,1 +59,59 @@

↥ Expand context

 [package]
 name = "json_rpc10"
 version = "0.0.1"
 authors = ["protocoltest@example.com"]
 description = "test"
 edition = "2021"
-8
 [package.metadata.smithy]
 codegen-version = "ci"
 protocol = "aws.protocols#awsJson1_0"
 [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-http-server-python]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-http-server-python"
 [dependencies.aws-smithy-json]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-json"
 [dependencies.aws-smithy-legacy-http]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-legacy-http"
 [dependencies.aws-smithy-legacy-http-server]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-legacy-http-server"
 [dependencies.aws-smithy-runtime-api]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-runtime-api"
 features = ["http-02x"]
 [dependencies.aws-smithy-types]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-types"
 features = ["http-body-0-4-x"]
 [dependencies.futures-util]
 version = "0.3"
 [dependencies.http]
 version = "0.2.9"
 [dependencies.hyper]
 version = "0.14.26"
 [dependencies.mime]
 version = "0.3"
 [dependencies.parking_lot]
 version = "0.12"
 [dependencies.pin-project-lite]
 version = "0.2"
 [dependencies.pyo3]
 version = "0.20"
 [dependencies.pyo3-asyncio]
 version = "0.20"
 features = ["attributes", "tokio-runtime"]
 [dependencies.tower]
 version = "0.4"
 [dependencies.tracing]
 version = "0.1"
 [dev-dependencies.hyper]
 version = "0.14.12"
 [dev-dependencies.tokio]
 version = "1.23.1"
 [features]
 rt-tokio = ["aws-smithy-types/rt-tokio"]
 aws-lambda = ["aws-smithy-http-server/aws-lambda"]
 request-id = ["aws-smithy-http-server/request-id"]
 aws-lambda = ["aws-smithy-legacy-http-server/aws-lambda"]
 request-id = ["aws-smithy-legacy-http-server/request-id"]
 extension-module = ["pyo3/extension-module"]
 default = ["rt-tokio", "request-id", "extension-module"]
 [lib]
 name = "json_rpc10"
 crate-type = ["cdylib"]
-58
-59

tmp-codegen-diff/codegen-server-test-python/json_rpc10/rust-server-codegen-python/python/json_rpc10/middleware/init.pyi

@@ -1,1 +38,38 @@

 import typing
-2
 class MiddlewareException(Exception):
     """
     Exception that can be thrown from a Python middleware.
-6
     It allows to specify a message and HTTP status code and implementing protocol specific capabilities
     to build a [aws_smithy_http_server::response::Response] from it.
     to build a [aws_smithy_legacy_http_server::response::Response] from it.
     """
-10
     message: str
-12
     status_code: int
-14
     def __init__(self, message: str, status_code: typing.Optional[int] = ...) -> None:
         ...
-17
-18

↧ Expand context

 class Request:
     """
     Python-compatible [Request] object.
     """
-23
     body: typing.Awaitable[bytes]
     """
     Return the HTTP body of this request.
     Note that this is a costly operation because the whole request body is cloned.
     """
-29
     headers: typing.MutableMapping[str, str]
     """
     Return the HTTP headers of this request.
     """
-34
     method: str
     """
     Return the HTTP method of this request.
     """

tmp-codegen-diff/codegen-server-test-python/json_rpc10/rust-server-codegen-python/src/input.rs

@@ -957,957 +1017,1017 @@

↥ Expand context

         /// `top_level` was not provided but it is required when building `OperationWithNestedStructureInput`.
         MissingTopLevel,
         /// Constraint violation occurred building member `top_level` when building `OperationWithNestedStructureInput`.
         #[doc(hidden)]
         TopLevel(crate::model::top_level_internal::ConstraintViolation),
-962
+    }
     impl ::std::fmt::Display for ConstraintViolation {
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             match self {
                 ConstraintViolation::MissingTopLevel => write!(f, "`top_level` was not provided but it is required when building `OperationWithNestedStructureInput`"),
                 ConstraintViolation::TopLevel(_) => write!(f, "constraint violation occurred building member `top_level` when building `OperationWithNestedStructureInput`"),
-968
+            }
-969
+        }
-970
+    }
     impl ::std::error::Error for ConstraintViolation {}
     impl ConstraintViolation {
         pub(crate) fn as_validation_exception_field(
             self,
             path: ::std::string::String,
         ) -> crate::model::ValidationExceptionField {

             match self {
             ConstraintViolation::MissingTopLevel => crate::model::ValidationExceptionField {
                                                 message: format!("Value at '{}/topLevel' failed to satisfy constraint: Member must not be null", path),
                                                 path: path + "/topLevel",
                                             },
             ConstraintViolation::TopLevel(inner) => inner.as_validation_exception_field(path + "/topLevel"),
-983
+        }
-984
+        }
-985
+    }
     impl ::std::convert::From<ConstraintViolation>
         for ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection
         for ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection
-988
+    {
         fn from(constraint_violation: ConstraintViolation) -> Self {
             let first_validation_exception_field =
                 constraint_violation.as_validation_exception_field("".to_owned());
             let validation_exception = crate::error::ValidationException {
                 message: format!(
                     "1 validation error detected. {}",
                     &first_validation_exception_field.message
                 ),
                 field_list: Some(vec![first_validation_exception_field]),

↧ Expand context

             };
             Self::ConstraintViolation(
                                 crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(&validation_exception)
                                     .expect("validation exceptions should never fail to serialize; please file a bug report under https://github.com/smithy-lang/smithy-rs/issues")
-1002
+                            )
-1003
+        }
-1004
+    }
     impl ::std::convert::From<Builder>
         for crate::constrained::MaybeConstrained<crate::input::OperationWithNestedStructureInput>
-1007
+    {
         fn from(builder: Builder) -> Self {
             Self::Unconstrained(builder)
-1010
+        }
-1011
+    }
     impl ::std::convert::TryFrom<Builder> for crate::input::OperationWithNestedStructureInput {
         type Error = ConstraintViolation;
-1014
         fn try_from(builder: Builder) -> ::std::result::Result<Self, Self::Error> {
             builder.build()
-1017
+        }

@@ -1166,1166 +1226,1226 @@

↥ Expand context

     #[derive(::std::cmp::PartialEq, ::std::fmt::Debug)]
     /// Holds one variant for each of the ways the builder can fail.
     #[non_exhaustive]
     #[allow(clippy::enum_variant_names)]
     pub(crate) enum ConstraintViolation {
         /// Constraint violation occurred building member `defaults` when building `OperationWithDefaultsInput`.
         #[doc(hidden)]
         Defaults(crate::model::defaults_internal::ConstraintViolation),
-1174
+    }
     impl ::std::fmt::Display for ConstraintViolation {
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             match self {
                 ConstraintViolation::Defaults(_) => write!(f, "constraint violation occurred building member `defaults` when building `OperationWithDefaultsInput`"),
-1179
+            }
-1180
+        }
-1181
+    }
     impl ::std::error::Error for ConstraintViolation {}
     impl ConstraintViolation {
         pub(crate) fn as_validation_exception_field(
             self,

             path: ::std::string::String,
         ) -> crate::model::ValidationExceptionField {
             match self {
                 ConstraintViolation::Defaults(inner) => {
                     inner.as_validation_exception_field(path + "/defaults")
-1191
+                }
-1192
+            }
-1193
+        }
-1194
+    }
     impl ::std::convert::From<ConstraintViolation>
         for ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection
         for ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection
-1197
+    {
         fn from(constraint_violation: ConstraintViolation) -> Self {
             let first_validation_exception_field =
                 constraint_violation.as_validation_exception_field("".to_owned());
             let validation_exception = crate::error::ValidationException {
                 message: format!(
                     "1 validation error detected. {}",
                     &first_validation_exception_field.message
                 ),
                 field_list: Some(vec![first_validation_exception_field]),

↧ Expand context

             };
             Self::ConstraintViolation(
                                 crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(&validation_exception)
                                     .expect("validation exceptions should never fail to serialize; please file a bug report under https://github.com/smithy-lang/smithy-rs/issues")
-1211
+                            )
-1212
+        }
-1213
+    }
     impl ::std::convert::From<Builder>
         for crate::constrained::MaybeConstrained<crate::input::OperationWithDefaultsInput>
-1216
+    {
         fn from(builder: Builder) -> Self {
             Self::Unconstrained(builder)
-1219
+        }
-1220
+    }
     impl ::std::convert::TryFrom<Builder> for crate::input::OperationWithDefaultsInput {
         type Error = ConstraintViolation;
-1223
         fn try_from(builder: Builder) -> ::std::result::Result<Self, Self::Error> {
             builder.build()
-1226
+        }

@@ -1548,1548 +1608,1608 @@

↥ Expand context

     #[allow(clippy::enum_variant_names)]
     pub(crate) enum ConstraintViolation {
         /// `label` was not provided but it is required when building `EndpointWithHostLabelOperationInput`.
         MissingLabel,
-1552
+    }
     impl ::std::fmt::Display for ConstraintViolation {
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             match self {
                 ConstraintViolation::MissingLabel => write!(f, "`label` was not provided but it is required when building `EndpointWithHostLabelOperationInput`"),
-1557
+            }
-1558
+        }
-1559
+    }
     impl ::std::error::Error for ConstraintViolation {}
     impl ConstraintViolation {
         pub(crate) fn as_validation_exception_field(
             self,
             path: ::std::string::String,
         ) -> crate::model::ValidationExceptionField {
             match self {
                 ConstraintViolation::MissingLabel => crate::model::ValidationExceptionField {

                     message: format!(
                         "Value at '{}/label' failed to satisfy constraint: Member must not be null",
                         path
                     ),
                     path: path + "/label",
                 },
-1574
+            }
-1575
+        }
-1576
+    }
     impl ::std::convert::From<ConstraintViolation>
         for ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection
         for ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection
-1579
+    {
         fn from(constraint_violation: ConstraintViolation) -> Self {
             let first_validation_exception_field =
                 constraint_violation.as_validation_exception_field("".to_owned());
             let validation_exception = crate::error::ValidationException {
                 message: format!(
                     "1 validation error detected. {}",
                     &first_validation_exception_field.message
                 ),
                 field_list: Some(vec![first_validation_exception_field]),

↧ Expand context

             };
             Self::ConstraintViolation(
                                 crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(&validation_exception)
                                     .expect("validation exceptions should never fail to serialize; please file a bug report under https://github.com/smithy-lang/smithy-rs/issues")
-1593
+                            )
-1594
+        }
-1595
+    }
     impl ::std::convert::From<Builder>
         for crate::constrained::MaybeConstrained<crate::input::EndpointWithHostLabelOperationInput>
-1598
+    {
         fn from(builder: Builder) -> Self {
             Self::Unconstrained(builder)
-1601
+        }
-1602
+    }
     impl ::std::convert::TryFrom<Builder> for crate::input::EndpointWithHostLabelOperationInput {
         type Error = ConstraintViolation;
-1605
         fn try_from(builder: Builder) -> ::std::result::Result<Self, Self::Error> {
             builder.build()
-1608
+        }

@@ -1745,1745 +1805,1805 @@

↥ Expand context

     #[derive(::std::cmp::PartialEq, ::std::fmt::Debug)]
     /// Holds one variant for each of the ways the builder can fail.
     #[non_exhaustive]
     #[allow(clippy::enum_variant_names)]
     pub(crate) enum ConstraintViolation {
         /// Constraint violation occurred building member `contents` when building `JsonUnionsInput`.
         #[doc(hidden)]
         Contents(crate::model::my_union_internal::ConstraintViolation),
-1753
+    }
     impl ::std::fmt::Display for ConstraintViolation {
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             match self {
                 ConstraintViolation::Contents(_) => write!(f, "constraint violation occurred building member `contents` when building `JsonUnionsInput`"),
-1758
+            }
-1759
+        }
-1760
+    }
     impl ::std::error::Error for ConstraintViolation {}
     impl ConstraintViolation {
         pub(crate) fn as_validation_exception_field(
             self,

             path: ::std::string::String,
         ) -> crate::model::ValidationExceptionField {
             match self {
                 ConstraintViolation::Contents(inner) => {
                     inner.as_validation_exception_field(path + "/contents")
-1770
+                }
-1771
+            }
-1772
+        }
-1773
+    }
     impl ::std::convert::From<ConstraintViolation>
         for ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection
         for ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection
-1776
+    {
         fn from(constraint_violation: ConstraintViolation) -> Self {
             let first_validation_exception_field =
                 constraint_violation.as_validation_exception_field("".to_owned());
             let validation_exception = crate::error::ValidationException {
                 message: format!(
                     "1 validation error detected. {}",
                     &first_validation_exception_field.message
                 ),
                 field_list: Some(vec![first_validation_exception_field]),

↧ Expand context

             };
             Self::ConstraintViolation(
                                 crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(&validation_exception)
                                     .expect("validation exceptions should never fail to serialize; please file a bug report under https://github.com/smithy-lang/smithy-rs/issues")
-1790
+                            )
-1791
+        }
-1792
+    }
     impl ::std::convert::From<Builder>
         for crate::constrained::MaybeConstrained<crate::input::JsonUnionsInput>
-1795
+    {
         fn from(builder: Builder) -> Self {
             Self::Unconstrained(builder)
-1798
+        }
-1799
+    }
     impl ::std::convert::TryFrom<Builder> for crate::input::JsonUnionsInput {
         type Error = ConstraintViolation;
-1802
         fn try_from(builder: Builder) -> ::std::result::Result<Self, Self::Error> {
             builder.build()
-1805
+        }

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

@@ -29,29 +128,129 @@

↥ Expand context

 //! The primary entrypoint is [`JsonRpc10`]: 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 [`JsonRpc10::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 json_rpc10::{JsonRpc10, JsonRpc10Config};

 //!
 //! # let app = JsonRpc10::builder(
 //! #     JsonRpc10Config::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();
 //! # }
 //!
 //! ```
 //!
 //! ### Running on Lambda
 //!
 //! ```rust,ignore
 //! use json_rpc10::server::routing::LambdaHandler;
 //! use json_rpc10::JsonRpc10;
 //!
 //! # async fn dummy() {
 //! # let app = JsonRpc10::builder(
 //! #     JsonRpc10Config::builder()
 //! #         .build()
 //! # ).build_unchecked();
 //! let handler = LambdaHandler::new(app);
 //! lambda_http::run(handler).await.unwrap();
 //! # }
 //! ```
 //!
 //! # Building the JsonRpc10
 //!
 //! To construct [`JsonRpc10`] we use [`JsonRpc10Builder`] returned by [`JsonRpc10::builder`].
 //!
 //! ## Plugins
 //!
 //! The [`JsonRpc10::builder`] method, returning [`JsonRpc10Builder`],
 //! 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 json_rpc10::server::plugin::IdentityPlugin as LoggingPlugin;
 //! # use json_rpc10::server::plugin::IdentityPlugin as MetricsPlugin;
 //! # use ::hyper::Body;
 //! use json_rpc10::server::plugin::HttpPlugins;
 //! use json_rpc10::{JsonRpc10, JsonRpc10Config, JsonRpc10Builder};
 //!
 //! let http_plugins = HttpPlugins::new()
 //!         .push(LoggingPlugin)
 //!         .push(MetricsPlugin);
 //! let config = JsonRpc10Config::builder().build();
 //! let builder: JsonRpc10Builder<Body, _, _, _> = JsonRpc10::builder(config);
 //! let builder: JsonRpc10Builder<::hyper::Body, _, _, _> = JsonRpc10::builder(config);
 //! ```
 //!
 //! Check out [`crate::server::plugin`] to learn more about plugins.
 //!
 //! ## Handlers
 //!
 //! [`JsonRpc10Builder`] 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;

@@ -239,240 +334,335 @@

↥ Expand context

 //!     todo!()
 //! }
 //!
 //! async fn operation_with_nested_structure(input: input::OperationWithNestedStructureInput) -> Result<output::OperationWithNestedStructureOutput, error::OperationWithNestedStructureError> {
 //!     todo!()
 //! }
 //!
 //! async fn operation_with_required_members(input: input::OperationWithRequiredMembersInput) -> Result<output::OperationWithRequiredMembersOutput, error::OperationWithRequiredMembersError> {
 //!     todo!()
 //! }
 //!
 //! async fn operation_with_required_members_with_defaults(input: input::OperationWithRequiredMembersWithDefaultsInput) -> Result<output::OperationWithRequiredMembersWithDefaultsOutput, error::OperationWithRequiredMembersWithDefaultsError> {
 //!     todo!()
 //! }
 //!
 //! async fn put_with_content_encoding(input: input::PutWithContentEncodingInput) -> Result<output::PutWithContentEncodingOutput, error::PutWithContentEncodingError> {
 //!     todo!()
 //! }
 //!
 //! async fn query_incompatible_operation(input: input::QueryIncompatibleOperationInput) -> Result<output::QueryIncompatibleOperationOutput, error::QueryIncompatibleOperationError> {

 //!     todo!()
 //! }
 //!
 //! async fn simple_scalar_properties(input: input::SimpleScalarPropertiesInput) -> Result<output::SimpleScalarPropertiesOutput, error::SimpleScalarPropertiesError> {
 //!     todo!()
 //! }
 //!
 //! ```
 //!
 //! [`serve`]: https://docs.rs/hyper/0.14.16/hyper/server/struct.Builder.html#method.serve
 //! [hyper server]: https://docs.rs/hyper/0.14.26/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::service::{
     JsonRpc10, JsonRpc10Builder, JsonRpc10Config, JsonRpc10ConfigBuilder, MissingOperationsError,
 };
-278
 /// 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::*;
     pub use ::aws_smithy_legacy_http_server::*;
-283
+}
-284
 /// Crate version number.
 pub static PKG_VERSION: &str = env!("CARGO_PKG_VERSION");
-287
 /// All error types that operations can return. Documentation on these types is copied from the model.
 pub mod error;
-290
 /// Input structures for operations. Documentation on these types is copied from the model.
 pub mod input;
-293
 /// Data structures used by operation inputs/outputs. Documentation on these types is copied from the model.
 pub mod model;
-296
 /// All operations that this crate can perform.
 pub mod operation;
-299
 /// A collection of types representing each operation defined in the service closure.
 ///
 /// The [plugin system](::aws_smithy_http_server::plugin) makes use of these
 /// The [plugin system](::aws_smithy_legacy_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
 /// [`OperationShape`](::aws_smithy_http_server::operation::OperationShape), can be used to provide
 /// parameterize [`Plugin`](::aws_smithy_legacy_http_server::plugin::Plugin) implementations. Their traits, such as
 /// [`OperationShape`](::aws_smithy_legacy_http_server::operation::OperationShape), can be used to provide
 /// operation specific information to the [`Layer`](::tower::Layer) being applied.
 pub mod operation_shape;
-308
 /// Output structures for operations. Documentation on these types is copied from the model.
 pub mod output;
-311
 /// Export PyO3 symbols in the shared library
 pub mod python_module_export;
-314
 /// Operation adapters that delegate to Python handlers.

↧ Expand context

 pub mod python_operation_adaptor;
-317
 /// Python server and application implementation.
 pub mod python_server_application;
-320
 mod service;
-322
 /// Data primitives referenced by other data types.
 pub mod types;
-325
 /// Unconstrained types for constrained shapes.
 mod unconstrained;
-328
 /// Constrained types for constrained shapes.
 mod constrained;
-331
 mod mimes;
-333
 pub(crate) mod protocol_serde;
-335

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

@@ -1,1 +1593,1549 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`QueryIncompatibleOperationInput`](crate::input::QueryIncompatibleOperationInput) using modelled bindings.
     pub struct QueryIncompatibleOperationInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryIncompatibleOperationInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryIncompatibleOperationInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-7
+    }
-8
+}
-9
 impl std::future::Future for QueryIncompatibleOperationInputFuture {
     type Output = Result<
         crate::input::QueryIncompatibleOperationInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_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_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
         B,
     > for crate::input::QueryIncompatibleOperationInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_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>,
     ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-37
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = QueryIncompatibleOperationInputFuture;
-41
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-49
+            }
             crate::protocol_serde::shape_query_incompatible_operation::de_query_incompatible_operation_http_request(request)
                             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_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)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         QueryIncompatibleOperationInputFuture {
             inner: Box::pin(fut),
-60
+        }
-61
+    }
-62
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::output::QueryIncompatibleOperationOutput
-67
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_query_incompatible_operation::ser_query_incompatible_operation_http_response(self) {
                         Ok(response) => response,
                         Err(e) => {
                             ::tracing::error!(error = %e, "failed to serialize response");
                             ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                             ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-74
+                        }
-75
+                    }
-76
+    }
-77
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::error::QueryIncompatibleOperationError
-82
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_query_incompatible_operation::ser_query_incompatible_operation_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response.extensions_mut().insert(::aws_smithy_legacy_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-92
+            }
-93
+        }
-94
+    }
-95
+}
-96
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`OperationWithRequiredMembersWithDefaultsInput`](crate::input::OperationWithRequiredMembersWithDefaultsInput) using modelled bindings.
     pub struct OperationWithRequiredMembersWithDefaultsInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::OperationWithRequiredMembersWithDefaultsInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::OperationWithRequiredMembersWithDefaultsInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-102
+    }
-103
+}
-104
 impl std::future::Future for OperationWithRequiredMembersWithDefaultsInputFuture {
     type Output = Result<
         crate::input::OperationWithRequiredMembersWithDefaultsInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-110
     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)
-117
+    }
-118
+}
-119
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
         B,
     > for crate::input::OperationWithRequiredMembersWithDefaultsInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-128
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-132
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = OperationWithRequiredMembersWithDefaultsInputFuture;
-136
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-144
+            }
             crate::protocol_serde::shape_operation_with_required_members_with_defaults::de_operation_with_required_members_with_defaults_http_request(request)
                             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_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)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         OperationWithRequiredMembersWithDefaultsInputFuture {
             inner: Box::pin(fut),
-155
+        }
-156
+    }
-157
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::output::OperationWithRequiredMembersWithDefaultsOutput
-162
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_operation_with_required_members_with_defaults::ser_operation_with_required_members_with_defaults_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                             ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-169
+                        }
-170
+                    }
-171
+    }
-172
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::error::OperationWithRequiredMembersWithDefaultsError
-177
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_operation_with_required_members_with_defaults::ser_operation_with_required_members_with_defaults_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response.extensions_mut().insert(::aws_smithy_legacy_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-187
+            }
-188
+        }
-189
+    }
-190
+}
-191
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`OperationWithNestedStructureInput`](crate::input::OperationWithNestedStructureInput) using modelled bindings.
     pub struct OperationWithNestedStructureInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::OperationWithNestedStructureInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::OperationWithNestedStructureInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-197
+    }
-198
+}
-199
 impl std::future::Future for OperationWithNestedStructureInputFuture {
     type Output = Result<
         crate::input::OperationWithNestedStructureInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-205
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-212
+    }
-213
+}
-214
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
         B,
     > for crate::input::OperationWithNestedStructureInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-223
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-227
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = OperationWithNestedStructureInputFuture;
-231
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-239
+            }
             crate::protocol_serde::shape_operation_with_nested_structure::de_operation_with_nested_structure_http_request(request)
                             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_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)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         OperationWithNestedStructureInputFuture {
             inner: Box::pin(fut),
-250
+        }
-251
+    }
-252
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::output::OperationWithNestedStructureOutput
-257
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_operation_with_nested_structure::ser_operation_with_nested_structure_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                             ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-264
+                        }
-265
+                    }
-266
+    }
-267
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::error::OperationWithNestedStructureError
-272
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_operation_with_nested_structure::ser_operation_with_nested_structure_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response.extensions_mut().insert(::aws_smithy_legacy_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-282
+            }
-283
+        }
-284
+    }
-285
+}
-286
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`OperationWithRequiredMembersInput`](crate::input::OperationWithRequiredMembersInput) using modelled bindings.
     pub struct OperationWithRequiredMembersInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::OperationWithRequiredMembersInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::OperationWithRequiredMembersInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-292
+    }
-293
+}
-294
 impl std::future::Future for OperationWithRequiredMembersInputFuture {
     type Output = Result<
         crate::input::OperationWithRequiredMembersInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-300
     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)
-307
+    }
-308
+}
-309
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
         B,
     > for crate::input::OperationWithRequiredMembersInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-318
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-322
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = OperationWithRequiredMembersInputFuture;
-326
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-334
+            }
             crate::protocol_serde::shape_operation_with_required_members::de_operation_with_required_members_http_request(request)
                             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_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)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         OperationWithRequiredMembersInputFuture {
             inner: Box::pin(fut),
-345
+        }
-346
+    }
-347
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::output::OperationWithRequiredMembersOutput
-352
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_operation_with_required_members::ser_operation_with_required_members_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                             ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-359
+                        }
-360
+                    }
-361
+    }
-362
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::error::OperationWithRequiredMembersError
-367
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_operation_with_required_members::ser_operation_with_required_members_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response.extensions_mut().insert(::aws_smithy_legacy_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-377
+            }
-378
+        }
-379
+    }
-380
+}
-381
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`OperationWithDefaultsInput`](crate::input::OperationWithDefaultsInput) using modelled bindings.
     pub struct OperationWithDefaultsInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::OperationWithDefaultsInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::OperationWithDefaultsInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-387
+    }
-388
+}
-389
 impl std::future::Future for OperationWithDefaultsInputFuture {
     type Output = Result<
         crate::input::OperationWithDefaultsInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-395
     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)
-402
+    }
-403
+}
-404
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
         B,
     > for crate::input::OperationWithDefaultsInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-413
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-417
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = OperationWithDefaultsInputFuture;
-421
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-429
+            }
             crate::protocol_serde::shape_operation_with_defaults::de_operation_with_defaults_http_request(request)
                             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_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)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         OperationWithDefaultsInputFuture {
             inner: Box::pin(fut),
-440
+        }
-441
+    }
-442
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::output::OperationWithDefaultsOutput
-447
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_operation_with_defaults::ser_operation_with_defaults_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                             ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-454
+                        }
-455
+                    }
-456
+    }
-457
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::error::OperationWithDefaultsError
-462
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_operation_with_defaults::ser_operation_with_defaults_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response.extensions_mut().insert(::aws_smithy_legacy_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-472
+            }
-473
+        }
-474
+    }
-475
+}
-476
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`ContentTypeParametersInput`](crate::input::ContentTypeParametersInput) using modelled bindings.
     pub struct ContentTypeParametersInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ContentTypeParametersInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ContentTypeParametersInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-482
+    }
-483
+}
-484
 impl std::future::Future for ContentTypeParametersInputFuture {
     type Output = Result<
         crate::input::ContentTypeParametersInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-490
     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)
-497
+    }
-498
+}
-499
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
         B,
     > for crate::input::ContentTypeParametersInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-508
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-512
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = ContentTypeParametersInputFuture;
-516
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-524
+            }
             crate::protocol_serde::shape_content_type_parameters::de_content_type_parameters_http_request(request)
                             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_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)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         ContentTypeParametersInputFuture {
             inner: Box::pin(fut),
-535
+        }
-536
+    }
-537
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::output::ContentTypeParametersOutput
-542
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_content_type_parameters::ser_content_type_parameters_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                             ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-549
+                        }
-550
+                    }
-551
+    }
-552
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::error::ContentTypeParametersError
-557
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_content_type_parameters::ser_content_type_parameters_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response.extensions_mut().insert(::aws_smithy_legacy_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-567
+            }
-568
+        }
-569
+    }
-570
+}
-571
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`PutWithContentEncodingInput`](crate::input::PutWithContentEncodingInput) using modelled bindings.
     pub struct PutWithContentEncodingInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::PutWithContentEncodingInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::PutWithContentEncodingInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-577
+    }
-578
+}
-579
 impl std::future::Future for PutWithContentEncodingInputFuture {
     type Output = Result<
         crate::input::PutWithContentEncodingInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-585
     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)
-592
+    }
-593
+}
-594
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
         B,
     > for crate::input::PutWithContentEncodingInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-603
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-607
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = PutWithContentEncodingInputFuture;
-611
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-619
+            }
             crate::protocol_serde::shape_put_with_content_encoding::de_put_with_content_encoding_http_request(request)
                             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_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)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         PutWithContentEncodingInputFuture {
             inner: Box::pin(fut),
-630
+        }
-631
+    }
-632
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::output::PutWithContentEncodingOutput
-637
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_put_with_content_encoding::ser_put_with_content_encoding_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                             ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-644
+                        }
-645
+                    }
-646
+    }
-647
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::error::PutWithContentEncodingError
-652
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_put_with_content_encoding::ser_put_with_content_encoding_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response.extensions_mut().insert(::aws_smithy_legacy_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-662
+            }
-663
+        }
-664
+    }
-665
+}
-666
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`HostWithPathOperationInput`](crate::input::HostWithPathOperationInput) using modelled bindings.
     pub struct HostWithPathOperationInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::HostWithPathOperationInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::HostWithPathOperationInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-672
+    }
-673
+}
-674
 impl std::future::Future for HostWithPathOperationInputFuture {
     type Output = Result<
         crate::input::HostWithPathOperationInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-680
     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)
-687
+    }
-688
+}
-689
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
         B,
     > for crate::input::HostWithPathOperationInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-698
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-702
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = HostWithPathOperationInputFuture;
-706
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-714
+            }
             crate::protocol_serde::shape_host_with_path_operation::de_host_with_path_operation_http_request(request)
                             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_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)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         HostWithPathOperationInputFuture {
             inner: Box::pin(fut),
-725
+        }
-726
+    }
-727
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::output::HostWithPathOperationOutput
-732
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_host_with_path_operation::ser_host_with_path_operation_http_response(self) {
                         Ok(response) => response,
                         Err(e) => {
                             ::tracing::error!(error = %e, "failed to serialize response");
                             ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                             ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-739
+                        }
-740
+                    }
-741
+    }
-742
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::error::HostWithPathOperationError
-747
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_host_with_path_operation::ser_host_with_path_operation_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response.extensions_mut().insert(::aws_smithy_legacy_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-757
+            }
-758
+        }
-759
+    }
-760
+}
-761
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`EndpointWithHostLabelOperationInput`](crate::input::EndpointWithHostLabelOperationInput) using modelled bindings.
     pub struct EndpointWithHostLabelOperationInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EndpointWithHostLabelOperationInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EndpointWithHostLabelOperationInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-767
+    }
-768
+}
-769
 impl std::future::Future for EndpointWithHostLabelOperationInputFuture {
     type Output = Result<
         crate::input::EndpointWithHostLabelOperationInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-775
     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)
-782
+    }
-783
+}
-784
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
         B,
     > for crate::input::EndpointWithHostLabelOperationInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-793
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-797
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = EndpointWithHostLabelOperationInputFuture;
-801
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-809
+            }
             crate::protocol_serde::shape_endpoint_with_host_label_operation::de_endpoint_with_host_label_operation_http_request(request)
                             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_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)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         EndpointWithHostLabelOperationInputFuture {
             inner: Box::pin(fut),
-820
+        }
-821
+    }
-822
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::output::EndpointWithHostLabelOperationOutput
-827
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_endpoint_with_host_label_operation::ser_endpoint_with_host_label_operation_http_response(self) {
                         Ok(response) => response,
                         Err(e) => {
                             ::tracing::error!(error = %e, "failed to serialize response");
                             ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                             ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-834
+                        }
-835
+                    }
-836
+    }
-837
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::error::EndpointWithHostLabelOperationError
-842
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_endpoint_with_host_label_operation::ser_endpoint_with_host_label_operation_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response.extensions_mut().insert(::aws_smithy_legacy_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-852
+            }
-853
+        }
-854
+    }
-855
+}
-856
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`EndpointOperationInput`](crate::input::EndpointOperationInput) using modelled bindings.
     pub struct EndpointOperationInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EndpointOperationInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EndpointOperationInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-862
+    }
-863
+}
-864
 impl std::future::Future for EndpointOperationInputFuture {
     type Output = Result<
         crate::input::EndpointOperationInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-870
     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)
-877
+    }
-878
+}
-879
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
         B,
     > for crate::input::EndpointOperationInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-888
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-892
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = EndpointOperationInputFuture;
-896
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-904
+            }
             crate::protocol_serde::shape_endpoint_operation::de_endpoint_operation_http_request(
                 request,
-907
+            )
             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_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)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         EndpointOperationInputFuture {
             inner: Box::pin(fut),
-917
+        }
-918
+    }
-919
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::output::EndpointOperationOutput
-924
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_endpoint_operation::ser_endpoint_operation_http_response(
             self,
         ) {
             Ok(response) => response,
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<
                     ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
                 >::into_response(
                     ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
                         e,
                     ),
--
+                )
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-933
+            }
-934
+        }
-935
+    }
-936
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::error::EndpointOperationError
-941
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_endpoint_operation::ser_endpoint_operation_http_error(
             &self,
         ) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                     ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
                         self.name(),
                     ),
                 );
                 response
-953
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<
                     ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
                 >::into_response(
                     ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
                         e,
                     ),
--
+                )
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-957
+            }
-958
+        }
-959
+    }
-960
+}
-961
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`JsonUnionsInput`](crate::input::JsonUnionsInput) using modelled bindings.
     pub struct JsonUnionsInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::JsonUnionsInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::JsonUnionsInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-967
+    }
-968
+}
-969
 impl std::future::Future for JsonUnionsInputFuture {
     type Output = Result<
         crate::input::JsonUnionsInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-975
     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)
-982
+    }
-983
+}
-984
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
         B,
     > for crate::input::JsonUnionsInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-993
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-997
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = JsonUnionsInputFuture;
-1001
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-1009
+            }
             crate::protocol_serde::shape_json_unions::de_json_unions_http_request(request).await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_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)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         JsonUnionsInputFuture {
             inner: Box::pin(fut),
-1019
+        }
-1020
+    }
-1021
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::output::JsonUnionsOutput
-1026
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_json_unions::ser_json_unions_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_10::AwsJson1_0,
                 >::into_response(
                     ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
                         e,
                     ),
--
+                )
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-1033
+            }
-1034
+        }
-1035
+    }
-1036
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::error::JsonUnionsError
-1041
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_json_unions::ser_json_unions_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                     ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
                         self.name(),
                     ),
                 );
                 response
-1051
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<
                     ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
                 >::into_response(
                     ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
                         e,
                     ),
--
+                )
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-1055
+            }
-1056
+        }
-1057
+    }
-1058
+}
-1059
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`GreetingWithErrorsInput`](crate::input::GreetingWithErrorsInput) using modelled bindings.
     pub struct GreetingWithErrorsInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::GreetingWithErrorsInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::GreetingWithErrorsInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-1065
+    }
-1066
+}
-1067
 impl std::future::Future for GreetingWithErrorsInputFuture {
     type Output = Result<
         crate::input::GreetingWithErrorsInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-1073
     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)
-1080
+    }
-1081
+}
-1082
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
         B,
     > for crate::input::GreetingWithErrorsInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-1091
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-1095
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = GreetingWithErrorsInputFuture;
-1099
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-1107
+            }
             crate::protocol_serde::shape_greeting_with_errors::de_greeting_with_errors_http_request(
                 request,
-1110
+            )
             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_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)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         GreetingWithErrorsInputFuture {
             inner: Box::pin(fut),
-1120
+        }
-1121
+    }
-1122
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::output::GreetingWithErrorsOutput
-1127
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_greeting_with_errors::ser_greeting_with_errors_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                             ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-1134
+                        }
-1135
+                    }
-1136
+    }
-1137
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::error::GreetingWithErrorsError
-1142
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_greeting_with_errors::ser_greeting_with_errors_http_error(
             &self,
         ) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                     ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
                         self.name(),
                     ),
                 );
                 response
-1154
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<
                     ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
                 >::into_response(
                     ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
                         e,
                     ),
--
+                )
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-1158
+            }
-1159
+        }
-1160
+    }
-1161
+}
-1162
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`SimpleScalarPropertiesInput`](crate::input::SimpleScalarPropertiesInput) using modelled bindings.
     pub struct SimpleScalarPropertiesInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::SimpleScalarPropertiesInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::SimpleScalarPropertiesInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-1168
+    }
-1169
+}
-1170
 impl std::future::Future for SimpleScalarPropertiesInputFuture {
     type Output = Result<
         crate::input::SimpleScalarPropertiesInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-1176
     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)
-1183
+    }
-1184
+}
-1185
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
         B,
     > for crate::input::SimpleScalarPropertiesInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-1194
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-1198
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = SimpleScalarPropertiesInputFuture;
-1202
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-1210
+            }
             crate::protocol_serde::shape_simple_scalar_properties::de_simple_scalar_properties_http_request(request)
                             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_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)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         SimpleScalarPropertiesInputFuture {
             inner: Box::pin(fut),
-1221
+        }
-1222
+    }
-1223
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::output::SimpleScalarPropertiesOutput
-1228
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_simple_scalar_properties::ser_simple_scalar_properties_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                             ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-1235
+                        }
-1236
+                    }
-1237
+    }
-1238
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::error::SimpleScalarPropertiesError
-1243
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_simple_scalar_properties::ser_simple_scalar_properties_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response.extensions_mut().insert(::aws_smithy_legacy_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-1253
+            }
-1254
+        }
-1255
+    }
-1256
+}
-1257
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`EmptyInputAndEmptyOutputInput`](crate::input::EmptyInputAndEmptyOutputInput) using modelled bindings.
     pub struct EmptyInputAndEmptyOutputInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EmptyInputAndEmptyOutputInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EmptyInputAndEmptyOutputInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-1263
+    }
-1264
+}
-1265
 impl std::future::Future for EmptyInputAndEmptyOutputInputFuture {
     type Output = Result<
         crate::input::EmptyInputAndEmptyOutputInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-1271
     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)
-1278
+    }
-1279
+}
-1280
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
         B,
     > for crate::input::EmptyInputAndEmptyOutputInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-1289
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-1293
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = EmptyInputAndEmptyOutputInputFuture;
-1297
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-1305
+            }
             crate::protocol_serde::shape_empty_input_and_empty_output::de_empty_input_and_empty_output_http_request(request)
                             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_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)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         EmptyInputAndEmptyOutputInputFuture {
             inner: Box::pin(fut),
-1316
+        }
-1317
+    }
-1318
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::output::EmptyInputAndEmptyOutputOutput
-1323
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_empty_input_and_empty_output::ser_empty_input_and_empty_output_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                             ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-1330
+                        }
-1331
+                    }
-1332
+    }
-1333
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::error::EmptyInputAndEmptyOutputError
-1338
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_empty_input_and_empty_output::ser_empty_input_and_empty_output_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response.extensions_mut().insert(::aws_smithy_legacy_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-1348
+            }
-1349
+        }
-1350
+    }
-1351
+}
-1352
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`NoInputAndOutputInput`](crate::input::NoInputAndOutputInput) using modelled bindings.
     pub struct NoInputAndOutputInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::NoInputAndOutputInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::NoInputAndOutputInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-1358
+    }
-1359
+}
-1360
 impl std::future::Future for NoInputAndOutputInputFuture {
     type Output = Result<
         crate::input::NoInputAndOutputInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-1366
     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)
-1373
+    }
-1374
+}
-1375
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
         B,
     > for crate::input::NoInputAndOutputInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-1384
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-1388
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = NoInputAndOutputInputFuture;
-1392
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-1400
+            }
             crate::protocol_serde::shape_no_input_and_output::de_no_input_and_output_http_request(
                 request,
-1403
+            )
             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_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)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         NoInputAndOutputInputFuture {
             inner: Box::pin(fut),
-1413
+        }
-1414
+    }
-1415
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::output::NoInputAndOutputOutput
-1420
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_no_input_and_output::ser_no_input_and_output_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                             ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-1427
+                        }
-1428
+                    }
-1429
+    }
-1430
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::error::NoInputAndOutputError
-1435
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_no_input_and_output::ser_no_input_and_output_http_error(
             &self,
         ) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                     ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
                         self.name(),
                     ),
                 );
                 response
-1447
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<
                     ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
                 >::into_response(
                     ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
                         e,
                     ),
--
+                )
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-1451
+            }
-1452
+        }
-1453
+    }
-1454
+}
-1455
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`NoInputAndNoOutputInput`](crate::input::NoInputAndNoOutputInput) using modelled bindings.
     pub struct NoInputAndNoOutputInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::NoInputAndNoOutputInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::NoInputAndNoOutputInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-1461
+    }
-1462
+}
-1463
 impl std::future::Future for NoInputAndNoOutputInputFuture {
     type Output = Result<
         crate::input::NoInputAndNoOutputInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-1469
     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)
-1476
+    }
-1477
+}
-1478
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
         B,
     > for crate::input::NoInputAndNoOutputInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-1487
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-1491
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = NoInputAndNoOutputInputFuture;
-1495
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-1503
+            }
             crate::protocol_serde::shape_no_input_and_no_output::de_no_input_and_no_output_http_request(request)
                             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_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)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         NoInputAndNoOutputInputFuture {
             inner: Box::pin(fut),
-1514
+        }
-1515
+    }
-1516
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::output::NoInputAndNoOutputOutput
-1521
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_no_input_and_no_output::ser_no_input_and_no_output_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                             ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-1528
+                        }
-1529
+                    }
-1530
+    }
-1531
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_10::AwsJson1_0,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
     > for crate::error::NoInputAndNoOutputError
-1536
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_no_input_and_no_output::ser_no_input_and_no_output_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response.extensions_mut().insert(::aws_smithy_legacy_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_10::AwsJson1_0>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-1546
+            }
-1547
+        }
-1548
+    }
-1549
+}

Pages: 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35