Server Test

tmp-codegen-diff/codegen-server-test/constraints/rust-server-codegen/src/protocol_serde/shape_event_streams_operation.rs

@@ -1,1 +68,58 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_event_streams_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::EventStreamsOperationInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-8
+>
 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>,
-15
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::event_streams_operation_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) = {
             let mut receiver =
             let receiver =
                 crate::protocol_serde::shape_event_streams_operation_input::de_events_payload(
                     &mut body.into().into_inner(),
                 )?;
             if let Some(_initial_event) = receiver
                                                 .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
                                                 .await
                                                 .map_err(
                                                     |ev_error| ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::ConstraintViolation(
                                                         #[allow(clippy::useless_conversion)]
                                                         format!("{ev_error}").into()
--
+                                                    )
                                                 )? {
--
--
+                                            }
-+
             Some(receiver)
         } {
             input = input.set_events(value)
-32
+        }
         input.build()?
     })
-35
+}
-36
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_event_streams_operation_http_response(

↧ Expand context

     #[allow(unused_variables)] output: crate::output::EventStreamsOperationOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/vnd.amazon.eventstream",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let body = ::aws_smithy_http_server::body::boxed(
             ::aws_smithy_http_server::body::Body::wrap_stream({
                 let error_marshaller = crate::event_stream_serde::EventErrorMarshaller::new();
                 let marshaller = crate::event_stream_serde::EventMarshaller::new();
                 let signer = ::aws_smithy_eventstream::frame::NoOpSigner {};

tmp-codegen-diff/codegen-server-test/constraints_without_public_constrained_types/rust-server-codegen/src/protocol_serde/shape_event_streams_operation.rs

@@ -1,1 +68,58 @@

↥ Expand context

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_event_streams_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::EventStreamsOperationInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-8
+>
 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>,
-15
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::event_streams_operation_input_internal::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) = {
             let mut receiver =
             let receiver =
                 crate::protocol_serde::shape_event_streams_operation_input::de_events_payload(
                     &mut body.into().into_inner(),
                 )?;
             if let Some(_initial_event) = receiver
                                                 .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
                                                 .await
                                                 .map_err(
                                                     |ev_error| ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::ConstraintViolation(
                                                         #[allow(clippy::useless_conversion)]
                                                         format!("{ev_error}").into()
--
+                                                    )
                                                 )? {
--
--
+                                            }
-+
             Some(receiver)
         } {
             input = input.set_events(value)
-32
+        }
         input.build()?
     })
-35
+}
-36
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_event_streams_operation_http_response(

↧ Expand context

     #[allow(unused_variables)] output: crate::output::EventStreamsOperationOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/vnd.amazon.eventstream",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let body = ::aws_smithy_http_server::body::boxed(
             ::aws_smithy_http_server::body::Body::wrap_stream({
                 let error_marshaller = crate::event_stream_serde::EventErrorMarshaller::new();
                 let marshaller = crate::event_stream_serde::EventMarshaller::new();
                 let signer = ::aws_smithy_eventstream::frame::NoOpSigner {};

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

@@ -1,1 +68,57 @@

↥ Expand context

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 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::aws_json::rejection::RequestRejection,
-8
+>
 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::aws_json::rejection::RequestRejection:

         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-15
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::capture_pokemon_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) = {
             let mut receiver =
                 crate::protocol_serde::shape_capture_pokemon_input::de_events_payload(
                     &mut body.into().into_inner(),
                 )?;
             if let Some(_initial_event) = receiver
                                                 .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
                                                 .await
                                                 .map_err(
                                                     |ev_error| ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::ConstraintViolation(
                                                         #[allow(clippy::useless_conversion)]
                                                         format!("{ev_error}").into()
--
+                                                    )
                                                 )? {
--
--
+                                            }
             let receiver = crate::protocol_serde::shape_capture_pokemon_input::de_events_payload(
                 &mut body.into().into_inner(),
             )?;
-+
             Some(receiver)
         } {
             input = input.set_events(value)
-31
+        }
         input.build()?
     })
-34
+}
-35
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_capture_pokemon_http_response(

↧ Expand context

     #[allow(unused_variables)] output: crate::output::CapturePokemonOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::aws_json::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/x-amz-json-1.0",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let body = ::aws_smithy_http_server::body::boxed(
             ::aws_smithy_http_server::body::Body::wrap_stream({
                 let error_marshaller =
                     crate::event_stream_serde::CapturePokemonEventsErrorMarshaller::new();
                 let marshaller = crate::event_stream_serde::CapturePokemonEventsMarshaller::new();

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

@@ -1,1 +68,57 @@

↥ Expand context

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 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,
-8
+>
 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>,
-15
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::capture_pokemon_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) = {
             let mut receiver =
                 crate::protocol_serde::shape_capture_pokemon_input::de_events_payload(
                     &mut body.into().into_inner(),
                 )?;
             if let Some(_initial_event) = receiver
                                                 .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
                                                 .await
                                                 .map_err(
                                                     |ev_error| ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::ConstraintViolation(
                                                         #[allow(clippy::useless_conversion)]
                                                         format!("{ev_error}").into()
--
+                                                    )
                                                 )? {
--
--
+                                            }
             let receiver = crate::protocol_serde::shape_capture_pokemon_input::de_events_payload(
                 &mut body.into().into_inner(),
             )?;
-+
             Some(receiver)
         } {
             input = input.set_events(value)
-31
+        }
         let input_string = uri.path();
         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>>(

↧ Expand context

                         "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);
         input =
             input.set_region(crate::protocol_serde::shape_capture_pokemon_input::de_region(m1)?);
         input.build()?
     })
-54
+}
-55
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_capture_pokemon_http_response(

tmp-codegen-diff/codegen-server-test/rpcv2Cbor_extras/rust-server-codegen/src/protocol_serde/shape_streaming_operation.rs

@@ -1,1 +68,58 @@

↥ Expand context

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_streaming_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::StreamingOperationInput,
     ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::RequestRejection,
-8
+>
 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::rpc_v2_cbor::rejection::RequestRejection:

         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-15
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::streaming_operation_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) = {
             let mut receiver =
             let receiver =
                 crate::protocol_serde::shape_streaming_operation_input::de_events_payload(
                     &mut body.into().into_inner(),
                 )?;
             if let Some(_initial_event) = receiver
                                                 .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
                                                 .await
                                                 .map_err(
                                                     |ev_error| ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::RequestRejection::ConstraintViolation(
                                                         #[allow(clippy::useless_conversion)]
                                                         format!("{ev_error}").into()
--
+                                                    )
                                                 )? {
--
--
+                                            }
-+
             Some(receiver)
         } {
             input = input.set_events(value)
-32
+        }
         input.build()?
     })
-35
+}
-36
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_streaming_operation_http_response(

↧ Expand context

     #[allow(unused_variables)] output: crate::output::StreamingOperationOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/vnd.amazon.eventstream",
         );
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::HeaderName::from_static("smithy-protocol"),
             "rpc-v2-cbor",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);

tmp-codegen-diff/codegen-server-test/rpcv2Cbor_extras/rust-server-codegen/src/protocol_serde/shape_streaming_operation_with_initial_data.rs

@@ -1,1 +66,67 @@

↥ Expand context

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_streaming_operation_with_initial_data_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::StreamingOperationWithInitialDataInput,
     ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::RequestRejection,
-8
+>
 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::rpc_v2_cbor::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,

-15
+{
     Ok({
         #[allow(unused_mut)]
         let mut input =
             crate::input::streaming_operation_with_initial_data_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) = {
             let mut receiver = crate::protocol_serde::shape_streaming_operation_with_initial_data_input::de_events_payload(&mut body.into().into_inner())?;
             let receiver = crate::protocol_serde::shape_streaming_operation_with_initial_data_input::de_events_payload(&mut body.into().into_inner())?;
             let mut receiver = receiver;
             if let Some(_initial_event) = receiver
                                                 .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
                                                 .await
                                                 .map_err(
                                                     |ev_error| ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::RequestRejection::ConstraintViolation(
                                                         #[allow(clippy::useless_conversion)]
                                                         format!("{ev_error}").into()
--
+                                                    )
                                                 )? {
                                                 input = crate::protocol_serde::shape_streaming_operation_with_initial_data::de_streaming_operation_with_initial_data(_initial_event.payload(), input)?;
--
+                                            }
                                                             .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
                                                             .await
                                                             .map_err(
                                                                 |ev_error| ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::RequestRejection::ConstraintViolation(
                                                                     #[allow(clippy::useless_conversion)]
                                                                     format!("{ev_error}").into()
-+
+                                                                )
                                                             )? {
                                                             input = crate::protocol_serde::shape_streaming_operation_with_initial_data::de_streaming_operation_with_initial_data(_initial_event.payload(), input)?;
-+
+                                                        }
             Some(receiver)
         } {
             input = input.set_events(value)
-41
+        }
         input.build()?
     })
-44
+}
-45
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_streaming_operation_with_initial_data_http_response(

↧ Expand context

     #[allow(unused_variables)] output: crate::output::StreamingOperationWithInitialDataOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/vnd.amazon.eventstream",
         );
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::HeaderName::from_static("smithy-protocol"),
             "rpc-v2-cbor",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);

tmp-codegen-diff/codegen-server-test/rpcv2Cbor_extras/rust-server-codegen/src/protocol_serde/shape_streaming_operation_with_initial_response.rs

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

↥ Expand context

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_streaming_operation_with_initial_response_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::StreamingOperationWithInitialResponseInput,
     ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::RequestRejection,
-8
+>
 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::rpc_v2_cbor::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,

-15
+{
     Ok({
         #[allow(unused_mut)]
         let mut input =
             crate::input::streaming_operation_with_initial_response_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) = {
             let mut receiver = crate::protocol_serde::shape_streaming_operation_with_initial_response_input::de_events_payload(&mut body.into().into_inner())?;
             if let Some(_initial_event) = receiver
                                                 .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
                                                 .await
                                                 .map_err(
                                                     |ev_error| ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::RequestRejection::ConstraintViolation(
                                                         #[allow(clippy::useless_conversion)]
                                                         format!("{ev_error}").into()
--
+                                                    )
                                                 )? {
--
--
+                                            }
             let receiver = crate::protocol_serde::shape_streaming_operation_with_initial_response_input::de_events_payload(&mut body.into().into_inner())?;
-+
             Some(receiver)
         } {
             input = input.set_events(value)
-30
+        }
         input.build()?
     })
-33
+}
-34
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_streaming_operation_with_initial_response_http_response(

↧ Expand context

     #[allow(unused_variables)] output: crate::output::StreamingOperationWithInitialResponseOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/vnd.amazon.eventstream",
         );
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::HeaderName::from_static("smithy-protocol"),
             "rpc-v2-cbor",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);

tmp-codegen-diff/codegen-server-test/rpcv2Cbor_extras/rust-server-codegen/src/protocol_serde/shape_streaming_operation_with_optional_data.rs

@@ -1,1 +66,67 @@

↥ Expand context

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_streaming_operation_with_optional_data_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::StreamingOperationWithOptionalDataInput,
     ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::RequestRejection,
-8
+>
 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::rpc_v2_cbor::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,

-15
+{
     Ok({
         #[allow(unused_mut)]
         let mut input =
             crate::input::streaming_operation_with_optional_data_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) = {
             let mut receiver = crate::protocol_serde::shape_streaming_operation_with_optional_data_input::de_events_payload(&mut body.into().into_inner())?;
             let receiver = crate::protocol_serde::shape_streaming_operation_with_optional_data_input::de_events_payload(&mut body.into().into_inner())?;
             let mut receiver = receiver;
             if let Some(_initial_event) = receiver
                                                 .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
                                                 .await
                                                 .map_err(
                                                     |ev_error| ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::RequestRejection::ConstraintViolation(
                                                         #[allow(clippy::useless_conversion)]
                                                         format!("{ev_error}").into()
--
+                                                    )
                                                 )? {
                                                 input = crate::protocol_serde::shape_streaming_operation_with_optional_data::de_streaming_operation_with_optional_data(_initial_event.payload(), input)?;
--
+                                            }
                                                             .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
                                                             .await
                                                             .map_err(
                                                                 |ev_error| ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::RequestRejection::ConstraintViolation(
                                                                     #[allow(clippy::useless_conversion)]
                                                                     format!("{ev_error}").into()
-+
+                                                                )
                                                             )? {
                                                             input = crate::protocol_serde::shape_streaming_operation_with_optional_data::de_streaming_operation_with_optional_data(_initial_event.payload(), input)?;
-+
+                                                        }
             Some(receiver)
         } {
             input = input.set_events(value)
-41
+        }
         input.build()?
     })
-44
+}
-45
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_streaming_operation_with_optional_data_http_response(

↧ Expand context

     #[allow(unused_variables)] output: crate::output::StreamingOperationWithOptionalDataOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/vnd.amazon.eventstream",
         );
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::HeaderName::from_static("smithy-protocol"),
             "rpc-v2-cbor",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);

tmp-codegen-diff/codegen-server-test/rpcv2Cbor_extras_no_initial_response/rust-server-codegen/src/protocol_serde/shape_streaming_operation.rs

@@ -1,1 +68,58 @@

↥ Expand context

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_streaming_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::StreamingOperationInput,
     ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::RequestRejection,
-8
+>
 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::rpc_v2_cbor::rejection::RequestRejection:

         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-15
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::streaming_operation_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) = {
             let mut receiver =
             let receiver =
                 crate::protocol_serde::shape_streaming_operation_input::de_events_payload(
                     &mut body.into().into_inner(),
                 )?;
             if let Some(_initial_event) = receiver
                                                 .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
                                                 .await
                                                 .map_err(
                                                     |ev_error| ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::RequestRejection::ConstraintViolation(
                                                         #[allow(clippy::useless_conversion)]
                                                         format!("{ev_error}").into()
--
+                                                    )
                                                 )? {
--
--
+                                            }
-+
             Some(receiver)
         } {
             input = input.set_events(value)
-32
+        }
         input.build()?
     })
-35
+}
-36
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_streaming_operation_http_response(

↧ Expand context

     #[allow(unused_variables)] output: crate::output::StreamingOperationOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/vnd.amazon.eventstream",
         );
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::HeaderName::from_static("smithy-protocol"),
             "rpc-v2-cbor",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);

tmp-codegen-diff/codegen-server-test/rpcv2Cbor_extras_no_initial_response/rust-server-codegen/src/protocol_serde/shape_streaming_operation_with_initial_data.rs

@@ -1,1 +66,67 @@

↥ Expand context

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_streaming_operation_with_initial_data_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::StreamingOperationWithInitialDataInput,
     ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::RequestRejection,
-8
+>
 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::rpc_v2_cbor::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,

-15
+{
     Ok({
         #[allow(unused_mut)]
         let mut input =
             crate::input::streaming_operation_with_initial_data_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) = {
             let mut receiver = crate::protocol_serde::shape_streaming_operation_with_initial_data_input::de_events_payload(&mut body.into().into_inner())?;
             let receiver = crate::protocol_serde::shape_streaming_operation_with_initial_data_input::de_events_payload(&mut body.into().into_inner())?;
             let mut receiver = receiver;
             if let Some(_initial_event) = receiver
                                                 .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
                                                 .await
                                                 .map_err(
                                                     |ev_error| ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::RequestRejection::ConstraintViolation(
                                                         #[allow(clippy::useless_conversion)]
                                                         format!("{ev_error}").into()
--
+                                                    )
                                                 )? {
                                                 input = crate::protocol_serde::shape_streaming_operation_with_initial_data::de_streaming_operation_with_initial_data(_initial_event.payload(), input)?;
--
+                                            }
                                                             .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
                                                             .await
                                                             .map_err(
                                                                 |ev_error| ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::RequestRejection::ConstraintViolation(
                                                                     #[allow(clippy::useless_conversion)]
                                                                     format!("{ev_error}").into()
-+
+                                                                )
                                                             )? {
                                                             input = crate::protocol_serde::shape_streaming_operation_with_initial_data::de_streaming_operation_with_initial_data(_initial_event.payload(), input)?;
-+
+                                                        }
             Some(receiver)
         } {
             input = input.set_events(value)
-41
+        }
         input.build()?
     })
-44
+}
-45
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_streaming_operation_with_initial_data_http_response(

↧ Expand context

     #[allow(unused_variables)] output: crate::output::StreamingOperationWithInitialDataOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/vnd.amazon.eventstream",
         );
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::HeaderName::from_static("smithy-protocol"),
             "rpc-v2-cbor",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);

tmp-codegen-diff/codegen-server-test/rpcv2Cbor_extras_no_initial_response/rust-server-codegen/src/protocol_serde/shape_streaming_operation_with_initial_response.rs

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

↥ Expand context

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_streaming_operation_with_initial_response_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::StreamingOperationWithInitialResponseInput,
     ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::RequestRejection,
-8
+>
 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::rpc_v2_cbor::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,

-15
+{
     Ok({
         #[allow(unused_mut)]
         let mut input =
             crate::input::streaming_operation_with_initial_response_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) = {
             let mut receiver = crate::protocol_serde::shape_streaming_operation_with_initial_response_input::de_events_payload(&mut body.into().into_inner())?;
             if let Some(_initial_event) = receiver
                                                 .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
                                                 .await
                                                 .map_err(
                                                     |ev_error| ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::RequestRejection::ConstraintViolation(
                                                         #[allow(clippy::useless_conversion)]
                                                         format!("{ev_error}").into()
--
+                                                    )
                                                 )? {
--
--
+                                            }
             let receiver = crate::protocol_serde::shape_streaming_operation_with_initial_response_input::de_events_payload(&mut body.into().into_inner())?;
-+
             Some(receiver)
         } {
             input = input.set_events(value)
-30
+        }
         input.build()?
     })
-33
+}
-34
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_streaming_operation_with_initial_response_http_response(

↧ Expand context

     #[allow(unused_variables)] output: crate::output::StreamingOperationWithInitialResponseOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/vnd.amazon.eventstream",
         );
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::HeaderName::from_static("smithy-protocol"),
             "rpc-v2-cbor",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);

tmp-codegen-diff/codegen-server-test/rpcv2Cbor_extras_no_initial_response/rust-server-codegen/src/protocol_serde/shape_streaming_operation_with_optional_data.rs

@@ -1,1 +66,67 @@

↥ Expand context

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_streaming_operation_with_optional_data_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::StreamingOperationWithOptionalDataInput,
     ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::RequestRejection,
-8
+>
 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::rpc_v2_cbor::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,

-15
+{
     Ok({
         #[allow(unused_mut)]
         let mut input =
             crate::input::streaming_operation_with_optional_data_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) = {
             let mut receiver = crate::protocol_serde::shape_streaming_operation_with_optional_data_input::de_events_payload(&mut body.into().into_inner())?;
             let receiver = crate::protocol_serde::shape_streaming_operation_with_optional_data_input::de_events_payload(&mut body.into().into_inner())?;
             let mut receiver = receiver;
             if let Some(_initial_event) = receiver
                                                 .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
                                                 .await
                                                 .map_err(
                                                     |ev_error| ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::RequestRejection::ConstraintViolation(
                                                         #[allow(clippy::useless_conversion)]
                                                         format!("{ev_error}").into()
--
+                                                    )
                                                 )? {
                                                 input = crate::protocol_serde::shape_streaming_operation_with_optional_data::de_streaming_operation_with_optional_data(_initial_event.payload(), input)?;
--
+                                            }
                                                             .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
                                                             .await
                                                             .map_err(
                                                                 |ev_error| ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::RequestRejection::ConstraintViolation(
                                                                     #[allow(clippy::useless_conversion)]
                                                                     format!("{ev_error}").into()
-+
+                                                                )
                                                             )? {
                                                             input = crate::protocol_serde::shape_streaming_operation_with_optional_data::de_streaming_operation_with_optional_data(_initial_event.payload(), input)?;
-+
+                                                        }
             Some(receiver)
         } {
             input = input.set_events(value)
-41
+        }
         input.build()?
     })
-44
+}
-45
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_streaming_operation_with_optional_data_http_response(

↧ Expand context

     #[allow(unused_variables)] output: crate::output::StreamingOperationWithOptionalDataOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rpc_v2_cbor::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/vnd.amazon.eventstream",
         );
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::HeaderName::from_static("smithy-protocol"),
             "rpc-v2-cbor",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);

Server Test

Files changed: