Server Test

tmp-codegen-diff/codegen-server-test/pokemon-service-server-sdk/rust-server-codegen/src/operation.rs

@@ -1,1 +625,647 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* ServerHttpBoundProtocolGenerator.kt:276 */
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`GetStorageInput`](crate::input::GetStorageInput) using modelled bindings.
     pub struct GetStorageInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::GetStorageInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-8
+    }
-9
+}
-10
 impl std::future::Future for GetStorageInputFuture {
     type Output = Result<
         crate::input::GetStorageInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-16
     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)
-23
+    }
-24
+}
-25
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::GetStorageInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-34
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-38
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = GetStorageInputFuture;
-41
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-49
+            }
             crate::protocol_serde::shape_get_storage::de_get_storage_http_request(request).await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-58
+                )
             },
         );
         GetStorageInputFuture {
             inner: Box::pin(fut),
-63
+        }
-64
+    }
-65
+}
 /* ServerHttpBoundProtocolGenerator.kt:335 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::GetStorageOutput
-71
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_get_storage::ser_get_storage_http_response(self) {
             Ok(response) => response,
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-78
+            }
-79
+        }
-80
+    }
-81
+}
 /* ServerHttpBoundProtocolGenerator.kt:356 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::GetStorageError
-87
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_get_storage::ser_get_storage_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                 );
                 response
-95
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-99
+            }
-100
+        }
-101
+    }
-102
+}
-103
 /* ServerHttpBoundProtocolGenerator.kt:276 */
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`GetPokemonSpeciesInput`](crate::input::GetPokemonSpeciesInput) using modelled bindings.
     pub struct GetPokemonSpeciesInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::GetPokemonSpeciesInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-110
+    }
-111
+}
-112
 impl std::future::Future for GetPokemonSpeciesInputFuture {
     type Output = Result<
         crate::input::GetPokemonSpeciesInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-118
     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)
-125
+    }
-126
+}
-127
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::GetPokemonSpeciesInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-136
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-140
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = GetPokemonSpeciesInputFuture;
-143
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-151
+            }
             crate::protocol_serde::shape_get_pokemon_species::de_get_pokemon_species_http_request(
                 request,
-154
+            )
             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-163
+                )
             },
         );
         GetPokemonSpeciesInputFuture {
             inner: Box::pin(fut),
-168
+        }
-169
+    }
-170
+}
 /* ServerHttpBoundProtocolGenerator.kt:335 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::GetPokemonSpeciesOutput
-176
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_get_pokemon_species::ser_get_pokemon_species_http_response(self) {
                         Ok(response) => response,
                         Err(e) => {
                             ::tracing::error!(error = %e, "failed to serialize response");
                             ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-183
+                        }
-184
+                    }
-185
+    }
-186
+}
 /* ServerHttpBoundProtocolGenerator.kt:356 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::GetPokemonSpeciesError
-192
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_get_pokemon_species::ser_get_pokemon_species_http_error(
             &self,
         ) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                 );
                 response
-202
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-206
+            }
-207
+        }
-208
+    }
-209
+}
-210
 /* ServerHttpBoundProtocolGenerator.kt:276 */
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`StreamPokemonRadioInput`](crate::input::StreamPokemonRadioInput) using modelled bindings.
     pub struct StreamPokemonRadioInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::StreamPokemonRadioInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-217
+    }
-218
+}
-219
 impl std::future::Future for StreamPokemonRadioInputFuture {
     type Output = Result<
         crate::input::StreamPokemonRadioInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-225
     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)
-232
+    }
-233
+}
-234
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::StreamPokemonRadioInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-243
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-247
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = StreamPokemonRadioInputFuture;
-250
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_OCTET_STREAM,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-258
+            }
             crate::protocol_serde::shape_stream_pokemon_radio::de_stream_pokemon_radio_http_request(
                 request,
-261
+            )
             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-270
+                )
             },
         );
         StreamPokemonRadioInputFuture {
             inner: Box::pin(fut),
-275
+        }
-276
+    }
-277
+}
 /* ServerHttpBoundProtocolGenerator.kt:335 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::StreamPokemonRadioOutput
-283
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_stream_pokemon_radio::ser_stream_pokemon_radio_http_response(self) {
                         Ok(response) => response,
                         Err(e) => {
                             ::tracing::error!(error = %e, "failed to serialize response");
                             ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-290
+                        }
-291
+                    }
-292
+    }
-293
+}
-294
 /* ServerHttpBoundProtocolGenerator.kt:276 */
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`CheckHealthInput`](crate::input::CheckHealthInput) using modelled bindings.
     pub struct CheckHealthInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::CheckHealthInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-301
+    }
-302
+}
-303
 impl std::future::Future for CheckHealthInputFuture {
     type Output = Result<
         crate::input::CheckHealthInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-309
     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)
-316
+    }
-317
+}
-318
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::CheckHealthInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-327
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-331
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = CheckHealthInputFuture;
-334
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-342
+            }
             crate::protocol_serde::shape_check_health::de_check_health_http_request(request).await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-351
+                )
             },
         );
         CheckHealthInputFuture {
             inner: Box::pin(fut),
-356
+        }
-357
+    }
-358
+}
 /* ServerHttpBoundProtocolGenerator.kt:335 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::CheckHealthOutput
-364
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_check_health::ser_check_health_http_response(self) {
             Ok(response) => response,
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-371
+            }
-372
+        }
-373
+    }
-374
+}
-375
 /* ServerHttpBoundProtocolGenerator.kt:276 */
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`CapturePokemonInput`](crate::input::CapturePokemonInput) using modelled bindings.
     pub struct CapturePokemonInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::CapturePokemonInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-382
+    }
-383
+}
-384
 impl std::future::Future for CapturePokemonInputFuture {
     type Output = Result<
         crate::input::CapturePokemonInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-390
     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)
-397
+    }
-398
+}
-399
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::CapturePokemonInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-408
     B: Into<::aws_smithy_types::byte_stream::ByteStream>,
     B: ::http_body_1x::Body<Data = ::bytes::Bytes>
         + ::std::marker::Send
         + ::std::marker::Sync
         + 'static,
     B::Error: Into<::aws_smithy_types::body::Error> + 'static,
-+
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-418
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = CapturePokemonInputFuture;
-421
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_VND_AMAZON_EVENTSTREAM,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-429
+            }
             crate::protocol_serde::shape_capture_pokemon::de_capture_pokemon_http_request(request)
                 .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-439
+                )
             },
         );
         CapturePokemonInputFuture {
             inner: Box::pin(fut),
-444
+        }
-445
+    }
-446
+}
 /* ServerHttpBoundProtocolGenerator.kt:335 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::CapturePokemonOutput
-452
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_capture_pokemon::ser_capture_pokemon_http_response(self)
-455
+        {
             Ok(response) => response,
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-460
+            }
-461
+        }
-462
+    }
-463
+}
 /* ServerHttpBoundProtocolGenerator.kt:356 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::CapturePokemonError
-469
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_capture_pokemon::ser_capture_pokemon_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                 );
                 response
-477
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-481
+            }
-482
+        }
-483
+    }
-484
+}
-485
 /* ServerHttpBoundProtocolGenerator.kt:276 */
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`DoNothingInput`](crate::input::DoNothingInput) using modelled bindings.
     pub struct DoNothingInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::DoNothingInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-492
+    }
-493
+}
-494
 impl std::future::Future for DoNothingInputFuture {
     type Output = Result<
         crate::input::DoNothingInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-500
     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)
-507
+    }
-508
+}
-509
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::DoNothingInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-518
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-522
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = DoNothingInputFuture;
-525
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-533
+            }
             crate::protocol_serde::shape_do_nothing::de_do_nothing_http_request(request).await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-542
+                )
             },
         );
         DoNothingInputFuture {
             inner: Box::pin(fut),
-547
+        }
-548
+    }
-549
+}
 /* ServerHttpBoundProtocolGenerator.kt:335 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::DoNothingOutput
-555
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_do_nothing::ser_do_nothing_http_response(self) {
             Ok(response) => response,
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-562
+            }
-563
+        }
-564
+    }
-565
+}
-566
 /* ServerHttpBoundProtocolGenerator.kt:276 */
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`GetServerStatisticsInput`](crate::input::GetServerStatisticsInput) using modelled bindings.
     pub struct GetServerStatisticsInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::GetServerStatisticsInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-573
+    }
-574
+}
-575
 impl std::future::Future for GetServerStatisticsInputFuture {
     type Output = Result<
         crate::input::GetServerStatisticsInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-581
     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)
-588
+    }
-589
+}
-590
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::GetServerStatisticsInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-599
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-603
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = GetServerStatisticsInputFuture;
-606
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-614
+            }
             crate::protocol_serde::shape_get_server_statistics::de_get_server_statistics_http_request(request)
                             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-624
+                )
             },
         );
         GetServerStatisticsInputFuture {
             inner: Box::pin(fut),
-629
+        }
-630
+    }
-631
+}
 /* ServerHttpBoundProtocolGenerator.kt:335 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::GetServerStatisticsOutput
-637
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_get_server_statistics::ser_get_server_statistics_http_response(self) {
                         Ok(response) => response,
                         Err(e) => {
                             ::tracing::error!(error = %e, "failed to serialize response");

↧ Expand context

                             ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-644
+                        }
-645
+                    }
-646
+    }
-647
+}

tmp-codegen-diff/codegen-server-test/pokemon-service-server-sdk/rust-server-codegen/src/operation_shape.rs

@@ -1,1 +0,303 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
--
 /// Retrieve information about your Pokédex.
 /* ServerOperationGenerator.kt:48 */
 /// /* ServerOperationGenerator.kt:48 */Retrieve information about your Pokédex.
 /* ServerOperationGenerator.kt:55 */
 pub struct GetStorage;
-6
 impl ::aws_smithy_http_server::operation::OperationShape for GetStorage {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "com.aws.example#GetStorage",
             "com.aws.example",
             "GetStorage",
         );
-14
     type Input = crate::input::GetStorageInput;
     type Output = crate::output::GetStorageOutput;
     type Error = crate::error::GetStorageError;
-18
+}
-19
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for GetStorage {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::sensitivity::headers::MakeHeaders<
             fn(
                 &::http::header::HeaderName,
                 &::http_1x::header::HeaderName,
-25
+            )
                 -> ::aws_smithy_http_server::instrumentation::sensitivity::headers::HeaderMarker,
         >,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeLabel<
                 fn(usize) -> bool,
             >,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-39
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
             .header({
                 |name: &::http::header::HeaderName| {
                 |name: &::http_1x::header::HeaderName| {
                     let name_match = matches!(name.as_str(), "passcode");
                     let key_suffix = None;
                     let value = name_match;
                     ::aws_smithy_http_server::instrumentation::sensitivity::headers::HeaderMarker {
                         key_suffix,
                         value,
-50
+                    }
-51
+                }
             } as fn(&_) -> _)
             .label(
                 { |index: usize| matches!(index, 1) } as fn(usize) -> bool,
                 None,
-56
+            )
-57
+    }
-58
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-61
+    }
-62
+}
 /* ServerOperationGenerator.kt:88 */
-64
 /// Retrieve information about a Pokémon species.
 /// /* ServerOperationGenerator.kt:48 */Retrieve information about a Pokémon species.
 /* ServerOperationGenerator.kt:55 */
 pub struct GetPokemonSpecies;
-68
 impl ::aws_smithy_http_server::operation::OperationShape for GetPokemonSpecies {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "com.aws.example#GetPokemonSpecies",
             "com.aws.example",
             "GetPokemonSpecies",
         );
-76
     type Input = crate::input::GetPokemonSpeciesInput;
     type Output = crate::output::GetPokemonSpeciesOutput;
     type Error = crate::error::GetPokemonSpeciesError;
-80
+}
-81
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for GetPokemonSpecies {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-94
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-97
+    }
-98
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-101
+    }
-102
+}
 /* ServerOperationGenerator.kt:88 */
-104
 /// Fetch a radio song from the database and stream it back as a playable audio.
 /// /* ServerOperationGenerator.kt:48 */Fetch a radio song from the database and stream it back as a playable audio.
 /* ServerOperationGenerator.kt:55 */
 pub struct StreamPokemonRadio;
-108
 impl ::aws_smithy_http_server::operation::OperationShape for StreamPokemonRadio {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "com.aws.example#StreamPokemonRadio",
             "com.aws.example",
             "StreamPokemonRadio",
         );
-116
     type Input = crate::input::StreamPokemonRadioInput;
     type Output = crate::output::StreamPokemonRadioOutput;
     type Error = std::convert::Infallible;
-120
+}
-121
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for StreamPokemonRadio {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-134
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-137
+    }
-138
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-141
+    }
-142
+}
 /* ServerOperationGenerator.kt:88 */
-144
 /// Health check operation, to check the service is up Not yet a deep check
 /// /* ServerOperationGenerator.kt:48 */Health check operation, to check the service is up Not yet a deep check
 /* ServerOperationGenerator.kt:55 */
 pub struct CheckHealth;
-148
 impl ::aws_smithy_http_server::operation::OperationShape for CheckHealth {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "com.aws.example#CheckHealth",
             "com.aws.example",
             "CheckHealth",
         );
-156
     type Input = crate::input::CheckHealthInput;
     type Output = crate::output::CheckHealthOutput;
     type Error = std::convert::Infallible;
-160
+}
-161
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for CheckHealth {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-174
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-177
+    }
-178
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-181
+    }
-182
+}
 /* ServerOperationGenerator.kt:88 */
-184
 /// Capture Pokémons via event streams.
 /// /* ServerOperationGenerator.kt:48 */Capture Pokémons via event streams.
 /* ServerOperationGenerator.kt:55 */
 pub struct CapturePokemon;
-188
 impl ::aws_smithy_http_server::operation::OperationShape for CapturePokemon {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "com.aws.example#CapturePokemon",
             "com.aws.example",
             "CapturePokemon",
         );
-196
     type Input = crate::input::CapturePokemonInput;
     type Output = crate::output::CapturePokemonOutput;
     type Error = crate::error::CapturePokemonError;
-200
+}
-201
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for CapturePokemon {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-214
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-217
+    }
-218
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-221
+    }
-222
+}
 /* ServerOperationGenerator.kt:88 */
-224
 /// DoNothing operation, used to stress test the framework.
 /// /* ServerOperationGenerator.kt:48 */DoNothing operation, used to stress test the framework.
 /* ServerOperationGenerator.kt:55 */
 pub struct DoNothing;
-228
 impl ::aws_smithy_http_server::operation::OperationShape for DoNothing {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "com.aws.example#DoNothing",
             "com.aws.example",
             "DoNothing",
         );
-236
     type Input = crate::input::DoNothingInput;
     type Output = crate::output::DoNothingOutput;
     type Error = std::convert::Infallible;
-240
+}
-241
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for DoNothing {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-254
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-257
+    }
-258
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-261
+    }
-262
+}
 /* ServerOperationGenerator.kt:88 */
-264
 /// Retrieve HTTP server statistiscs, such as calls count.
 /// /* ServerOperationGenerator.kt:48 */Retrieve HTTP server statistiscs, such as calls count.
 /* ServerOperationGenerator.kt:55 */
 pub struct GetServerStatistics;
-268
 impl ::aws_smithy_http_server::operation::OperationShape for GetServerStatistics {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "com.aws.example#GetServerStatistics",
             "com.aws.example",
             "GetServerStatistics",
         );
-276
     type Input = crate::input::GetServerStatisticsInput;
     type Output = crate::output::GetServerStatisticsOutput;
     type Error = std::convert::Infallible;
-280
+}
-281
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for GetServerStatistics {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-294
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-297
+    }
-298
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-301
+    }
-302
+}
 /* ServerOperationGenerator.kt:88 */

tmp-codegen-diff/codegen-server-test/pokemon-service-server-sdk/rust-server-codegen/src/output.rs

@@ -1,1 +461,760 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
--
 /// Contents of the Pokémon storage.
 /* StructureGenerator.kt:197 */
 /// /* StructureGenerator.kt:197 */Contents of the Pokémon storage.
 /* RustType.kt:534 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct GetStorageOutput {
     /// A list of Pokémon species.
 pub /* StructureGenerator.kt:201 */ struct GetStorageOutput {
     /// /* StructureGenerator.kt:231 */A list of Pokémon species.
     pub collection: ::std::vec::Vec<::std::string::String>,
     /* StructureGenerator.kt:201 */
-12
+}
 /* StructureGenerator.kt:135 */
 impl GetStorageOutput {
     /// A list of Pokémon species.
     /// /* StructureGenerator.kt:231 */A list of Pokémon species.
     /* StructureGenerator.kt:166 */
     pub fn collection(&self) -> &[::std::string::String] {
         /* StructureGenerator.kt:171 */
         use std::ops::Deref;
         self.collection.deref()
         /* StructureGenerator.kt:166 */
-22
+    }
     /* StructureGenerator.kt:135 */
-24
+}
 /* ServerCodegenVisitor.kt:356 */
 impl GetStorageOutput {
     /// Creates a new builder-style object to manufacture [`GetStorageOutput`](crate::output::GetStorageOutput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`GetStorageOutput`](crate::output::GetStorageOutput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::output::get_storage_output::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::output::get_storage_output::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-33
+    }
     /* ServerCodegenVisitor.kt:356 */
-35
+}
-36
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:534 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct GetPokemonSpeciesOutput {
     /// The name for this resource.
 pub /* StructureGenerator.kt:201 */ struct GetPokemonSpeciesOutput {
     /// /* StructureGenerator.kt:231 */The name for this resource.
     pub name: ::std::string::String,
     /// A list of flavor text entries for this Pokémon species.
     /// /* StructureGenerator.kt:231 */A list of flavor text entries for this Pokémon species.
     pub flavor_text_entries: ::std::vec::Vec<crate::model::FlavorText>,
     /* StructureGenerator.kt:201 */
-49
+}
 /* StructureGenerator.kt:135 */
 impl GetPokemonSpeciesOutput {
     /// The name for this resource.
     /// /* StructureGenerator.kt:231 */The name for this resource.
     /* StructureGenerator.kt:166 */
     pub fn name(&self) -> &str {
         /* StructureGenerator.kt:171 */
         use std::ops::Deref;
         self.name.deref()
         /* StructureGenerator.kt:166 */
-59
+    }
     /// A list of flavor text entries for this Pokémon species.
     /// /* StructureGenerator.kt:231 */A list of flavor text entries for this Pokémon species.
     /* StructureGenerator.kt:166 */
     pub fn flavor_text_entries(&self) -> &[crate::model::FlavorText] {
         /* StructureGenerator.kt:171 */
         use std::ops::Deref;
         self.flavor_text_entries.deref()
         /* StructureGenerator.kt:166 */
-67
+    }
     /* StructureGenerator.kt:135 */
-69
+}
 /* ServerCodegenVisitor.kt:356 */
 impl GetPokemonSpeciesOutput {
     /// Creates a new builder-style object to manufacture [`GetPokemonSpeciesOutput`](crate::output::GetPokemonSpeciesOutput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`GetPokemonSpeciesOutput`](crate::output::GetPokemonSpeciesOutput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::output::get_pokemon_species_output::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::output::get_pokemon_species_output::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-78
+    }
     /* ServerCodegenVisitor.kt:356 */
-80
+}
-81
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:534 */
 #[derive(::std::fmt::Debug)]
 pub struct StreamPokemonRadioOutput {
 pub /* StructureGenerator.kt:201 */ struct StreamPokemonRadioOutput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
     pub data: ::aws_smithy_types::byte_stream::ByteStream,
     /* StructureGenerator.kt:201 */
-91
+}
 /* StructureGenerator.kt:135 */
 impl StreamPokemonRadioOutput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
                            /* StructureGenerator.kt:166 */
     pub fn data(&self) -> &::aws_smithy_types::byte_stream::ByteStream {
         /* StructureGenerator.kt:172 */
         &self.data
         /* StructureGenerator.kt:166 */
-101
+    }
     /* StructureGenerator.kt:135 */
-103
+}
 /* ServerCodegenVisitor.kt:356 */
 impl StreamPokemonRadioOutput {
     /// Creates a new builder-style object to manufacture [`StreamPokemonRadioOutput`](crate::output::StreamPokemonRadioOutput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`StreamPokemonRadioOutput`](crate::output::StreamPokemonRadioOutput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::output::stream_pokemon_radio_output::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::output::stream_pokemon_radio_output::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-112
+    }
     /* ServerCodegenVisitor.kt:356 */
-114
+}
-115
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:534 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct CheckHealthOutput {}
 pub /* StructureGenerator.kt:201 */ struct CheckHealthOutput {/* StructureGenerator.kt:201 */}
 /* ServerCodegenVisitor.kt:356 */
 impl CheckHealthOutput {
     /// Creates a new builder-style object to manufacture [`CheckHealthOutput`](crate::output::CheckHealthOutput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`CheckHealthOutput`](crate::output::CheckHealthOutput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::output::check_health_output::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::output::check_health_output::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-131
+    }
     /* ServerCodegenVisitor.kt:356 */
-133
+}
-134
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:534 */
 #[derive(::std::fmt::Debug)]
 pub struct CapturePokemonOutput {
 pub /* StructureGenerator.kt:201 */ struct CapturePokemonOutput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
     pub events: ::aws_smithy_http::event_stream::EventStreamSender<
         crate::model::CapturePokemonEvents,
         crate::error::CapturePokemonEventsError,
     >,
     /* StructureGenerator.kt:201 */
-147
+}
 /* StructureGenerator.kt:135 */
 impl CapturePokemonOutput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
                            /* StructureGenerator.kt:166 */
     pub fn events(
         &self,
     ) -> &::aws_smithy_http::event_stream::EventStreamSender<
         crate::model::CapturePokemonEvents,
         crate::error::CapturePokemonEventsError,
     > {
         /* StructureGenerator.kt:172 */
         &self.events
         /* StructureGenerator.kt:166 */
-162
+    }
     /* StructureGenerator.kt:135 */
-164
+}
 /* ServerCodegenVisitor.kt:356 */
 impl CapturePokemonOutput {
     /// Creates a new builder-style object to manufacture [`CapturePokemonOutput`](crate::output::CapturePokemonOutput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`CapturePokemonOutput`](crate::output::CapturePokemonOutput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::output::capture_pokemon_output::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::output::capture_pokemon_output::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-173
+    }
     /* ServerCodegenVisitor.kt:356 */
-175
+}
-176
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:534 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct DoNothingOutput {}
 pub /* StructureGenerator.kt:201 */ struct DoNothingOutput {/* StructureGenerator.kt:201 */}
 /* ServerCodegenVisitor.kt:356 */
 impl DoNothingOutput {
     /// Creates a new builder-style object to manufacture [`DoNothingOutput`](crate::output::DoNothingOutput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`DoNothingOutput`](crate::output::DoNothingOutput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::output::do_nothing_output::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::output::do_nothing_output::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-192
+    }
     /* ServerCodegenVisitor.kt:356 */
-194
+}
-195
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:534 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct GetServerStatisticsOutput {
     /// The number of calls executed by the server.
 pub /* StructureGenerator.kt:201 */ struct GetServerStatisticsOutput {
     /// /* StructureGenerator.kt:231 */The number of calls executed by the server.
     pub calls_count: i64,
     /* StructureGenerator.kt:201 */
-206
+}
 /* StructureGenerator.kt:135 */
 impl GetServerStatisticsOutput {
     /// The number of calls executed by the server.
     /// /* StructureGenerator.kt:231 */The number of calls executed by the server.
     /* StructureGenerator.kt:166 */
     pub fn calls_count(&self) -> i64 {
         /* StructureGenerator.kt:168 */
         self.calls_count
         /* StructureGenerator.kt:166 */
-215
+    }
     /* StructureGenerator.kt:135 */
-217
+}
 /* ServerCodegenVisitor.kt:356 */
 impl GetServerStatisticsOutput {
     /// Creates a new builder-style object to manufacture [`GetServerStatisticsOutput`](crate::output::GetServerStatisticsOutput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`GetServerStatisticsOutput`](crate::output::GetServerStatisticsOutput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::output::get_server_statistics_output::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::output::get_server_statistics_output::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-226
+    }
     /* ServerCodegenVisitor.kt:356 */
-228
+}
 /// See [`GetStorageOutput`](crate::output::GetStorageOutput).
 /// /* ServerBuilderGenerator.kt:171 */See [`GetStorageOutput`](crate::output::GetStorageOutput).
 pub mod get_storage_output {
-231
     /* RustType.kt:534 */
     #[derive(::std::cmp::PartialEq, ::std::fmt::Debug)]
     /// Holds one variant for each of the ways the builder can fail.
     /// /* ServerBuilderConstraintViolations.kt:72 */Holds one variant for each of the ways the builder can fail.
     /* RustType.kt:534 */
     #[non_exhaustive]
     /* ServerBuilderConstraintViolations.kt:75 */
     #[allow(clippy::enum_variant_names)]
     pub enum ConstraintViolation {
         /// `collection` was not provided but it is required when building `GetStorageOutput`.
         /// /* ServerBuilderConstraintViolations.kt:137 */`collection` was not provided but it is required when building `GetStorageOutput`.
         /* ServerBuilderConstraintViolations.kt:144 */
         MissingCollection,
         /* ServerBuilderConstraintViolations.kt:75 */
-244
+    }
     /* ServerBuilderConstraintViolations.kt:116 */
     impl ::std::fmt::Display for ConstraintViolation {
         /* ServerBuilderConstraintViolations.kt:117 */
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             /* ServerBuilderConstraintViolations.kt:118 */
             match self {
                 ConstraintViolation::MissingCollection => write!(f, "`collection` was not provided but it is required when building `GetStorageOutput`"),
--
+            }
                 /* ServerBuilderConstraintViolations.kt:126 */ConstraintViolation::MissingCollection => write!(f, "`collection` was not provided but it is required when building `GetStorageOutput`"),
             /* ServerBuilderConstraintViolations.kt:118 */}
             /* ServerBuilderConstraintViolations.kt:117 */
-254
+        }
         /* ServerBuilderConstraintViolations.kt:116 */
-256
+    }
     /* ServerBuilderConstraintViolations.kt:83 */
     impl ::std::error::Error for ConstraintViolation {}
     /* ServerBuilderGenerator.kt:446 */
     impl ::std::convert::TryFrom<Builder> for crate::output::GetStorageOutput {
         type Error = ConstraintViolation;
-262
         fn try_from(builder: Builder) -> ::std::result::Result<Self, Self::Error> {
             builder.build()
-265
+        }
-266
+    }
     /// A builder for [`GetStorageOutput`](crate::output::GetStorageOutput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`GetStorageOutput`](crate::output::GetStorageOutput).
     /* RustType.kt:534 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {
         /* ServerBuilderGenerator.kt:308 */
         pub(crate) collection: ::std::option::Option<::std::vec::Vec<::std::string::String>>,
         /* ServerBuilderGenerator.kt:211 */
-275
+    }
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// A list of Pokémon species.
         /// /* ServerBuilderGenerator.kt:331 */A list of Pokémon species.
         /* ServerBuilderGenerator.kt:343 */
         pub fn collection(mut self, input: ::std::vec::Vec<::std::string::String>) -> Self {
             self.collection = Some(input);
             /* ServerBuilderGenerator.kt:344 */
             self.collection =
                 /* ServerBuilderGenerator.kt:345 */Some(
                     /* ServerBuilderGenerator.kt:376 */input
                 /* ServerBuilderGenerator.kt:345 */)
             /* ServerBuilderGenerator.kt:344 */;
             self
             /* ServerBuilderGenerator.kt:343 */
-289
+        }
         /// Consumes the builder and constructs a [`GetStorageOutput`](crate::output::GetStorageOutput).
         ///
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`GetStorageOutput`](crate::output::GetStorageOutput).
         /// /* ServerBuilderGenerator.kt:260 */
         /// The builder fails to construct a [`GetStorageOutput`](crate::output::GetStorageOutput) if a [`ConstraintViolation`] occurs.
         ///
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> Result<crate::output::GetStorageOutput, ConstraintViolation> {
             self.build_enforcing_all_constraints()
-297
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(
             self,
         ) -> Result<crate::output::GetStorageOutput, ConstraintViolation> {
             Ok(crate::output::GetStorageOutput {
             /* ServerBuilderGenerator.kt:287 */
             Ok(
                 /* ServerBuilderGenerator.kt:542 */
                 crate::output::GetStorageOutput {
                     /* ServerBuilderGenerator.kt:546 */
                     collection: self
                         .collection
                         /* ServerBuilderGenerator.kt:569 */
                         .ok_or(ConstraintViolation::MissingCollection)?,
             })
                     /* ServerBuilderGenerator.kt:542 */
                 }, /* ServerBuilderGenerator.kt:287 */
-+
+            )
             /* ServerBuilderGenerator.kt:283 */
-315
+        }
         /* ServerBuilderGenerator.kt:215 */
-317
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-320
+}
 /// See [`GetPokemonSpeciesOutput`](crate::output::GetPokemonSpeciesOutput).
 /// /* ServerBuilderGenerator.kt:171 */See [`GetPokemonSpeciesOutput`](crate::output::GetPokemonSpeciesOutput).
 pub mod get_pokemon_species_output {
-323
     /* RustType.kt:534 */
     #[derive(::std::cmp::PartialEq, ::std::fmt::Debug)]
     /// Holds one variant for each of the ways the builder can fail.
     /// /* ServerBuilderConstraintViolations.kt:72 */Holds one variant for each of the ways the builder can fail.
     /* RustType.kt:534 */
     #[non_exhaustive]
     /* ServerBuilderConstraintViolations.kt:75 */
     #[allow(clippy::enum_variant_names)]
     pub enum ConstraintViolation {
         /// `name` was not provided but it is required when building `GetPokemonSpeciesOutput`.
         /// /* ServerBuilderConstraintViolations.kt:137 */`name` was not provided but it is required when building `GetPokemonSpeciesOutput`.
         /* ServerBuilderConstraintViolations.kt:144 */
         MissingName,
         /// `flavor_text_entries` was not provided but it is required when building `GetPokemonSpeciesOutput`.
         /// /* ServerBuilderConstraintViolations.kt:137 */`flavor_text_entries` was not provided but it is required when building `GetPokemonSpeciesOutput`.
         /* ServerBuilderConstraintViolations.kt:144 */
         MissingFlavorTextEntries,
         /* ServerBuilderConstraintViolations.kt:75 */
-339
+    }
     /* ServerBuilderConstraintViolations.kt:116 */
     impl ::std::fmt::Display for ConstraintViolation {
         /* ServerBuilderConstraintViolations.kt:117 */
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             /* ServerBuilderConstraintViolations.kt:118 */
             match self {
                 ConstraintViolation::MissingName => write!(f, "`name` was not provided but it is required when building `GetPokemonSpeciesOutput`"),
                 ConstraintViolation::MissingFlavorTextEntries => write!(f, "`flavor_text_entries` was not provided but it is required when building `GetPokemonSpeciesOutput`"),
--
+            }
                 /* ServerBuilderConstraintViolations.kt:126 */ConstraintViolation::MissingName => write!(f, "`name` was not provided but it is required when building `GetPokemonSpeciesOutput`"),
                 /* ServerBuilderConstraintViolations.kt:126 */ConstraintViolation::MissingFlavorTextEntries => write!(f, "`flavor_text_entries` was not provided but it is required when building `GetPokemonSpeciesOutput`"),
             /* ServerBuilderConstraintViolations.kt:118 */}
             /* ServerBuilderConstraintViolations.kt:117 */
-350
+        }
         /* ServerBuilderConstraintViolations.kt:116 */
-352
+    }
     /* ServerBuilderConstraintViolations.kt:83 */
     impl ::std::error::Error for ConstraintViolation {}
     /* ServerBuilderGenerator.kt:446 */
     impl ::std::convert::TryFrom<Builder> for crate::output::GetPokemonSpeciesOutput {
         type Error = ConstraintViolation;
-358
         fn try_from(builder: Builder) -> ::std::result::Result<Self, Self::Error> {
             builder.build()
-361
+        }
-362
+    }
     /// A builder for [`GetPokemonSpeciesOutput`](crate::output::GetPokemonSpeciesOutput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`GetPokemonSpeciesOutput`](crate::output::GetPokemonSpeciesOutput).
     /* RustType.kt:534 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {
         /* ServerBuilderGenerator.kt:308 */
         pub(crate) name: ::std::option::Option<::std::string::String>,
         /* ServerBuilderGenerator.kt:308 */
         pub(crate) flavor_text_entries:
             ::std::option::Option<::std::vec::Vec<crate::model::FlavorText>>,
         /* ServerBuilderGenerator.kt:211 */
-374
+    }
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// The name for this resource.
         /// /* ServerBuilderGenerator.kt:331 */The name for this resource.
         /* ServerBuilderGenerator.kt:343 */
         pub fn name(mut self, input: ::std::string::String) -> Self {
             self.name = Some(input);
             /* ServerBuilderGenerator.kt:344 */
             self.name =
                 /* ServerBuilderGenerator.kt:345 */Some(
                     /* ServerBuilderGenerator.kt:376 */input
                 /* ServerBuilderGenerator.kt:345 */)
             /* ServerBuilderGenerator.kt:344 */;
             self
             /* ServerBuilderGenerator.kt:343 */
-388
+        }
         /// A list of flavor text entries for this Pokémon species.
         /// /* ServerBuilderGenerator.kt:331 */A list of flavor text entries for this Pokémon species.
         /* ServerBuilderGenerator.kt:343 */
         pub fn flavor_text_entries(
             mut self,
             input: ::std::vec::Vec<crate::model::FlavorText>,
         ) -> Self {
             self.flavor_text_entries = Some(input);
             /* ServerBuilderGenerator.kt:344 */
             self.flavor_text_entries =
                 /* ServerBuilderGenerator.kt:345 */Some(
                     /* ServerBuilderGenerator.kt:376 */input
                 /* ServerBuilderGenerator.kt:345 */)
             /* ServerBuilderGenerator.kt:344 */;
             self
             /* ServerBuilderGenerator.kt:343 */
-403
+        }
         /// Consumes the builder and constructs a [`GetPokemonSpeciesOutput`](crate::output::GetPokemonSpeciesOutput).
         ///
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`GetPokemonSpeciesOutput`](crate::output::GetPokemonSpeciesOutput).
         /// /* ServerBuilderGenerator.kt:260 */
         /// The builder fails to construct a [`GetPokemonSpeciesOutput`](crate::output::GetPokemonSpeciesOutput) if a [`ConstraintViolation`] occurs.
         ///
         /// If the builder fails, it will return the _first_ encountered [`ConstraintViolation`].
         /// /* ServerBuilderGenerator.kt:268 */If the builder fails, it will return the _first_ encountered [`ConstraintViolation`].
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> Result<crate::output::GetPokemonSpeciesOutput, ConstraintViolation> {
             self.build_enforcing_all_constraints()
-412
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(
             self,
         ) -> Result<crate::output::GetPokemonSpeciesOutput, ConstraintViolation> {
             Ok(crate::output::GetPokemonSpeciesOutput {
                 name: self.name.ok_or(ConstraintViolation::MissingName)?,
             /* ServerBuilderGenerator.kt:287 */
             Ok(
                 /* ServerBuilderGenerator.kt:542 */
                 crate::output::GetPokemonSpeciesOutput {
                     /* ServerBuilderGenerator.kt:546 */
                     name: self
                         .name
                         /* ServerBuilderGenerator.kt:569 */
                         .ok_or(ConstraintViolation::MissingName)?,
                     /* ServerBuilderGenerator.kt:546 */
                     flavor_text_entries: self
                         .flavor_text_entries
                         /* ServerBuilderGenerator.kt:569 */
                         .ok_or(ConstraintViolation::MissingFlavorTextEntries)?,
             })
                     /* ServerBuilderGenerator.kt:542 */
                 }, /* ServerBuilderGenerator.kt:287 */
-+
+            )
             /* ServerBuilderGenerator.kt:283 */
-435
+        }
         /* ServerBuilderGenerator.kt:215 */
-437
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-440
+}
 /// See [`StreamPokemonRadioOutput`](crate::output::StreamPokemonRadioOutput).
 /// /* ServerBuilderGenerator.kt:171 */See [`StreamPokemonRadioOutput`](crate::output::StreamPokemonRadioOutput).
 pub mod stream_pokemon_radio_output {
-443
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::output::StreamPokemonRadioOutput {
         fn from(builder: Builder) -> Self {
             builder.build()
-448
+        }
-449
+    }
     /// A builder for [`StreamPokemonRadioOutput`](crate::output::StreamPokemonRadioOutput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`StreamPokemonRadioOutput`](crate::output::StreamPokemonRadioOutput).
     /* RustType.kt:534 */
     #[derive(::std::default::Default, ::std::fmt::Debug)]
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {
         /* ServerBuilderGenerator.kt:308 */
         pub(crate) data: ::std::option::Option<::aws_smithy_types::byte_stream::ByteStream>,
         /* ServerBuilderGenerator.kt:211 */
-458
+    }
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /* ServerBuilderGenerator.kt:331 */
         #[allow(missing_docs)] // documentation missing in model
                                /* ServerBuilderGenerator.kt:343 */
         pub fn data(mut self, input: ::aws_smithy_types::byte_stream::ByteStream) -> Self {
             self.data = Some(input);
             /* ServerBuilderGenerator.kt:344 */
             self.data =
                 /* ServerBuilderGenerator.kt:345 */Some(
                     /* ServerBuilderGenerator.kt:376 */input
                 /* ServerBuilderGenerator.kt:345 */)
             /* ServerBuilderGenerator.kt:344 */;
             self
             /* ServerBuilderGenerator.kt:343 */
-473
+        }
         /// Consumes the builder and constructs a [`StreamPokemonRadioOutput`](crate::output::StreamPokemonRadioOutput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`StreamPokemonRadioOutput`](crate::output::StreamPokemonRadioOutput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::output::StreamPokemonRadioOutput {
             self.build_enforcing_all_constraints()
-478
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(self) -> crate::output::StreamPokemonRadioOutput {
             /* ServerBuilderGenerator.kt:542 */
             crate::output::StreamPokemonRadioOutput {
                 data: self.data.unwrap_or_default(),
                 /* ServerBuilderGenerator.kt:546 */
                 data: self
                     .data
                     /* ServerBuilderGeneratorCommon.kt:95 */
                     .unwrap_or_default(),
                 /* ServerBuilderGenerator.kt:542 */
-489
+            }
             /* ServerBuilderGenerator.kt:283 */
-491
+        }
         /* ServerBuilderGenerator.kt:215 */
-493
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-496
+}
 /// See [`CheckHealthOutput`](crate::output::CheckHealthOutput).
 /// /* ServerBuilderGenerator.kt:171 */See [`CheckHealthOutput`](crate::output::CheckHealthOutput).
 pub mod check_health_output {
-499
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::output::CheckHealthOutput {
         fn from(builder: Builder) -> Self {
             builder.build()
-504
+        }
-505
+    }
     /// A builder for [`CheckHealthOutput`](crate::output::CheckHealthOutput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`CheckHealthOutput`](crate::output::CheckHealthOutput).
     /* RustType.kt:534 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {}
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {/* ServerBuilderGenerator.kt:211 */}
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// Consumes the builder and constructs a [`CheckHealthOutput`](crate::output::CheckHealthOutput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`CheckHealthOutput`](crate::output::CheckHealthOutput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::output::CheckHealthOutput {
             self.build_enforcing_all_constraints()
-517
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(self) -> crate::output::CheckHealthOutput {
             crate::output::CheckHealthOutput {}
             /* ServerBuilderGenerator.kt:542 */
             crate::output::CheckHealthOutput {
             /* ServerBuilderGenerator.kt:542 */}
             /* ServerBuilderGenerator.kt:283 */
-524
+        }
         /* ServerBuilderGenerator.kt:215 */
-526
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-529
+}
 /// See [`CapturePokemonOutput`](crate::output::CapturePokemonOutput).
 /// /* ServerBuilderGenerator.kt:171 */See [`CapturePokemonOutput`](crate::output::CapturePokemonOutput).
 pub mod capture_pokemon_output {
-532
     /* RustType.kt:534 */
     #[derive(::std::cmp::PartialEq, ::std::fmt::Debug)]
     /// Holds one variant for each of the ways the builder can fail.
     /// /* ServerBuilderConstraintViolations.kt:72 */Holds one variant for each of the ways the builder can fail.
     /* RustType.kt:534 */
     #[non_exhaustive]
     /* ServerBuilderConstraintViolations.kt:75 */
     #[allow(clippy::enum_variant_names)]
     pub enum ConstraintViolation {
         /// `events` was not provided but it is required when building `CapturePokemonOutput`.
         /// /* ServerBuilderConstraintViolations.kt:137 */`events` was not provided but it is required when building `CapturePokemonOutput`.
         /* ServerBuilderConstraintViolations.kt:144 */
         MissingEvents,
         /* ServerBuilderConstraintViolations.kt:75 */
-545
+    }
     /* ServerBuilderConstraintViolations.kt:116 */
     impl ::std::fmt::Display for ConstraintViolation {
         /* ServerBuilderConstraintViolations.kt:117 */
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             /* ServerBuilderConstraintViolations.kt:118 */
             match self {
                 ConstraintViolation::MissingEvents => write!(f, "`events` was not provided but it is required when building `CapturePokemonOutput`"),
--
+            }
                 /* ServerBuilderConstraintViolations.kt:126 */ConstraintViolation::MissingEvents => write!(f, "`events` was not provided but it is required when building `CapturePokemonOutput`"),
             /* ServerBuilderConstraintViolations.kt:118 */}
             /* ServerBuilderConstraintViolations.kt:117 */
-555
+        }
         /* ServerBuilderConstraintViolations.kt:116 */
-557
+    }
     /* ServerBuilderConstraintViolations.kt:83 */
     impl ::std::error::Error for ConstraintViolation {}
     /* ServerBuilderGenerator.kt:446 */
     impl ::std::convert::TryFrom<Builder> for crate::output::CapturePokemonOutput {
         type Error = ConstraintViolation;
-563
         fn try_from(builder: Builder) -> ::std::result::Result<Self, Self::Error> {
             builder.build()
-566
+        }
-567
+    }
     /// A builder for [`CapturePokemonOutput`](crate::output::CapturePokemonOutput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`CapturePokemonOutput`](crate::output::CapturePokemonOutput).
     /* RustType.kt:534 */
     #[derive(::std::default::Default, ::std::fmt::Debug)]
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {
         /* ServerBuilderGenerator.kt:308 */
         pub(crate) events: ::std::option::Option<
             ::aws_smithy_http::event_stream::EventStreamSender<
                 crate::model::CapturePokemonEvents,
                 crate::error::CapturePokemonEventsError,
             >,
         >,
         /* ServerBuilderGenerator.kt:211 */
-581
+    }
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /* ServerBuilderGenerator.kt:331 */
         #[allow(missing_docs)] // documentation missing in model
                                /* ServerBuilderGenerator.kt:343 */
         pub fn events(
             mut self,
             input: ::aws_smithy_http::event_stream::EventStreamSender<
                 crate::model::CapturePokemonEvents,
                 crate::error::CapturePokemonEventsError,
             >,
         ) -> Self {
             self.events = Some(input);
             /* ServerBuilderGenerator.kt:344 */
             self.events =
                 /* ServerBuilderGenerator.kt:345 */Some(
                     /* ServerBuilderGenerator.kt:376 */input
                 /* ServerBuilderGenerator.kt:345 */)
             /* ServerBuilderGenerator.kt:344 */;
             self
             /* ServerBuilderGenerator.kt:343 */
-602
+        }
         /// Consumes the builder and constructs a [`CapturePokemonOutput`](crate::output::CapturePokemonOutput).
         ///
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`CapturePokemonOutput`](crate::output::CapturePokemonOutput).
         /// /* ServerBuilderGenerator.kt:260 */
         /// The builder fails to construct a [`CapturePokemonOutput`](crate::output::CapturePokemonOutput) if a [`ConstraintViolation`] occurs.
         ///
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> Result<crate::output::CapturePokemonOutput, ConstraintViolation> {
             self.build_enforcing_all_constraints()
-610
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(
             self,
         ) -> Result<crate::output::CapturePokemonOutput, ConstraintViolation> {
             Ok(crate::output::CapturePokemonOutput {
                 events: self.events.ok_or(ConstraintViolation::MissingEvents)?,
             })
--
+        }
             /* ServerBuilderGenerator.kt:287 */
             Ok(
                 /* ServerBuilderGenerator.kt:542 */
                 crate::output::CapturePokemonOutput {
                     /* ServerBuilderGenerator.kt:546 */
                     events: self
                         .events
                         /* ServerBuilderGenerator.kt:569 */
                         .ok_or(ConstraintViolation::MissingEvents)?,
                     /* ServerBuilderGenerator.kt:542 */
                 }, /* ServerBuilderGenerator.kt:287 */
-+
+            )
             /* ServerBuilderGenerator.kt:283 */
-+
+        }
         /* ServerBuilderGenerator.kt:215 */
-630
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-633
+}
 /// See [`DoNothingOutput`](crate::output::DoNothingOutput).
 /// /* ServerBuilderGenerator.kt:171 */See [`DoNothingOutput`](crate::output::DoNothingOutput).
 pub mod do_nothing_output {
-636
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::output::DoNothingOutput {
         fn from(builder: Builder) -> Self {
             builder.build()
-641
+        }
-642
+    }
     /// A builder for [`DoNothingOutput`](crate::output::DoNothingOutput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`DoNothingOutput`](crate::output::DoNothingOutput).
     /* RustType.kt:534 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {}
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {/* ServerBuilderGenerator.kt:211 */}
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// Consumes the builder and constructs a [`DoNothingOutput`](crate::output::DoNothingOutput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`DoNothingOutput`](crate::output::DoNothingOutput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::output::DoNothingOutput {
             self.build_enforcing_all_constraints()
-654
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(self) -> crate::output::DoNothingOutput {
             crate::output::DoNothingOutput {}
             /* ServerBuilderGenerator.kt:542 */
             crate::output::DoNothingOutput {
             /* ServerBuilderGenerator.kt:542 */}
             /* ServerBuilderGenerator.kt:283 */
-661
+        }
         /* ServerBuilderGenerator.kt:215 */
-663
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-666
+}
 /// See [`GetServerStatisticsOutput`](crate::output::GetServerStatisticsOutput).
 /// /* ServerBuilderGenerator.kt:171 */See [`GetServerStatisticsOutput`](crate::output::GetServerStatisticsOutput).
 pub mod get_server_statistics_output {
-669
     /* RustType.kt:534 */
     #[derive(::std::cmp::PartialEq, ::std::fmt::Debug)]
     /// Holds one variant for each of the ways the builder can fail.
     /// /* ServerBuilderConstraintViolations.kt:72 */Holds one variant for each of the ways the builder can fail.
     /* RustType.kt:534 */
     #[non_exhaustive]
     /* ServerBuilderConstraintViolations.kt:75 */
     #[allow(clippy::enum_variant_names)]
     pub enum ConstraintViolation {
         /// `calls_count` was not provided but it is required when building `GetServerStatisticsOutput`.
         /// /* ServerBuilderConstraintViolations.kt:137 */`calls_count` was not provided but it is required when building `GetServerStatisticsOutput`.
         /* ServerBuilderConstraintViolations.kt:144 */
         MissingCallsCount,
         /* ServerBuilderConstraintViolations.kt:75 */
-682
+    }
     /* ServerBuilderConstraintViolations.kt:116 */
     impl ::std::fmt::Display for ConstraintViolation {
         /* ServerBuilderConstraintViolations.kt:117 */
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             /* ServerBuilderConstraintViolations.kt:118 */
             match self {
                 ConstraintViolation::MissingCallsCount => write!(f, "`calls_count` was not provided but it is required when building `GetServerStatisticsOutput`"),
--
+            }
                 /* ServerBuilderConstraintViolations.kt:126 */ConstraintViolation::MissingCallsCount => write!(f, "`calls_count` was not provided but it is required when building `GetServerStatisticsOutput`"),
             /* ServerBuilderConstraintViolations.kt:118 */}
             /* ServerBuilderConstraintViolations.kt:117 */
-692
+        }
         /* ServerBuilderConstraintViolations.kt:116 */
-694
+    }
     /* ServerBuilderConstraintViolations.kt:83 */
     impl ::std::error::Error for ConstraintViolation {}
     /* ServerBuilderGenerator.kt:446 */
     impl ::std::convert::TryFrom<Builder> for crate::output::GetServerStatisticsOutput {
         type Error = ConstraintViolation;
-700
         fn try_from(builder: Builder) -> ::std::result::Result<Self, Self::Error> {
             builder.build()
-703
+        }
-704
+    }
     /// A builder for [`GetServerStatisticsOutput`](crate::output::GetServerStatisticsOutput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`GetServerStatisticsOutput`](crate::output::GetServerStatisticsOutput).
     /* RustType.kt:534 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {
         /* ServerBuilderGenerator.kt:308 */
         pub(crate) calls_count: ::std::option::Option<i64>,
         /* ServerBuilderGenerator.kt:211 */
-713
+    }
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// The number of calls executed by the server.
         /// /* ServerBuilderGenerator.kt:331 */The number of calls executed by the server.
         /* ServerBuilderGenerator.kt:343 */
         pub fn calls_count(mut self, input: i64) -> Self {
             self.calls_count = Some(input);
             /* ServerBuilderGenerator.kt:344 */
             self.calls_count =
                 /* ServerBuilderGenerator.kt:345 */Some(
                     /* ServerBuilderGenerator.kt:376 */input
                 /* ServerBuilderGenerator.kt:345 */)
             /* ServerBuilderGenerator.kt:344 */;
             self
             /* ServerBuilderGenerator.kt:343 */
-727
+        }
         /// Consumes the builder and constructs a [`GetServerStatisticsOutput`](crate::output::GetServerStatisticsOutput).
         ///
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`GetServerStatisticsOutput`](crate::output::GetServerStatisticsOutput).
         /// /* ServerBuilderGenerator.kt:260 */
         /// The builder fails to construct a [`GetServerStatisticsOutput`](crate::output::GetServerStatisticsOutput) if a [`ConstraintViolation`] occurs.
         ///
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(
             self,
         ) -> Result<crate::output::GetServerStatisticsOutput, ConstraintViolation> {
             self.build_enforcing_all_constraints()
-737
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(
             self,
         ) -> Result<crate::output::GetServerStatisticsOutput, ConstraintViolation> {
             Ok(crate::output::GetServerStatisticsOutput {
             /* ServerBuilderGenerator.kt:287 */
             Ok(
                 /* ServerBuilderGenerator.kt:542 */
                 crate::output::GetServerStatisticsOutput {
                     /* ServerBuilderGenerator.kt:546 */
                     calls_count: self
                         .calls_count
                         /* ServerBuilderGenerator.kt:569 */
                         .ok_or(ConstraintViolation::MissingCallsCount)?,
             })
                     /* ServerBuilderGenerator.kt:542 */
                 }, /* ServerBuilderGenerator.kt:287 */
-+
+            )
             /* ServerBuilderGenerator.kt:283 */
-755
+        }
         /* ServerBuilderGenerator.kt:215 */
-757
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-760
+}

tmp-codegen-diff/codegen-server-test/pokemon-service-server-sdk/rust-server-codegen/src/protocol_serde.rs

@@ -16,16 +58,59 @@

↥ Expand context

 pub(crate) mod shape_capture_pokemon_input;
-17
 pub(crate) mod shape_do_nothing_output;
-19
 pub(crate) mod shape_get_pokemon_species_input;
-21
 pub(crate) mod shape_get_pokemon_species_output;
-23
 pub(crate) mod shape_get_server_statistics_output;
-25
 pub(crate) mod shape_get_storage_input;
-27
 pub(crate) mod shape_get_storage_output;
-29
 pub(crate) mod shape_invalid_pokeball_error;
-31
 pub(crate) mod shape_master_ball_unsuccessful;
-33
 pub(crate) mod shape_resource_not_found_exception;
-35

 pub(crate) mod shape_storage_access_not_authorized;
-37
 pub(crate) mod shape_stream_pokemon_radio_output;
-39
 pub(crate) mod shape_throttling_error;
-41
 pub(crate) mod shape_unsupported_region_error;
-43
 pub(crate) mod shape_validation_exception;
-45
 /* JsonParserGenerator.kt:227 */
 pub(crate) fn or_empty_doc(data: &[u8]) -> &[u8] {
     if data.is_empty() {
         b"{}"
     } else {
         data
-52
+    }
-53
+}
-54
 pub(crate) mod shape_capturing_payload;
-56

↧ Expand context

tmp-codegen-diff/codegen-server-test/pokemon-service-server-sdk/rust-server-codegen/src/protocol_serde/shape_capture_pokemon.rs

@@ -1,1 +233,317 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:408 */
 pub async fn de_capture_pokemon_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::CapturePokemonInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-10
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: Into<::aws_smithy_types::byte_stream::ByteStream>,
     B: ::http_body_1x::Body<Data = ::bytes::Bytes>
         + ::std::marker::Send
         + ::std::marker::Sync
         + 'static,
     B::Error: Into<::aws_smithy_types::body::Error> + 'static,
-+
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-22
+{
     /* ServerHttpBoundProtocolGenerator.kt:424 */
     Ok({
         /* RustType.kt:534 */
         #[allow(unused_mut)]
         /* ServerHttpBoundProtocolGenerator.kt:759 */
         let mut input = crate::input::capture_pokemon_input::Builder::default();
         /* RustType.kt:534 */
         #[allow(unused_variables)]
         /* ServerHttpBoundProtocolGenerator.kt:764 */
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         /* ServerHttpBoundProtocolGenerator.kt:856 */
         if let Some(value) = {
             let mut receiver =
                 crate::protocol_serde::shape_capture_pokemon_input::de_events_payload(
                     &mut body.into().into_inner(),
                     &mut ::aws_smithy_types::body::SdkBody::from_body_1_x(body),
                 )?;
             if let Some(_initial_event) = receiver
                                                 .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
                                                 .await
                                                 .map_err(
                                                     |ev_error| ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::ConstraintViolation(
                                                         #[allow(clippy::useless_conversion)]
                                                         format!("{ev_error}").into()
-48
+                                                    )
                                                 )? {
-50
-51
+                                            }
             Some(receiver)
         } {
             input = input.set_events(value)
-55
+        }
         /* ServerHttpBoundProtocolGenerator.kt:1134 */
         let input_string = uri.path();
         /* ServerHttpBoundProtocolGenerator.kt:1146 */
         let (input_string, (_, m1)) =
             ::nom::sequence::tuple::<_, _, ::nom::error::Error<&str>, _>((
                 ::nom::sequence::preceded(
                     ::nom::bytes::complete::tag("/"),
                     ::nom::bytes::complete::tag::<_, _, ::nom::error::Error<&str>>(
                         "capture-pokemon-event",
                     ),
                 ),
                 ::nom::sequence::preceded(
                     ::nom::bytes::complete::tag("/"),
                     ::nom::branch::alt::<_, _, ::nom::error::Error<&str>, _>((
                         ::nom::bytes::complete::take_until("/"),
                         ::nom::combinator::rest,
                     )),
                 ),
             ))(input_string)?;
         debug_assert_eq!("", input_string);
         /* ServerHttpBoundProtocolGenerator.kt:1157 */
         input =
             input.set_region(crate::protocol_serde::shape_capture_pokemon_input::de_region(m1)?);
         /* ServerHttpBoundProtocolGenerator.kt:896 */
         input.build()?
         /* ServerHttpBoundProtocolGenerator.kt:424 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:408 */
-84
+}
-85
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:445 */
 pub fn ser_capture_pokemon_http_response(
     #[allow(unused_variables)] output: crate::output::CapturePokemonOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     /* ServerHttpBoundProtocolGenerator.kt:457 */
     Ok({
         /* RustType.kt:534 */
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         /* ServerHttpBoundProtocolGenerator.kt:547 */
         let mut builder = ::http_1x::Response::builder();
         /* ServerHttpBoundProtocolGenerator.kt:633 */
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             ::http_1x::header::CONTENT_TYPE,
             "application/vnd.amazon.eventstream",
         );
         /* ServerHttpBoundProtocolGenerator.kt:718 */
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let body = ::aws_smithy_http_server::body::boxed(
             ::aws_smithy_http_server::body::Body::wrap_stream({
         /* ServerHttpBoundProtocolGenerator.kt:575 */
         let body =
             ::aws_smithy_http_server::body::boxed(::aws_smithy_http_server::body::wrap_stream(
                 /* ServerHttpBoundProtocolGenerator.kt:142 */
-+
+                {
                     let error_marshaller =
                         crate::event_stream_serde::CapturePokemonEventsErrorMarshaller::new();
                 let marshaller = crate::event_stream_serde::CapturePokemonEventsMarshaller::new();
                     let marshaller =
                         crate::event_stream_serde::CapturePokemonEventsMarshaller::new();
                     let signer = ::aws_smithy_eventstream::frame::NoOpSigner {};
                     output
                         .events
                         .into_body_stream(marshaller, error_marshaller, signer)
             }),
         );
                 }, /* ServerHttpBoundProtocolGenerator.kt:575 */
             ));
         /* ServerHttpBoundProtocolGenerator.kt:611 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:457 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:445 */
-130
+}
-131
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:471 */
 pub fn ser_capture_pokemon_http_error(
     error: &crate::error::CapturePokemonError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     /* ServerHttpBoundProtocolGenerator.kt:476 */
     Ok({
         /* ServerHttpBoundProtocolGenerator.kt:492 */
         match error {
             /* ServerHttpBoundProtocolGenerator.kt:500 */
             crate::error::CapturePokemonError::UnsupportedRegionError(output) => {
                 /* ServerHttpBoundProtocolGenerator.kt:501 */
                 let payload = crate::protocol_serde::shape_unsupported_region_error::ser_unsupported_region_error_error(output)?;
                 /* RustType.kt:534 */
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:511 */
                 let mut builder = ::http_1x::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:633 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     ::http_1x::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:633 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
                     "UnsupportedRegionError",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:699 */
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     ::http_1x::header::CONTENT_LENGTH,
                     content_length,
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:528 */
                 builder
                     .status(500)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                 /* ServerHttpBoundProtocolGenerator.kt:500 */
-177
+            }
             /* ServerHttpBoundProtocolGenerator.kt:500 */
             crate::error::CapturePokemonError::ThrottlingError(output) => {
                 /* ServerHttpBoundProtocolGenerator.kt:501 */
                 let payload =
                     crate::protocol_serde::shape_throttling_error::ser_throttling_error_error(
                         output,
                     )?;
                 /* RustType.kt:534 */
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:511 */
                 let mut builder = ::http_1x::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:633 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     ::http_1x::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:633 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
                     "ThrottlingError",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:699 */
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     ::http_1x::header::CONTENT_LENGTH,
                     content_length,
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:528 */
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                 /* ServerHttpBoundProtocolGenerator.kt:500 */
-213
+            }
             /* ServerHttpBoundProtocolGenerator.kt:500 */
             crate::error::CapturePokemonError::ValidationException(output) => {
                 /* ServerHttpBoundProtocolGenerator.kt:501 */
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 /* RustType.kt:534 */
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:511 */
                 let mut builder = ::http_1x::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:633 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     ::http_1x::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:633 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
                     "ValidationException",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:699 */
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     ::http_1x::header::CONTENT_LENGTH,
                     content_length,
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:528 */
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                 /* ServerHttpBoundProtocolGenerator.kt:500 */
-246
+            }
             /* ServerHttpBoundProtocolGenerator.kt:500 */
             crate::error::CapturePokemonError::MasterBallUnsuccessful(output) => {
                 /* ServerHttpBoundProtocolGenerator.kt:501 */
                 let payload = crate::protocol_serde::shape_master_ball_unsuccessful::ser_master_ball_unsuccessful_error(output)?;
                 /* RustType.kt:534 */
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:511 */
                 let mut builder = ::http_1x::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:633 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     ::http_1x::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:633 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
                     "MasterBallUnsuccessful",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:699 */
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     ::http_1x::header::CONTENT_LENGTH,
                     content_length,
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:528 */
                 builder
                     .status(500)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                 /* ServerHttpBoundProtocolGenerator.kt:500 */
-279
+            }
             /* ServerHttpBoundProtocolGenerator.kt:500 */
             crate::error::CapturePokemonError::InvalidPokeballError(output) => {
                 /* ServerHttpBoundProtocolGenerator.kt:501 */
                 let payload = crate::protocol_serde::shape_invalid_pokeball_error::ser_invalid_pokeball_error_error(output)?;
                 /* RustType.kt:534 */
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:511 */
                 let mut builder = ::http_1x::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:633 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     ::http_1x::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:633 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
                     "InvalidPokeballError",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:699 */
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     ::http_1x::header::CONTENT_LENGTH,
                     content_length,
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:528 */
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                 /* ServerHttpBoundProtocolGenerator.kt:500 */
             } /* ServerHttpBoundProtocolGenerator.kt:492 */
-313
+        }
--
+        }
         /* ServerHttpBoundProtocolGenerator.kt:476 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:471 */
-317
+}

tmp-codegen-diff/codegen-server-test/pokemon-service-server-sdk/rust-server-codegen/src/protocol_serde/shape_capture_pokemon_input.rs

@@ -1,1 +27,35 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* HttpBindingGenerator.kt:236 */
 pub fn de_events_payload(
     body: &mut ::aws_smithy_types::body::SdkBody,
 ) -> std::result::Result<
     ::aws_smithy_http::event_stream::Receiver<
         crate::model::AttemptCapturingPokemonEvent,
         crate::error::AttemptCapturingPokemonEventError,
     >,
     ::aws_smithy_json::deserialize::error::DeserializeError,
 > {
     /* HttpBindingGenerator.kt:278 */
     let unmarshaller = crate::event_stream_serde::AttemptCapturingPokemonEventUnmarshaller::new();
     /* HttpBindingGenerator.kt:296 */
     let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
     let receiver = ::aws_smithy_http::event_stream::Receiver::new(unmarshaller, body);
     Ok(receiver)
     /* HttpBindingGenerator.kt:236 */
-19
+}
-20
 /* ServerHttpBoundProtocolGenerator.kt:1453 */
 pub fn de_region(
     value: &str,
 ) -> std::result::Result<
     ::std::string::String,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
 > {
     /* ServerHttpBoundProtocolGenerator.kt:1463 */
     let value = ::percent_encoding::percent_decode_str(value)
         .decode_utf8()?
         .into_owned();
     /* ServerHttpBoundProtocolGenerator.kt:1525 */
     Ok(value)
     /* ServerHttpBoundProtocolGenerator.kt:1453 */
-35
+}

tmp-codegen-diff/codegen-server-test/pokemon-service-server-sdk/rust-server-codegen/src/protocol_serde/shape_capturing_payload.rs

@@ -1,1 +90,122 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonParserGenerator.kt:175 */
 pub(crate) fn de_capturing_payload_payload(
     input: &[u8],
 ) -> ::std::result::Result<
     crate::model::CapturingPayload,
     ::aws_smithy_json::deserialize::error::DeserializeError,
 > {
     /* JsonParserGenerator.kt:187 */
     let mut tokens_owned =
         ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(input))
             .peekable();
     let tokens = &mut tokens_owned;
     let result = crate::protocol_serde::shape_capturing_payload::de_capturing_payload(tokens)?
         .ok_or_else(|| {
             ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                 "expected payload member value",
--
+            )
         });
     /* JsonParserGenerator.kt:194 */
     let result =
     /* JsonParserGenerator.kt:544 */crate::protocol_serde::shape_capturing_payload::de_capturing_payload(tokens)?
     /* JsonParserGenerator.kt:196 */.ok_or_else(|| ::aws_smithy_json::deserialize::error::DeserializeError::custom("expected payload member value"));
     /* JsonParserGenerator.kt:250 */
     if tokens.next().is_some() {
         /* JsonParserGenerator.kt:251 */
         return Err(
             ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                 "found more JSON tokens after completing parsing",
             ),
         );
         /* JsonParserGenerator.kt:250 */
-27
+    }
     /* JsonParserGenerator.kt:198 */
     result
     /* JsonParserGenerator.kt:175 */
-31
+}
-32
 /* JsonParserGenerator.kt:516 */
 pub(crate) fn de_capturing_payload<'a, I>(
     tokens: &mut ::std::iter::Peekable<I>,
 ) -> ::std::result::Result<
     Option<crate::model::CapturingPayload>,
     ::aws_smithy_json::deserialize::error::DeserializeError,
-39
+>
 where
     I: Iterator<
         Item = Result<
             ::aws_smithy_json::deserialize::Token<'a>,
             ::aws_smithy_json::deserialize::error::DeserializeError,
         >,
     >,
-47
+{
     /* JsonParserGenerator.kt:712 */
     match tokens.next().transpose()? {
         /* JsonParserGenerator.kt:713 */
         Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
         Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
             /* RustType.kt:534 */
             #[allow(unused_mut)]
             /* JsonParserGenerator.kt:526 */
             let mut builder = crate::model::capturing_payload::Builder::default();
             /* JsonParserGenerator.kt:684 */
             loop {
                 /* JsonParserGenerator.kt:685 */
                 match tokens.next().transpose()? {
                     /* JsonParserGenerator.kt:686 */
                     Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
                     Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
                         /* JsonParserGenerator.kt:260 */
                         match key.to_unescaped()?.as_ref() {
                             /* JsonParserGenerator.kt:262 */
                             "name" => {
                                 /* JsonParserGenerator.kt:272 */
                                 builder = builder.set_name(
                                     ::aws_smithy_json::deserialize::token::expect_string_or_null(
                                         tokens.next(),
                                     )?
                                     .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                                     .transpose()?,
                                 );
                                     /* JsonParserGenerator.kt:354 */::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?.map(|s|
                                         /* JsonParserGenerator.kt:339 */s.to_unescaped().map(|u|
                                             /* JsonParserGenerator.kt:348 */u.into_owned()
                                         /* JsonParserGenerator.kt:339 */)
                                     /* JsonParserGenerator.kt:354 */).transpose()?
                                 /* JsonParserGenerator.kt:272 */);
                                 /* JsonParserGenerator.kt:262 */
-77
+                            }
                             /* JsonParserGenerator.kt:262 */
                             "pokeball" => {
                                 /* JsonParserGenerator.kt:272 */
                                 builder = builder.set_pokeball(
                                     ::aws_smithy_json::deserialize::token::expect_string_or_null(
                                         tokens.next(),
                                     )?
                                     .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                                     .transpose()?,
                                 );
                                     /* JsonParserGenerator.kt:354 */::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?.map(|s|
                                         /* JsonParserGenerator.kt:339 */s.to_unescaped().map(|u|
                                             /* JsonParserGenerator.kt:348 */u.into_owned()
                                         /* JsonParserGenerator.kt:339 */)
                                     /* JsonParserGenerator.kt:354 */).transpose()?
                                 /* JsonParserGenerator.kt:272 */);
                                 /* JsonParserGenerator.kt:262 */
-89
+                            }
                             _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
                             /* JsonParserGenerator.kt:290 */
                             _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?, /* JsonParserGenerator.kt:260 */
-92
+                        }
                         /* JsonParserGenerator.kt:686 */
-94
+                    }
                     /* JsonParserGenerator.kt:695 */
                     other => {
                         return Err(
                             ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                                 format!("expected object key or end object, found: {other:?}"),
                             ),
-101
+                        )
                     } /* JsonParserGenerator.kt:685 */
-103
+                }
                 /* JsonParserGenerator.kt:684 */
-105
+            }
--
+            }
             /* JsonParserGenerator.kt:540 */
             Ok(Some(builder.build()))
             /* JsonParserGenerator.kt:713 */
-109
+        }
         _ => Err(
         /* JsonParserGenerator.kt:722 */
         _ => {
             /* JsonParserGenerator.kt:723 */
             Err(
                 ::aws_smithy_json::deserialize::error::DeserializeError::custom(
                     "expected start object or null",
                 ),
         ),
-+
+            )
             /* JsonParserGenerator.kt:722 */
         } /* JsonParserGenerator.kt:712 */
-120
+    }
     /* JsonParserGenerator.kt:516 */
-122
+}

tmp-codegen-diff/codegen-server-test/pokemon-service-server-sdk/rust-server-codegen/src/protocol_serde/shape_check_health.rs

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

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:408 */
 pub async fn de_check_health_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::CheckHealthInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-10
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-16
+{
     /* ServerHttpBoundProtocolGenerator.kt:424 */
     Ok({
         /* RustType.kt:534 */
         #[allow(unused_mut)]
         /* ServerHttpBoundProtocolGenerator.kt:759 */
         let mut input = crate::input::check_health_input::Builder::default();
         /* RustType.kt:534 */
         #[allow(unused_variables)]
         /* ServerHttpBoundProtocolGenerator.kt:764 */
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         /* ServerHttpBoundProtocolGenerator.kt:873 */
         ::aws_smithy_http_server::protocol::content_type_header_classifier_smithy(&headers, None)?;
         /* ServerHttpBoundProtocolGenerator.kt:896 */
         input.build()
         /* ServerHttpBoundProtocolGenerator.kt:424 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:408 */
-36
+}
-37
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:445 */
 pub fn ser_check_health_http_response(
     #[allow(unused_variables)] output: crate::output::CheckHealthOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     /* ServerHttpBoundProtocolGenerator.kt:457 */
     Ok({
         /* RustType.kt:534 */
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         /* ServerHttpBoundProtocolGenerator.kt:547 */
         let mut builder = ::http_1x::Response::builder();
         /* ServerHttpBoundProtocolGenerator.kt:633 */
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             ::http_1x::header::CONTENT_TYPE,
             "application/json",
         );
         /* ServerHttpBoundProtocolGenerator.kt:718 */
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload = "";
         /* ServerHttpBoundProtocolGenerator.kt:597 */
         let payload =
             /* HttpBoundProtocolPayloadGenerator.kt:233 */""
         /* ServerHttpBoundProtocolGenerator.kt:597 */;
         /* ServerHttpBoundProtocolGenerator.kt:699 */
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             ::http_1x::header::CONTENT_LENGTH,
             content_length,
         );
         /* ServerHttpBoundProtocolGenerator.kt:603 */
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         /* ServerHttpBoundProtocolGenerator.kt:611 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:457 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:445 */
-80
+}

tmp-codegen-diff/codegen-server-test/pokemon-service-server-sdk/rust-server-codegen/src/protocol_serde/shape_do_nothing.rs

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

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:408 */
 pub async fn de_do_nothing_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::DoNothingInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-10
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-16
+{
     /* ServerHttpBoundProtocolGenerator.kt:424 */
     Ok({
         /* RustType.kt:534 */
         #[allow(unused_mut)]
         /* ServerHttpBoundProtocolGenerator.kt:759 */
         let mut input = crate::input::do_nothing_input::Builder::default();
         /* RustType.kt:534 */
         #[allow(unused_variables)]
         /* ServerHttpBoundProtocolGenerator.kt:764 */
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         /* ServerHttpBoundProtocolGenerator.kt:896 */
         input.build()
         /* ServerHttpBoundProtocolGenerator.kt:424 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:408 */
-34
+}
-35
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:445 */
 pub fn ser_do_nothing_http_response(
     #[allow(unused_variables)] output: crate::output::DoNothingOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     /* ServerHttpBoundProtocolGenerator.kt:457 */
     Ok({
         /* RustType.kt:534 */
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         /* ServerHttpBoundProtocolGenerator.kt:547 */
         let mut builder = ::http_1x::Response::builder();
         /* ServerHttpBoundProtocolGenerator.kt:633 */
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             ::http_1x::header::CONTENT_TYPE,
             "application/json",
         );
         /* ServerHttpBoundProtocolGenerator.kt:718 */
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         /* ServerHttpBoundProtocolGenerator.kt:597 */
         let payload =
             crate::protocol_serde::shape_do_nothing_output::ser_do_nothing_output_output_output(
                 &output,
             )?;
             /* HttpBoundProtocolPayloadGenerator.kt:235 */crate::protocol_serde::shape_do_nothing_output::ser_do_nothing_output_output_output(&output)?
         /* ServerHttpBoundProtocolGenerator.kt:597 */;
         /* ServerHttpBoundProtocolGenerator.kt:699 */
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             ::http_1x::header::CONTENT_LENGTH,
             content_length,
         );
         /* ServerHttpBoundProtocolGenerator.kt:603 */
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         /* ServerHttpBoundProtocolGenerator.kt:611 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:457 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:445 */
-78
+}

tmp-codegen-diff/codegen-server-test/pokemon-service-server-sdk/rust-server-codegen/src/protocol_serde/shape_do_nothing_output.rs

@@ -1,1 +20,28 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonSerializerGenerator.kt:213 */
 pub fn ser_do_nothing_output_output_output(
     value: &crate::output::DoNothingOutput,
 ) -> ::std::result::Result<String, ::aws_smithy_types::error::operation::SerializationError> {
     /* JsonSerializerGenerator.kt:218 */
     let mut out = ::std::string::String::new();
     let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
     /* JsonSerializerGenerator.kt:375 */
     crate::protocol_serde::shape_do_nothing_output::ser_do_nothing_output_output(
         &mut object,
         value,
     )?;
     /* JsonSerializerGenerator.kt:227 */
     object.finish();
     Ok(out)
     /* JsonSerializerGenerator.kt:213 */
-18
+}
-19
 /* JsonSerializerGenerator.kt:358 */
 pub fn ser_do_nothing_output_output(
     #[allow(unused_variables)] object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
     #[allow(unused_variables)] input: &crate::output::DoNothingOutput,
 ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
     /* JsonSerializerGenerator.kt:372 */
     Ok(())
     /* JsonSerializerGenerator.kt:358 */
-28
+}

tmp-codegen-diff/codegen-server-test/pokemon-service-server-sdk/rust-server-codegen/src/protocol_serde/shape_flavor_text.rs

@@ -1,1 +13,22 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonSerializerGenerator.kt:358 */
 pub fn ser_flavor_text(
     object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
     input: &crate::model::FlavorText,
 ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
     /* SerializerUtil.kt:42 */
-8
+    {
         /* JsonSerializerGenerator.kt:423 */
         object.key("flavorText").string(input.flavor_text.as_str());
         /* SerializerUtil.kt:42 */
-12
+    }
     /* SerializerUtil.kt:42 */
-14
+    {
         /* JsonSerializerGenerator.kt:423 */
         object.key("language").string(input.language.as_str());
         /* SerializerUtil.kt:42 */
-18
+    }
     /* JsonSerializerGenerator.kt:372 */
     Ok(())
     /* JsonSerializerGenerator.kt:358 */
-22
+}

tmp-codegen-diff/codegen-server-test/pokemon-service-server-sdk/rust-server-codegen/src/protocol_serde/shape_get_pokemon_species.rs

@@ -1,1 +136,186 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:408 */
 pub async fn de_get_pokemon_species_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::GetPokemonSpeciesInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-10
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-16
+{
     /* ServerHttpBoundProtocolGenerator.kt:424 */
     Ok({
         /* RustType.kt:534 */
         #[allow(unused_mut)]
         /* ServerHttpBoundProtocolGenerator.kt:759 */
         let mut input = crate::input::get_pokemon_species_input::Builder::default();
         /* RustType.kt:534 */
         #[allow(unused_variables)]
         /* ServerHttpBoundProtocolGenerator.kt:764 */
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         /* ServerHttpBoundProtocolGenerator.kt:1134 */
         let input_string = uri.path();
         /* ServerHttpBoundProtocolGenerator.kt:1146 */
         let (input_string, (_, m1)) =
             ::nom::sequence::tuple::<_, _, ::nom::error::Error<&str>, _>((
                 ::nom::sequence::preceded(
                     ::nom::bytes::complete::tag("/"),
                     ::nom::bytes::complete::tag::<_, _, ::nom::error::Error<&str>>(
                         "pokemon-species",
                     ),
                 ),
                 ::nom::sequence::preceded(
                     ::nom::bytes::complete::tag("/"),
                     ::nom::branch::alt::<_, _, ::nom::error::Error<&str>, _>((
                         ::nom::bytes::complete::take_until("/"),
                         ::nom::combinator::rest,
                     )),
                 ),
             ))(input_string)?;
         debug_assert_eq!("", input_string);
         /* ServerHttpBoundProtocolGenerator.kt:1157 */
         input =
             input.set_name(crate::protocol_serde::shape_get_pokemon_species_input::de_name(m1)?);
         /* ServerHttpBoundProtocolGenerator.kt:896 */
         input.build()?
         /* ServerHttpBoundProtocolGenerator.kt:424 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:408 */
-57
+}
-58
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:445 */
 pub fn ser_get_pokemon_species_http_response(
     #[allow(unused_variables)] output: crate::output::GetPokemonSpeciesOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     /* ServerHttpBoundProtocolGenerator.kt:457 */
     Ok({
         /* RustType.kt:534 */
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         /* ServerHttpBoundProtocolGenerator.kt:547 */
         let mut builder = ::http_1x::Response::builder();
         /* ServerHttpBoundProtocolGenerator.kt:633 */
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             ::http_1x::header::CONTENT_TYPE,
             "application/json",
         );
         /* ServerHttpBoundProtocolGenerator.kt:718 */
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         /* ServerHttpBoundProtocolGenerator.kt:597 */
         let payload =
             crate::protocol_serde::shape_get_pokemon_species_output::ser_get_pokemon_species_output_output_output(&output)?
--
+        ;
             /* HttpBoundProtocolPayloadGenerator.kt:235 */crate::protocol_serde::shape_get_pokemon_species_output::ser_get_pokemon_species_output_output_output(&output)?
         /* ServerHttpBoundProtocolGenerator.kt:597 */;
         /* ServerHttpBoundProtocolGenerator.kt:699 */
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             ::http_1x::header::CONTENT_LENGTH,
             content_length,
         );
         /* ServerHttpBoundProtocolGenerator.kt:603 */
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         /* ServerHttpBoundProtocolGenerator.kt:611 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:457 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:445 */
-101
+}
-102
 /* RustType.kt:534 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:471 */
 pub fn ser_get_pokemon_species_http_error(
     error: &crate::error::GetPokemonSpeciesError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     /* ServerHttpBoundProtocolGenerator.kt:476 */
     Ok({
         /* ServerHttpBoundProtocolGenerator.kt:492 */
         match error {
             /* ServerHttpBoundProtocolGenerator.kt:500 */
             crate::error::GetPokemonSpeciesError::ResourceNotFoundException(output) => {
                 /* ServerHttpBoundProtocolGenerator.kt:501 */
                 let payload = crate::protocol_serde::shape_resource_not_found_exception::ser_resource_not_found_exception_error(output)?;
                 /* RustType.kt:534 */
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:511 */
                 let mut builder = ::http_1x::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:633 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     ::http_1x::header::CONTENT_TYPE,
                     "application/json",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:633 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
                     "ResourceNotFoundException",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:699 */
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     ::http_1x::header::CONTENT_LENGTH,
                     content_length,
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:528 */
                 builder
                     .status(404)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                 /* ServerHttpBoundProtocolGenerator.kt:500 */
-148
+            }
             /* ServerHttpBoundProtocolGenerator.kt:500 */
             crate::error::GetPokemonSpeciesError::ValidationException(output) => {
                 /* ServerHttpBoundProtocolGenerator.kt:501 */
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 /* RustType.kt:534 */
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:511 */
                 let mut builder = ::http_1x::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:633 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     ::http_1x::header::CONTENT_TYPE,
                     "application/json",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:633 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
                     "ValidationException",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:699 */
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     ::http_1x::header::CONTENT_LENGTH,
                     content_length,
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:528 */
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                 /* ServerHttpBoundProtocolGenerator.kt:500 */
             } /* ServerHttpBoundProtocolGenerator.kt:492 */
-182
+        }
--
+        }
         /* ServerHttpBoundProtocolGenerator.kt:476 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:471 */
-186
+}

56 57	`pub(crate) mod shape_flavor_text;`
57 58
58 59	`pub(crate) mod shape_validation_exception_field;`