Server Test

rev. dfb5149b65b7bcc09edd15b8e071ad43b5ac5943 (ignoring whitespace)

Files changed:

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

@@ -1,1 +31,32 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_GETSTORAGE: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::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>>
-9
+    }
-10
+}
-11
 impl std::future::Future for GetStorageInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::GetStorageInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-17
     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)
-24
+    }
-25
+}
-26
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::GetStorageInput
 where

@@ -38,39 +133,137 @@

↥ Expand context

-39
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = GetStorageInputFuture;
-42
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_GETSTORAGE,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-50
+            }
             crate::protocol_serde::shape_get_storage::de_get_storage_http_request(request)
                 .await
                 .map_err(Into::into)
         };
         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,
-61
+                )
             },
         );
         GetStorageInputFuture {
             inner: Box::pin(fut),
-66
+        }
-67
+    }
-68
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::GetStorageOutput
-74
+{
     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))
-81
+            }
-82
+        }
-83
+    }
-84
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::GetStorageError
-90
+{
     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
-98
+            }
             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))
-102
+            }
-103
+        }
-104
+    }
-105
+}
-106
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_GETPOKEMONSPECIES: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::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>>
-114
+    }
-115
+}
-116
 impl std::future::Future for GetPokemonSpeciesInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::GetPokemonSpeciesInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-122
     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)
-129
+    }
-130
+}
-131
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::GetPokemonSpeciesInput
 where

@@ -142,146 +239,246 @@

↥ Expand context

     type Future = GetPokemonSpeciesInputFuture;
-147
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_GETPOKEMONSPECIES,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-155
+            }
             crate::protocol_serde::shape_get_pokemon_species::de_get_pokemon_species_http_request(
                 request,
-158
+            )
             .await
             .map_err(Into::into)
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-168
+                )
             },
         );
         GetPokemonSpeciesInputFuture {
             inner: Box::pin(fut),
-173
+        }
-174
+    }
-175
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::GetPokemonSpeciesOutput
-181
+{
     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))
-188
+                        }
-189
+                    }
-190
+    }
-191
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::GetPokemonSpeciesError
-197
+{
     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
-207
+            }
             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))
-211
+            }
-212
+        }
-213
+    }
-214
+}
-215
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_STREAMPOKEMONRADIO: ::mime::Mime = ::mime::APPLICATION_OCTET_STREAM;
 ::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>>
-223
+    }
-224
+}
-225
 impl std::future::Future for StreamPokemonRadioInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::StreamPokemonRadioInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-231
     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)
-238
+    }
-239
+}
-240
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::StreamPokemonRadioInput
 where

@@ -248,255 +323,332 @@

↥ Expand context

     type Future = StreamPokemonRadioInputFuture;
-256
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_STREAMPOKEMONRADIO,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-264
+            }
             crate::protocol_serde::shape_stream_pokemon_radio::de_stream_pokemon_radio_http_request(
                 request,
-267
+            )
             .await
             .map_err(Into::into)
         };
         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,
-277
+                )
             },
         );
         StreamPokemonRadioInputFuture {
             inner: Box::pin(fut),
-282
+        }
-283
+    }
-284
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::StreamPokemonRadioOutput
-290
+{
     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))
-297
+                        }
-298
+                    }
-299
+    }
-300
+}
-301
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_CHECKHEALTH: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::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>>
-309
+    }
-310
+}
-311
 impl std::future::Future for CheckHealthInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::CheckHealthInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-317
     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)
-324
+    }
-325
+}
-326
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::CheckHealthInput
 where

@@ -330,339 +405,416 @@

↥ Expand context

-339
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = CheckHealthInputFuture;
-342
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_CHECKHEALTH,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-350
+            }
             crate::protocol_serde::shape_check_health::de_check_health_http_request(request)
                 .await
                 .map_err(Into::into)
         };
         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,
-361
+                )
             },
         );
         CheckHealthInputFuture {
             inner: Box::pin(fut),
-366
+        }
-367
+    }
-368
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::CheckHealthOutput
-374
+{
     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))
-381
+            }
-382
+        }
-383
+    }
-384
+}
-385
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 static CONTENT_TYPE_CAPTUREPOKEMON: std::sync::LazyLock<::mime::Mime> =
     std::sync::LazyLock::new(|| {
         "application/vnd.amazon.eventstream"
             .parse::<::mime::Mime>()
             .expect("BUG: MIME parsing failed, content_type is not valid")
     });
 ::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 {

↧ Expand context

         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>>
-398
+    }
-399
+}
-400
 impl std::future::Future for CapturePokemonInputFuture {
     type Output = Result<
         crate::input::CapturePokemonInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-406
     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)
-413
+    }
-414
+}
-415
 impl<B>

@@ -418,429 +514,528 @@

↥ Expand context

-429
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = CapturePokemonInputFuture;
-432
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_CAPTUREPOKEMON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-440
+            }
             crate::protocol_serde::shape_capture_pokemon::de_capture_pokemon_http_request(request)
                 .await
                 .map_err(Into::into)
         };
         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,
-451
+                )
             },
         );
         CapturePokemonInputFuture {
             inner: Box::pin(fut),
-456
+        }
-457
+    }
-458
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::CapturePokemonOutput
-464
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_capture_pokemon::ser_capture_pokemon_http_response(self)
-467
+        {
             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))
-472
+            }
-473
+        }
-474
+    }
-475
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::CapturePokemonError
-481
+{
     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
-489
+            }
             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))
-493
+            }
-494
+        }
-495
+    }
-496
+}
-497
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_DONOTHING: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::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>>
-505
+    }
-506
+}
-507
 impl std::future::Future for DoNothingInputFuture {

↧ Expand context

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

@@ -521,535 +596,612 @@

↥ Expand context

-535
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = DoNothingInputFuture;
-538
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_DONOTHING,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-546
+            }
             crate::protocol_serde::shape_do_nothing::de_do_nothing_http_request(request)
                 .await
                 .map_err(Into::into)
         };
         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,
-557
+                )
             },
         );
         DoNothingInputFuture {
             inner: Box::pin(fut),
-562
+        }
-563
+    }
-564
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::DoNothingOutput
-570
+{
     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))
-577
+            }
-578
+        }
-579
+    }
-580
+}
-581
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_GETSERVERSTATISTICS: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::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>>
-589
+    }
-590
+}
-591
 impl std::future::Future for GetServerStatisticsInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::GetServerStatisticsInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-597
     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)
-604
+    }
-605
+}
-606
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::GetServerStatisticsInput
 where

@@ -603,619 +647,664 @@

↥ Expand context

-619
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = GetServerStatisticsInputFuture;
-622
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_GETSERVERSTATISTICS,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-630
+            }
             crate::protocol_serde::shape_get_server_statistics::de_get_server_statistics_http_request(request)
                             .await
                             .map_err(Into::into)
         };
         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,
-641
+                )
             },
         );
         GetServerStatisticsInputFuture {
             inner: Box::pin(fut),
-646
+        }
-647
+    }
-648
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::GetServerStatisticsOutput
-654
+{
     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))
-661
+                        }
-662
+                    }
-663
+    }
-664
+}

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,
-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| {
                     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:516 */
 #[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:345 */
 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:345 */
-35
+}
-36
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[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:345 */
 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:345 */
-80
+}
-81
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[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:345 */
 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:345 */
-114
+}
-115
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[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:345 */
 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:345 */
-133
+}
-134
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[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:345 */
 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:345 */
-175
+}
-176
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[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:345 */
 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:345 */
-194
+}
-195
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[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:345 */
 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:345 */
-228
+}
 /// See [`GetStorageOutput`](crate::output::GetStorageOutput).
 /// /* ServerBuilderGenerator.kt:171 */See [`GetStorageOutput`](crate::output::GetStorageOutput).
 pub mod get_storage_output {
-231
     /* RustType.kt:516 */
     #[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:516 */
     #[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:138 */`collection` was not provided but it is required when building `GetStorageOutput`.
         /* ServerBuilderConstraintViolations.kt:143 */
         MissingCollection,
         /* ServerBuilderConstraintViolations.kt:75 */
-244
+    }
     /* ServerBuilderConstraintViolations.kt:117 */
     impl ::std::fmt::Display for ConstraintViolation {
         /* ServerBuilderConstraintViolations.kt:118 */
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             /* ServerBuilderConstraintViolations.kt:119 */
             match self {
                 ConstraintViolation::MissingCollection => write!(f, "`collection` was not provided but it is required when building `GetStorageOutput`"),
--
+            }
                 /* ServerBuilderConstraintViolations.kt:127 */ConstraintViolation::MissingCollection => write!(f, "`collection` was not provided but it is required when building `GetStorageOutput`"),
             /* ServerBuilderConstraintViolations.kt:119 */}
             /* ServerBuilderConstraintViolations.kt:118 */
-254
+        }
         /* ServerBuilderConstraintViolations.kt:117 */
-256
+    }
     /* ServerBuilderConstraintViolations.kt:84 */
     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:516 */
     #[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:516 */
     #[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:516 */
     #[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:138 */`name` was not provided but it is required when building `GetPokemonSpeciesOutput`.
         /* ServerBuilderConstraintViolations.kt:143 */
         MissingName,
         /// `flavor_text_entries` was not provided but it is required when building `GetPokemonSpeciesOutput`.
         /// /* ServerBuilderConstraintViolations.kt:138 */`flavor_text_entries` was not provided but it is required when building `GetPokemonSpeciesOutput`.
         /* ServerBuilderConstraintViolations.kt:143 */
         MissingFlavorTextEntries,
         /* ServerBuilderConstraintViolations.kt:75 */
-339
+    }
     /* ServerBuilderConstraintViolations.kt:117 */
     impl ::std::fmt::Display for ConstraintViolation {
         /* ServerBuilderConstraintViolations.kt:118 */
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             /* ServerBuilderConstraintViolations.kt:119 */
             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:127 */ConstraintViolation::MissingName => write!(f, "`name` was not provided but it is required when building `GetPokemonSpeciesOutput`"),
                 /* ServerBuilderConstraintViolations.kt:127 */ConstraintViolation::MissingFlavorTextEntries => write!(f, "`flavor_text_entries` was not provided but it is required when building `GetPokemonSpeciesOutput`"),
             /* ServerBuilderConstraintViolations.kt:119 */}
             /* ServerBuilderConstraintViolations.kt:118 */
-350
+        }
         /* ServerBuilderConstraintViolations.kt:117 */
-352
+    }
     /* ServerBuilderConstraintViolations.kt:84 */
     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:516 */
     #[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:516 */
     #[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:113 */
                     .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:516 */
     #[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:516 */
     #[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:516 */
     #[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:138 */`events` was not provided but it is required when building `CapturePokemonOutput`.
         /* ServerBuilderConstraintViolations.kt:143 */
         MissingEvents,
         /* ServerBuilderConstraintViolations.kt:75 */
-545
+    }
     /* ServerBuilderConstraintViolations.kt:117 */
     impl ::std::fmt::Display for ConstraintViolation {
         /* ServerBuilderConstraintViolations.kt:118 */
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             /* ServerBuilderConstraintViolations.kt:119 */
             match self {
                 ConstraintViolation::MissingEvents => write!(f, "`events` was not provided but it is required when building `CapturePokemonOutput`"),
--
+            }
                 /* ServerBuilderConstraintViolations.kt:127 */ConstraintViolation::MissingEvents => write!(f, "`events` was not provided but it is required when building `CapturePokemonOutput`"),
             /* ServerBuilderConstraintViolations.kt:119 */}
             /* ServerBuilderConstraintViolations.kt:118 */
-555
+        }
         /* ServerBuilderConstraintViolations.kt:117 */
-557
+    }
     /* ServerBuilderConstraintViolations.kt:84 */
     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:516 */
     #[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:516 */
     #[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:516 */
     #[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:516 */
     #[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:138 */`calls_count` was not provided but it is required when building `GetServerStatisticsOutput`.
         /* ServerBuilderConstraintViolations.kt:143 */
         MissingCallsCount,
         /* ServerBuilderConstraintViolations.kt:75 */
-682
+    }
     /* ServerBuilderConstraintViolations.kt:117 */
     impl ::std::fmt::Display for ConstraintViolation {
         /* ServerBuilderConstraintViolations.kt:118 */
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             /* ServerBuilderConstraintViolations.kt:119 */
             match self {
                 ConstraintViolation::MissingCallsCount => write!(f, "`calls_count` was not provided but it is required when building `GetServerStatisticsOutput`"),
--
+            }
                 /* ServerBuilderConstraintViolations.kt:127 */ConstraintViolation::MissingCallsCount => write!(f, "`calls_count` was not provided but it is required when building `GetServerStatisticsOutput`"),
             /* ServerBuilderConstraintViolations.kt:119 */}
             /* ServerBuilderConstraintViolations.kt:118 */
-692
+        }
         /* ServerBuilderConstraintViolations.kt:117 */
-694
+    }
     /* ServerBuilderConstraintViolations.kt:84 */
     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:516 */
     #[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 +223,304 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* RustType.kt:516 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:383 */
 pub async fn de_capture_pokemon_http_request<B>(
     #[allow(unused_variables)] request: ::http::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::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-17
+{
     /* ServerHttpBoundProtocolGenerator.kt:399 */
     Ok({
         /* RustType.kt:516 */
         #[allow(unused_mut)]
         /* ServerHttpBoundProtocolGenerator.kt:723 */
         let mut input = crate::input::capture_pokemon_input::Builder::default();
         /* RustType.kt:516 */
         #[allow(unused_variables)]
         /* ServerHttpBoundProtocolGenerator.kt:728 */
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         /* ServerHttpBoundProtocolGenerator.kt:794 */
         if let Some(value) = {
             Some(
                 crate::protocol_serde::shape_capture_pokemon_input::de_events_payload(
                     &mut body.into().into_inner(),
                 )?,
-36
+            )
         } {
             input = input.set_events(value)
-39
+        }
         /* ServerHttpBoundProtocolGenerator.kt:986 */
         let input_string = uri.path();
         /* ServerHttpBoundProtocolGenerator.kt:998 */
         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:1009 */
         input =
             input.set_region(crate::protocol_serde::shape_capture_pokemon_input::de_region(m1)?);
         /* ServerHttpBoundProtocolGenerator.kt:834 */
         input.build()?
         /* ServerHttpBoundProtocolGenerator.kt:399 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:383 */
-68
+}
-69
 /* RustType.kt:516 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:421 */
 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:433 */
     Ok({
         /* RustType.kt:516 */
         #[allow(unused_mut)]
         /* ServerHttpBoundProtocolGenerator.kt:523 */
         let mut builder = ::http::Response::builder();
         /* ServerHttpBoundProtocolGenerator.kt:597 */
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/vnd.amazon.eventstream",
         );
         /* ServerHttpBoundProtocolGenerator.kt:682 */
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         /* ServerHttpBoundProtocolGenerator.kt:543 */
         let body = ::aws_smithy_http_server::body::boxed(
             ::aws_smithy_http_server::body::Body::wrap_stream({
             ::aws_smithy_http_server::body::Body::wrap_stream(
                 /* ServerHttpBoundProtocolGenerator.kt:135 */
-+
+                {
                     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 {};
                 let adapter: ::aws_smithy_http::event_stream::MessageStreamAdapter<_, _> = output
                     let adapter: ::aws_smithy_http::event_stream::MessageStreamAdapter<_, _> =
                         output
                             .events
                             .into_body_stream(marshaller, error_marshaller, signer);
                     adapter
             }),
                 }, /* ServerHttpBoundProtocolGenerator.kt:543 */
             ),
         );
         /* ServerHttpBoundProtocolGenerator.kt:575 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:433 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:421 */
-117
+}
-118
 /* RustType.kt:516 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:447 */
 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:452 */
     Ok({
         /* ServerHttpBoundProtocolGenerator.kt:468 */
         match error {
             /* ServerHttpBoundProtocolGenerator.kt:476 */
             crate::error::CapturePokemonError::ValidationException(output) => {
                 /* ServerHttpBoundProtocolGenerator.kt:477 */
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 /* RustType.kt:516 */
                 #[allow(unused_mut)]
                 /* ServerHttpBoundProtocolGenerator.kt:487 */
                 let mut builder = ::http::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:597 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:597 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "ValidationException",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:663 */
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:504 */
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                 /* ServerHttpBoundProtocolGenerator.kt:476 */
-164
+            }
             /* ServerHttpBoundProtocolGenerator.kt:476 */
             crate::error::CapturePokemonError::MasterBallUnsuccessful(output) => {
                 /* ServerHttpBoundProtocolGenerator.kt:477 */
                 let payload = crate::protocol_serde::shape_master_ball_unsuccessful::ser_master_ball_unsuccessful_error(output)?;
                 /* RustType.kt:516 */
                 #[allow(unused_mut)]
                 /* ServerHttpBoundProtocolGenerator.kt:487 */
                 let mut builder = ::http::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:597 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:597 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "MasterBallUnsuccessful",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:663 */
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:504 */
                 builder
                     .status(500)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                 /* ServerHttpBoundProtocolGenerator.kt:476 */
-197
+            }
             /* ServerHttpBoundProtocolGenerator.kt:476 */
             crate::error::CapturePokemonError::InvalidPokeballError(output) => {
                 /* ServerHttpBoundProtocolGenerator.kt:477 */
                 let payload = crate::protocol_serde::shape_invalid_pokeball_error::ser_invalid_pokeball_error_error(output)?;
                 /* RustType.kt:516 */
                 #[allow(unused_mut)]
                 /* ServerHttpBoundProtocolGenerator.kt:487 */
                 let mut builder = ::http::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:597 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:597 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "InvalidPokeballError",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:663 */
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:504 */
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                 /* ServerHttpBoundProtocolGenerator.kt:476 */
-230
+            }
             /* ServerHttpBoundProtocolGenerator.kt:476 */
             crate::error::CapturePokemonError::ThrottlingError(output) => {
                 /* ServerHttpBoundProtocolGenerator.kt:477 */
                 let payload =
                     crate::protocol_serde::shape_throttling_error::ser_throttling_error_error(
                         output,
                     )?;
                 /* RustType.kt:516 */
                 #[allow(unused_mut)]
                 /* ServerHttpBoundProtocolGenerator.kt:487 */
                 let mut builder = ::http::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:597 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:597 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "ThrottlingError",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:663 */
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:504 */
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                 /* ServerHttpBoundProtocolGenerator.kt:476 */
-266
+            }
             /* ServerHttpBoundProtocolGenerator.kt:476 */
             crate::error::CapturePokemonError::UnsupportedRegionError(output) => {
                 /* ServerHttpBoundProtocolGenerator.kt:477 */
                 let payload = crate::protocol_serde::shape_unsupported_region_error::ser_unsupported_region_error_error(output)?;
                 /* RustType.kt:516 */
                 #[allow(unused_mut)]
                 /* ServerHttpBoundProtocolGenerator.kt:487 */
                 let mut builder = ::http::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:597 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:597 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "UnsupportedRegionError",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:663 */
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:504 */
                 builder
                     .status(500)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                 /* ServerHttpBoundProtocolGenerator.kt:476 */
             } /* ServerHttpBoundProtocolGenerator.kt:468 */
-300
+        }
--
+        }
         /* ServerHttpBoundProtocolGenerator.kt:452 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:447 */
-304
+}

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

@@ -1,1 +29,36 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* HttpBindingGenerator.kt:230 */
 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:272 */
     let unmarshaller = crate::event_stream_serde::AttemptCapturingPokemonEventUnmarshaller::new();
     let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
     Ok(::aws_smithy_http::event_stream::Receiver::new(
         unmarshaller,
         body,
     ))
     /* HttpBindingGenerator.kt:230 */
-20
+}
-21
 /* ServerHttpBoundProtocolGenerator.kt:1292 */
 pub fn de_region(
     value: &str,
 ) -> std::result::Result<
     ::std::string::String,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
 > {
     /* ServerHttpBoundProtocolGenerator.kt:1302 */
     let value = ::percent_encoding::percent_decode_str(value)
         .decode_utf8()?
         .into_owned();
     /* ServerHttpBoundProtocolGenerator.kt:1357 */
     Ok(value)
     /* ServerHttpBoundProtocolGenerator.kt:1292 */
-36
+}

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:516 */
             #[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:516 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:383 */
 pub async fn de_check_health_http_request<B>(
     #[allow(unused_variables)] request: ::http::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:399 */
     Ok({
         /* RustType.kt:516 */
         #[allow(unused_mut)]
         /* ServerHttpBoundProtocolGenerator.kt:723 */
         let mut input = crate::input::check_health_input::Builder::default();
         /* RustType.kt:516 */
         #[allow(unused_variables)]
         /* ServerHttpBoundProtocolGenerator.kt:728 */
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         /* ServerHttpBoundProtocolGenerator.kt:811 */
         ::aws_smithy_http_server::protocol::content_type_header_classifier_smithy(&headers, None)?;
         /* ServerHttpBoundProtocolGenerator.kt:834 */
         input.build()
         /* ServerHttpBoundProtocolGenerator.kt:399 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:383 */
-36
+}
-37
 /* RustType.kt:516 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:421 */
 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:433 */
     Ok({
         /* RustType.kt:516 */
         #[allow(unused_mut)]
         /* ServerHttpBoundProtocolGenerator.kt:523 */
         let mut builder = ::http::Response::builder();
         /* ServerHttpBoundProtocolGenerator.kt:597 */
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/json",
         );
         /* ServerHttpBoundProtocolGenerator.kt:682 */
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload = "";
         /* ServerHttpBoundProtocolGenerator.kt:561 */
         let payload =
             /* HttpBoundProtocolPayloadGenerator.kt:235 */""
         /* ServerHttpBoundProtocolGenerator.kt:561 */;
         /* ServerHttpBoundProtocolGenerator.kt:663 */
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             content_length,
         );
         /* ServerHttpBoundProtocolGenerator.kt:567 */
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         /* ServerHttpBoundProtocolGenerator.kt:575 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:433 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:421 */
-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:516 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:383 */
 pub async fn de_do_nothing_http_request<B>(
     #[allow(unused_variables)] request: ::http::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:399 */
     Ok({
         /* RustType.kt:516 */
         #[allow(unused_mut)]
         /* ServerHttpBoundProtocolGenerator.kt:723 */
         let mut input = crate::input::do_nothing_input::Builder::default();
         /* RustType.kt:516 */
         #[allow(unused_variables)]
         /* ServerHttpBoundProtocolGenerator.kt:728 */
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         /* ServerHttpBoundProtocolGenerator.kt:834 */
         input.build()
         /* ServerHttpBoundProtocolGenerator.kt:399 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:383 */
-34
+}
-35
 /* RustType.kt:516 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:421 */
 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:433 */
     Ok({
         /* RustType.kt:516 */
         #[allow(unused_mut)]
         /* ServerHttpBoundProtocolGenerator.kt:523 */
         let mut builder = ::http::Response::builder();
         /* ServerHttpBoundProtocolGenerator.kt:597 */
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/json",
         );
         /* ServerHttpBoundProtocolGenerator.kt:682 */
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         /* ServerHttpBoundProtocolGenerator.kt:561 */
         let payload =
             crate::protocol_serde::shape_do_nothing_output::ser_do_nothing_output_output_output(
                 &output,
             )?;
             /* HttpBoundProtocolPayloadGenerator.kt:237 */crate::protocol_serde::shape_do_nothing_output::ser_do_nothing_output_output_output(&output)?
         /* ServerHttpBoundProtocolGenerator.kt:561 */;
         /* ServerHttpBoundProtocolGenerator.kt:663 */
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             content_length,
         );
         /* ServerHttpBoundProtocolGenerator.kt:567 */
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         /* ServerHttpBoundProtocolGenerator.kt:575 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:433 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:421 */
-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:516 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:383 */
 pub async fn de_get_pokemon_species_http_request<B>(
     #[allow(unused_variables)] request: ::http::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:399 */
     Ok({
         /* RustType.kt:516 */
         #[allow(unused_mut)]
         /* ServerHttpBoundProtocolGenerator.kt:723 */
         let mut input = crate::input::get_pokemon_species_input::Builder::default();
         /* RustType.kt:516 */
         #[allow(unused_variables)]
         /* ServerHttpBoundProtocolGenerator.kt:728 */
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         /* ServerHttpBoundProtocolGenerator.kt:986 */
         let input_string = uri.path();
         /* ServerHttpBoundProtocolGenerator.kt:998 */
         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:1009 */
         input =
             input.set_name(crate::protocol_serde::shape_get_pokemon_species_input::de_name(m1)?);
         /* ServerHttpBoundProtocolGenerator.kt:834 */
         input.build()?
         /* ServerHttpBoundProtocolGenerator.kt:399 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:383 */
-57
+}
-58
 /* RustType.kt:516 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:421 */
 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:433 */
     Ok({
         /* RustType.kt:516 */
         #[allow(unused_mut)]
         /* ServerHttpBoundProtocolGenerator.kt:523 */
         let mut builder = ::http::Response::builder();
         /* ServerHttpBoundProtocolGenerator.kt:597 */
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/json",
         );
         /* ServerHttpBoundProtocolGenerator.kt:682 */
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         /* ServerHttpBoundProtocolGenerator.kt:561 */
         let payload =
             crate::protocol_serde::shape_get_pokemon_species_output::ser_get_pokemon_species_output_output_output(&output)?
--
+        ;
             /* HttpBoundProtocolPayloadGenerator.kt:237 */crate::protocol_serde::shape_get_pokemon_species_output::ser_get_pokemon_species_output_output_output(&output)?
         /* ServerHttpBoundProtocolGenerator.kt:561 */;
         /* ServerHttpBoundProtocolGenerator.kt:663 */
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             content_length,
         );
         /* ServerHttpBoundProtocolGenerator.kt:567 */
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         /* ServerHttpBoundProtocolGenerator.kt:575 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:433 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:421 */
-101
+}
-102
 /* RustType.kt:516 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:447 */
 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:452 */
     Ok({
         /* ServerHttpBoundProtocolGenerator.kt:468 */
         match error {
             /* ServerHttpBoundProtocolGenerator.kt:476 */
             crate::error::GetPokemonSpeciesError::ValidationException(output) => {
                 /* ServerHttpBoundProtocolGenerator.kt:477 */
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 /* RustType.kt:516 */
                 #[allow(unused_mut)]
                 /* ServerHttpBoundProtocolGenerator.kt:487 */
                 let mut builder = ::http::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:597 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/json",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:597 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "ValidationException",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:663 */
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:504 */
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                 /* ServerHttpBoundProtocolGenerator.kt:476 */
-148
+            }
             /* ServerHttpBoundProtocolGenerator.kt:476 */
             crate::error::GetPokemonSpeciesError::ResourceNotFoundException(output) => {
                 /* ServerHttpBoundProtocolGenerator.kt:477 */
                 let payload = crate::protocol_serde::shape_resource_not_found_exception::ser_resource_not_found_exception_error(output)?;
                 /* RustType.kt:516 */
                 #[allow(unused_mut)]
                 /* ServerHttpBoundProtocolGenerator.kt:487 */
                 let mut builder = ::http::Response::builder();
                 /* ServerHttpBoundProtocolGenerator.kt:597 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/json",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:597 */
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "ResourceNotFoundException",
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:663 */
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 /* ServerHttpBoundProtocolGenerator.kt:504 */
                 builder
                     .status(404)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                 /* ServerHttpBoundProtocolGenerator.kt:476 */
             } /* ServerHttpBoundProtocolGenerator.kt:468 */
-182
+        }
--
+        }
         /* ServerHttpBoundProtocolGenerator.kt:452 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:447 */
-186
+}

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

@@ -1,1 +12,16 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* ServerHttpBoundProtocolGenerator.kt:1292 */
 pub fn de_name(
     value: &str,
 ) -> std::result::Result<
     ::std::string::String,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
 > {
     /* ServerHttpBoundProtocolGenerator.kt:1302 */
     let value = ::percent_encoding::percent_decode_str(value)
         .decode_utf8()?
         .into_owned();
     /* ServerHttpBoundProtocolGenerator.kt:1357 */
     Ok(value)
     /* ServerHttpBoundProtocolGenerator.kt:1292 */
-16
+}

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

@@ -1,1 +35,58 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonSerializerGenerator.kt:213 */
 pub fn ser_get_pokemon_species_output_output_output(
     value: &crate::output::GetPokemonSpeciesOutput,
 ) -> ::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_get_pokemon_species_output::ser_get_pokemon_species_output_output(
         &mut object,
         value,
     )?;
     /* JsonSerializerGenerator.kt:227 */
     object.finish();
     Ok(out)
     /* JsonSerializerGenerator.kt:213 */
-18
+}
-19
 /* JsonSerializerGenerator.kt:358 */
 pub fn ser_get_pokemon_species_output_output(
     object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
     input: &crate::output::GetPokemonSpeciesOutput,
 ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
     /* SerializerUtil.kt:42 */
-26
+    {
         /* JsonSerializerGenerator.kt:484 */
         let mut array_1 = object.key("flavorTextEntries").start_array();
         /* JsonSerializerGenerator.kt:524 */
         for item_2 in &input.flavor_text_entries {
             /* SerializerUtil.kt:42 */
-32
+            {
                 /* JsonSerializerGenerator.kt:495 */
                 #[allow(unused_mut)]
                 /* JsonSerializerGenerator.kt:496 */
                 let mut object_3 = array_1.value().start_object();
                 /* JsonSerializerGenerator.kt:375 */
                 crate::protocol_serde::shape_flavor_text::ser_flavor_text(&mut object_3, item_2)?;
                 /* JsonSerializerGenerator.kt:515 */
                 object_3.finish();
                 /* SerializerUtil.kt:42 */
-42
+            }
             /* JsonSerializerGenerator.kt:524 */
-44
+        }
         /* JsonSerializerGenerator.kt:486 */
         array_1.finish();
         /* SerializerUtil.kt:42 */
-48
+    }
     /* SerializerUtil.kt:42 */
-50
+    {
         /* JsonSerializerGenerator.kt:423 */
         object.key("name").string(input.name.as_str());
         /* SerializerUtil.kt:42 */
-54
+    }
     /* JsonSerializerGenerator.kt:372 */
     Ok(())
     /* JsonSerializerGenerator.kt:358 */
-58
+}

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

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

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* RustType.kt:516 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:383 */
 pub async fn de_get_server_statistics_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::GetServerStatisticsInput,
     ::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:399 */
     Ok({
         /* RustType.kt:516 */
         #[allow(unused_mut)]
         /* ServerHttpBoundProtocolGenerator.kt:723 */
         let mut input = crate::input::get_server_statistics_input::Builder::default();
         /* RustType.kt:516 */
         #[allow(unused_variables)]
         /* ServerHttpBoundProtocolGenerator.kt:728 */
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         /* ServerHttpBoundProtocolGenerator.kt:834 */
         input.build()
         /* ServerHttpBoundProtocolGenerator.kt:399 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:383 */
-34
+}
-35
 /* RustType.kt:516 */
 #[allow(clippy::unnecessary_wraps)]
 /* ServerHttpBoundProtocolGenerator.kt:421 */
 pub fn ser_get_server_statistics_http_response(
     #[allow(unused_variables)] output: crate::output::GetServerStatisticsOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     /* ServerHttpBoundProtocolGenerator.kt:433 */
     Ok({
         /* RustType.kt:516 */
         #[allow(unused_mut)]
         /* ServerHttpBoundProtocolGenerator.kt:523 */
         let mut builder = ::http::Response::builder();
         /* ServerHttpBoundProtocolGenerator.kt:597 */
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/json",
         );
         /* ServerHttpBoundProtocolGenerator.kt:682 */
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         /* ServerHttpBoundProtocolGenerator.kt:561 */
         let payload =
             crate::protocol_serde::shape_get_server_statistics_output::ser_get_server_statistics_output_output_output(&output)?
--
+        ;
             /* HttpBoundProtocolPayloadGenerator.kt:237 */crate::protocol_serde::shape_get_server_statistics_output::ser_get_server_statistics_output_output_output(&output)?
         /* ServerHttpBoundProtocolGenerator.kt:561 */;
         /* ServerHttpBoundProtocolGenerator.kt:663 */
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             content_length,
         );
         /* ServerHttpBoundProtocolGenerator.kt:567 */
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         /* ServerHttpBoundProtocolGenerator.kt:575 */
         builder.body(body)?
         /* ServerHttpBoundProtocolGenerator.kt:433 */
     })
     /* ServerHttpBoundProtocolGenerator.kt:421 */
-78
+}

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

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

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* JsonSerializerGenerator.kt:213 */
 pub fn ser_get_server_statistics_output_output_output(
     value: &crate::output::GetServerStatisticsOutput,
 ) -> ::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_get_server_statistics_output::ser_get_server_statistics_output_output(&mut object, value)?;
     /* JsonSerializerGenerator.kt:227 */
     object.finish();
     Ok(out)
     /* JsonSerializerGenerator.kt:213 */
-15
+}
-16
 /* JsonSerializerGenerator.kt:358 */
 pub fn ser_get_server_statistics_output_output(
     object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
     input: &crate::output::GetServerStatisticsOutput,
 ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
     /* SerializerUtil.kt:42 */
-23
+    {
         /* JsonSerializerGenerator.kt:432 */
         object.key("calls_count").number(
             #[allow(clippy::useless_conversion)]
             ::aws_smithy_types::Number::NegInt((input.calls_count).into()),
         );
         /* SerializerUtil.kt:42 */
-30
+    }
     /* JsonSerializerGenerator.kt:372 */
     Ok(())
     /* JsonSerializerGenerator.kt:358 */
-34
+}

Pages: 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101

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