Client Test

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/empty_input_output.rs

@@ -1,1 +40,49 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* OperationGenerator.kt:77 */
 /// Orchestration and serialization glue logic for `EmptyInputOutput`.
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* OperationGenerator.kt:84 */
 pub struct EmptyInputOutput;
 /* OperationGenerator.kt:85 */
 impl EmptyInputOutput {
     /// Creates a new `EmptyInputOutput`
     /// /* OperationGenerator.kt:86 */Creates a new `EmptyInputOutput`
     /* OperationGenerator.kt:87 */
     pub fn new() -> Self {
         /* OperationGenerator.kt:88 */
         Self
         /* OperationGenerator.kt:87 */
-18
+    }
     /* OperationGenerator.kt:138 */
     pub(crate) async fn orchestrate(
         runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         input: crate::operation::empty_input_output::EmptyInputOutputInput,
     ) -> ::std::result::Result<
         crate::operation::empty_input_output::EmptyInputOutputOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::empty_input_output::EmptyInputOutputError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {

↧ Expand context

         let map_err = |err: ::aws_smithy_runtime_api::client::result::SdkError<
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >| {
             err.map_service_error(|err| {
                 err.downcast::<crate::operation::empty_input_output::EmptyInputOutputError>()
                     .expect("correct error type")
             })
         };
         let context = Self::orchestrate_with_stop_point(runtime_plugins, input, ::aws_smithy_runtime::client::orchestrator::StopPoint::None)
             .await
             .map_err(map_err)?;
         let output = context.finalize().map_err(map_err)?;
         ::std::result::Result::Ok(
             output
                 .downcast::<crate::operation::empty_input_output::EmptyInputOutputOutput>()
                 .expect("correct output type"),
-47
+        )
-48
+    }
-49

@@ -57,66 +267,284 @@

↥ Expand context

             .instrument(::tracing::debug_span!(
                 "RpcV2Protocol.EmptyInputOutput",
                 "rpc.service" = "RpcV2Protocol",
                 "rpc.method" = "EmptyInputOutput",
                 "sdk_invocation_id" = ::fastrand::u32(1_000_000..10_000_000),
             ))
             .await
-73
+    }
-74
     pub(crate) fn operation_runtime_plugins(
         client_runtime_plugins: ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         client_config: &crate::config::Config,
         config_override: ::std::option::Option<crate::config::Builder>,
     ) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
         let mut runtime_plugins = client_runtime_plugins.with_operation_plugin(Self::new());
         runtime_plugins = runtime_plugins.with_client_plugin(crate::auth_plugin::DefaultAuthOptionsPlugin::new(vec![
             ::aws_smithy_runtime::client::auth::no_auth::NO_AUTH_SCHEME_ID,
         ]));
         if let ::std::option::Option::Some(config_override) = config_override {
             for plugin in config_override.runtime_plugins.iter().cloned() {

                 runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
-87
+            }
             runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
                 config_override,
                 client_config.config.clone(),
                 &client_config.runtime_components,
             ));
-93
+        }
         runtime_plugins
-95
+    }
     /* OperationGenerator.kt:85 */
-97
+}
 /* OperationRuntimePluginGenerator.kt:55 */
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for EmptyInputOutput {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         let mut cfg = ::aws_smithy_types::config_bag::Layer::new("EmptyInputOutput");
-102
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
             EmptyInputOutputRequestSerializer,
         ));
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
             EmptyInputOutputResponseDeserializer,
         ));
-109
         cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
             ::aws_smithy_runtime_api::client::auth::static_resolver::StaticAuthSchemeOptionResolverParams::new(),
         ));
-113
         cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
             "EmptyInputOutput",
             "RpcV2Protocol",
         ));
-118
         ::std::option::Option::Some(cfg.freeze())
-120
+    }
-121
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         #[allow(unused_mut)]
         let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("EmptyInputOutput")
             .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
             .with_interceptor(EmptyInputOutputEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::empty_input_output::EmptyInputOutputError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::empty_input_output::EmptyInputOutputError,
             >::new());
-136
         ::std::borrow::Cow::Owned(rcb)
-138
+    }
-139
+}
-140
 /* ResponseDeserializerGenerator.kt:64 */
 #[derive(Debug)]
 struct EmptyInputOutputResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for EmptyInputOutputResponseDeserializer {
     fn deserialize_nonstreaming(
         &self,
         response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
     ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
         let (success, status) = (response.status().is_success(), response.status().as_u16());
         let headers = response.headers();
         let body = response.body().bytes().expect("body loaded");
         #[allow(unused_mut)]
         let mut force_error = false;
-154
         let parse_result = if !success && status != 200 || force_error {
             crate::protocol_serde::shape_empty_input_output::de_empty_input_output_http_error(status, headers, body)
         } else {
             crate::protocol_serde::shape_empty_input_output::de_empty_input_output_http_response(status, headers, body)
         };
         crate::protocol_serde::type_erase_result(parse_result)
-161
+    }
-162
+}
 /* RequestSerializerGenerator.kt:67 */
 #[derive(Debug)]
 struct EmptyInputOutputRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for EmptyInputOutputRequestSerializer {
     #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
     fn serialize_input(
         &self,
         input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
         _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
         let input = input
             .downcast::<crate::operation::empty_input_output::EmptyInputOutputInput>()
             .expect("correct type");
         let _header_serialization_settings = _cfg
             .load::<crate::serialization_settings::HeaderSerializationSettings>()
             .cloned()
             .unwrap_or_default();
         let mut request_builder = {
             fn uri_base(
                 _input: &crate::operation::empty_input_output::EmptyInputOutputInput,
                 output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 use ::std::fmt::Write as _;
                 ::std::write!(output, "/service/RpcV2Protocol/operation/EmptyInputOutput").expect("formatting should succeed");
                 ::std::result::Result::Ok(())
-188
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::empty_input_output::EmptyInputOutputInput,
                 builder: ::http::request::Builder,
             ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
                 let mut uri = ::std::string::String::new();
                 uri_base(input, &mut uri)?;
                 ::std::result::Result::Ok(builder.method("POST").uri(uri))
-197
+            }
             let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
             builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/cbor");
             builder =
                 _header_serialization_settings.set_default_header(builder, ::http::header::HeaderName::from_static("smithy-protocol"), "rpc-v2-cbor");
             builder =
                 _header_serialization_settings.set_default_header(builder, ::http::header::HeaderName::from_static("accept"), "application/cbor");
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_empty_input_output::ser_empty_input_output_input(&input)?);
         if let Some(content_length) = body.content_length() {
             let content_length = content_length.to_string();
             request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
-210
+        }
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
-212
+    }
-213
+}
 /* EndpointParamsInterceptorGenerator.kt:86 */
 #[derive(Debug)]
 struct EmptyInputOutputEndpointParamsInterceptor;
-217
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for EmptyInputOutputEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "EmptyInputOutputEndpointParamsInterceptor"
-221
+    }
-222
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<EmptyInputOutputInput>()
             .ok_or("failed to downcast to EmptyInputOutputInput")?;
-237
         let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
             ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
         })?;
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
         ::std::result::Result::Ok(())
-244
+    }
-245
+}
-246
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-249
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod empty_input_output_test {
-256
     /// When Input structure is empty we write CBOR equivalent of {}
     /// Test ID: empty_input
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn empty_input_request() {
         let (http_client, request_receiver) = ::aws_smithy_http_client::test_util::capture_request(None);
         let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");
-264

↧ Expand context

         let client = crate::Client::from_conf(config_builder.http_client(http_client).build());
         let result = client.empty_input_output().send().await;
         let _ = dbg!(result);
         let http_request = request_receiver.expect_request();
         let expected_headers = [
             ("Accept", "application/cbor"),
             ("Content-Type", "application/cbor"),
             ("smithy-protocol", "rpc-v2-cbor"),
         ];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(http_request.headers(), expected_headers));
         let forbidden_headers = &["X-Amz-Target"];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::forbid_headers(http_request.headers(), forbidden_headers));
         let required_headers = &["Content-Length"];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::require_headers(http_request.headers(), required_headers));
         let body = http_request.body().bytes().expect("body should be strict");
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_body(
             body,
             "v/8=",
             ::aws_smithy_protocol_test::MediaType::from("application/cbor"),
         ));

@@ -322,339 +451,527 @@

↥ Expand context

                 .header("smithy-protocol", "rpc-v2-cbor")
                 .status(200)
                 .body(::aws_smithy_types::body::SdkBody::from(""))
                 .unwrap(),
-343
+        )
         .unwrap();
         use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
         use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;
-347
         let op = crate::operation::empty_input_output::EmptyInputOutput::new();
         let config = op.config().expect("the operation has config");
         let de = config
             .load::<::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer>()
             .expect("the config must have a deserializer");
-353
         let parsed = de.deserialize_streaming(&mut http_response);
         let parsed = parsed.unwrap_or_else(|| {
             let http_response = http_response.map(|body| {
                 ::aws_smithy_types::body::SdkBody::from(::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                     body.bytes().unwrap(),

                     ::aws_smithy_protocol_test::MediaType::from("application/cbor"),
                 )))
             });
             de.deserialize_nonstreaming(&http_response)
         });
         let parsed = parsed
             .expect("should be successful response")
             .downcast::<crate::operation::empty_input_output::EmptyInputOutputOutput>()
             .unwrap();
-368
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-371
+}
-372
 /* OperationErrorGenerator.kt:79 */
 /// Error type for the `EmptyInputOutputError` operation.
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::fmt::Debug)]
 pub enum EmptyInputOutputError {
 pub /* OperationErrorGenerator.kt:81 */ enum EmptyInputOutputError {
     /* OperationErrorGenerator.kt:88 */
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-384
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-386
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-EmptyInputOutputError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
     /* OperationErrorGenerator.kt:81 */
-390
+}
 /* OperationErrorGenerator.kt:218 */
 impl EmptyInputOutputError {
     /* OperationErrorGenerator.kt:219 */
     /// Creates the `EmptyInputOutputError::Unhandled` variant from any error type.
     pub fn unhandled(
         err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
     ) -> Self {
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source: err.into(),
             meta: ::std::default::Default::default(),
         })
-402
+    }
-403
     /// Creates the `EmptyInputOutputError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
     pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source: err.clone().into(),
             meta: err,
         })
-410
+    }
     ///
     /// /* OperationErrorGenerator.kt:236 */
     /// Returns error metadata, which includes the error code, message,
     /// request ID, and potentially additional information.
     ///
     /* OperationErrorGenerator.kt:242 */
     pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         /* OperationErrorGenerator.kt:243 */
         match self {
             Self::Unhandled(e) => &e.meta,
             /* OperationErrorGenerator.kt:251 */ Self::Unhandled(e) => &e.meta,
             /* OperationErrorGenerator.kt:243 */
-421
+        }
         /* OperationErrorGenerator.kt:242 */
-423
+    }
     /* OperationErrorGenerator.kt:218 */
-425
+}
 /* OperationErrorGenerator.kt:269 */
 impl ::std::error::Error for EmptyInputOutputError {
     /* OperationErrorGenerator.kt:270 */
     fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
         /* OperationErrorGenerator.kt:318 */
         match self {
             Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:279 */
                 ::std::option::Option::Some(&*_inner.source)
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-438
+        }
         /* OperationErrorGenerator.kt:270 */
-440
+    }
     /* OperationErrorGenerator.kt:269 */
-442
+}
 /* OperationErrorGenerator.kt:133 */
 impl ::std::fmt::Display for EmptyInputOutputError {
     /* OperationErrorGenerator.kt:134 */
     fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
         /* OperationErrorGenerator.kt:318 */
         match self {
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:139 */
                 if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
                     write!(f, "unhandled error ({code})")
                 } else {
                     f.write_str("unhandled error")
-456
+                }
--
+            }
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-459
+        }
         /* OperationErrorGenerator.kt:134 */
-461
+    }
     /* OperationErrorGenerator.kt:133 */
-463
+}
 /* OperationErrorGenerator.kt:182 */
 impl ::aws_smithy_types::retry::ProvideErrorKind for EmptyInputOutputError {
     /* OperationErrorGenerator.kt:186 */
     fn code(&self) -> ::std::option::Option<&str> {
         /* OperationErrorGenerator.kt:187 */
         ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
         /* OperationErrorGenerator.kt:186 */
-471
+    }
     /* OperationErrorGenerator.kt:190 */
     fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
         /* OperationErrorGenerator.kt:197 */
         ::std::option::Option::None
         /* OperationErrorGenerator.kt:190 */
-477
+    }
     /* OperationErrorGenerator.kt:182 */
-479
+}
 /* OperationErrorGenerator.kt:163 */
 impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for EmptyInputOutputError {
     /* OperationErrorGenerator.kt:164 */
     fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         /* OperationErrorGenerator.kt:318 */
         match self {
             Self::Unhandled(_inner) => &_inner.meta,
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:168 */
                 &_inner.meta
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-492
+        }
         /* OperationErrorGenerator.kt:164 */
-494
+    }
     /* OperationErrorGenerator.kt:163 */
-496
+}
 /* OperationErrorGenerator.kt:109 */
 impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for EmptyInputOutputError {
     /* OperationErrorGenerator.kt:110 */
     fn create_unhandled_error(
         source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
         meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
     ) -> Self {
         /* OperationErrorGenerator.kt:121 */
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source,
             meta: meta.unwrap_or_default(),
         })
         /* OperationErrorGenerator.kt:110 */
-510
+    }
     /* OperationErrorGenerator.kt:109 */
-512
+}
-513
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::empty_input_output::_empty_input_output_output::EmptyInputOutputOutput;
-516
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::empty_input_output::_empty_input_output_input::EmptyInputOutputInput;
-519
 /* RustModule.kt:172 */
 mod _empty_input_output_input;
-522
 /* RustModule.kt:172 */
 mod _empty_input_output_output;
-525
 /// Builders
 /// /* CodegenDelegator.kt:51 */Builders
 pub mod builders;

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/empty_input_output/_empty_input_output_input.rs

@@ -1,1 +24,44 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct EmptyInputOutputInput {}
 pub /* StructureGenerator.kt:201 */ struct EmptyInputOutputInput {/* StructureGenerator.kt:201 */}
 /* ClientCodegenVisitor.kt:237 */
 impl EmptyInputOutputInput {
     /// Creates a new builder-style object to manufacture [`EmptyInputOutputInput`](crate::operation::empty_input_output::EmptyInputOutputInput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`EmptyInputOutputInput`](crate::operation::empty_input_output::EmptyInputOutputInput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::empty_input_output::builders::EmptyInputOutputInputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::empty_input_output::builders::EmptyInputOutputInputBuilder::default()
         /* BuilderGenerator.kt:175 */
-17
+    }
     /* ClientCodegenVisitor.kt:237 */
-19
+}
-20
 /// A builder for [`EmptyInputOutputInput`](crate::operation::empty_input_output::EmptyInputOutputInput).
 /// /* BuilderGenerator.kt:342 */A builder for [`EmptyInputOutputInput`](crate::operation::empty_input_output::EmptyInputOutputInput).
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 pub struct EmptyInputOutputInputBuilder {}
 /* BuilderGenerator.kt:345 */
 pub struct EmptyInputOutputInputBuilder {/* BuilderGenerator.kt:345 */}
 /* BuilderGenerator.kt:355 */
 impl EmptyInputOutputInputBuilder {
     /// Consumes the builder and constructs a [`EmptyInputOutputInput`](crate::operation::empty_input_output::EmptyInputOutputInput).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`EmptyInputOutputInput`](crate::operation::empty_input_output::EmptyInputOutputInput).
     /* BuilderGenerator.kt:253 */
     pub fn build(
         self,
     ) -> ::std::result::Result<crate::operation::empty_input_output::EmptyInputOutputInput, ::aws_smithy_types::error::operation::BuildError> {
         ::std::result::Result::Ok(crate::operation::empty_input_output::EmptyInputOutputInput {})
         /* BuilderGenerator.kt:254 */
         ::std::result::Result::Ok(
             /* BuilderGenerator.kt:477 */
             crate::operation::empty_input_output::EmptyInputOutputInput {
             /* BuilderGenerator.kt:477 */}, /* BuilderGenerator.kt:254 */
-+
+        )
         /* BuilderGenerator.kt:253 */
-42
+    }
     /* BuilderGenerator.kt:355 */
-44
+}

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/empty_input_output/_empty_input_output_output.rs

@@ -1,1 +22,39 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct EmptyInputOutputOutput {}
 pub /* StructureGenerator.kt:201 */ struct EmptyInputOutputOutput {/* StructureGenerator.kt:201 */}
 /* ClientCodegenVisitor.kt:237 */
 impl EmptyInputOutputOutput {
     /// Creates a new builder-style object to manufacture [`EmptyInputOutputOutput`](crate::operation::empty_input_output::EmptyInputOutputOutput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`EmptyInputOutputOutput`](crate::operation::empty_input_output::EmptyInputOutputOutput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::empty_input_output::builders::EmptyInputOutputOutputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::empty_input_output::builders::EmptyInputOutputOutputBuilder::default()
         /* BuilderGenerator.kt:175 */
-17
+    }
     /* ClientCodegenVisitor.kt:237 */
-19
+}
-20
 /// A builder for [`EmptyInputOutputOutput`](crate::operation::empty_input_output::EmptyInputOutputOutput).
 /// /* BuilderGenerator.kt:342 */A builder for [`EmptyInputOutputOutput`](crate::operation::empty_input_output::EmptyInputOutputOutput).
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 pub struct EmptyInputOutputOutputBuilder {}
 /* BuilderGenerator.kt:345 */
 pub struct EmptyInputOutputOutputBuilder {/* BuilderGenerator.kt:345 */}
 /* BuilderGenerator.kt:355 */
 impl EmptyInputOutputOutputBuilder {
     /// Consumes the builder and constructs a [`EmptyInputOutputOutput`](crate::operation::empty_input_output::EmptyInputOutputOutput).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`EmptyInputOutputOutput`](crate::operation::empty_input_output::EmptyInputOutputOutput).
     /* BuilderGenerator.kt:253 */
     pub fn build(self) -> crate::operation::empty_input_output::EmptyInputOutputOutput {
         crate::operation::empty_input_output::EmptyInputOutputOutput {}
         /* BuilderGenerator.kt:477 */
         crate::operation::empty_input_output::EmptyInputOutputOutput {
         /* BuilderGenerator.kt:477 */}
         /* BuilderGenerator.kt:253 */
-37
+    }
     /* BuilderGenerator.kt:355 */
-39
+}

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/empty_input_output/builders.rs

@@ -1,1 +110,122 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::empty_input_output::_empty_input_output_output::EmptyInputOutputOutputBuilder;
-4
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::empty_input_output::_empty_input_output_input::EmptyInputOutputInputBuilder;
-7
 /* FluentBuilderGenerator.kt:408 */
 impl crate::operation::empty_input_output::builders::EmptyInputOutputInputBuilder {
     /// Sends a request with this input using the given client.
     pub async fn send_with(
         self,
         client: &crate::Client,
     ) -> ::std::result::Result<
         crate::operation::empty_input_output::EmptyInputOutputOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::empty_input_output::EmptyInputOutputError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {
         let mut fluent_builder = client.empty_input_output();
         fluent_builder.inner = self;
         fluent_builder.send().await
-24
+    }
-25
+}
 /// Fluent builder constructing a request to `EmptyInputOutput`.
 /// /* FluentBuilderGenerator.kt:129 */Fluent builder constructing a request to `EmptyInputOutput`.
 ///
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::fmt::Debug)]
 /* FluentBuilderGenerator.kt:270 */
 pub struct EmptyInputOutputFluentBuilder {
     handle: ::std::sync::Arc<crate::client::Handle>,
     inner: crate::operation::empty_input_output::builders::EmptyInputOutputInputBuilder,
     config_override: ::std::option::Option<crate::config::Builder>,
-35
+}
 /* FluentBuilderGenerator.kt:381 */
 impl
     crate::client::customize::internal::CustomizableSend<
         crate::operation::empty_input_output::EmptyInputOutputOutput,
         crate::operation::empty_input_output::EmptyInputOutputError,
     > for EmptyInputOutputFluentBuilder
-42
+{
     fn send(
         self,
         config_override: crate::config::Builder,
     ) -> crate::client::customize::internal::BoxFuture<
         crate::client::customize::internal::SendResult<
             crate::operation::empty_input_output::EmptyInputOutputOutput,
             crate::operation::empty_input_output::EmptyInputOutputError,
         >,
     > {
         ::std::boxed::Box::pin(async move { self.config_override(config_override).send().await })
-53
+    }
-54
+}
 /* FluentBuilderGenerator.kt:282 */
 impl EmptyInputOutputFluentBuilder {
     /* FluentBuilderGenerator.kt:288 */
     /// Creates a new `EmptyInputOutputFluentBuilder`.
     pub(crate) fn new(handle: ::std::sync::Arc<crate::client::Handle>) -> Self {
         Self {
             handle,
             inner: ::std::default::Default::default(),
             config_override: ::std::option::Option::None,
-64
+        }
-65
+    }
     /* FluentBuilderGenerator.kt:301 */
     /// Access the EmptyInputOutput as a reference.
     pub fn as_input(&self) -> &crate::operation::empty_input_output::builders::EmptyInputOutputInputBuilder {
         &self.inner
-70
+    }
     /* FluentBuilderGenerator.kt:145 */
     /// Sends the request and returns the response.
     ///
     /// If an error occurs, an `SdkError` will be returned with additional details that
     /// can be matched against.
     ///
     /// By default, any retryable failures will be retried twice. Retry behavior
     /// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
     /// set when configuring the client.
     pub async fn send(
         self,
     ) -> ::std::result::Result<
         crate::operation::empty_input_output::EmptyInputOutputOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::empty_input_output::EmptyInputOutputError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {
         let input = self
             .inner
             .build()
             .map_err(::aws_smithy_runtime_api::client::result::SdkError::construction_failure)?;
         let runtime_plugins = crate::operation::empty_input_output::EmptyInputOutput::operation_runtime_plugins(
             self.handle.runtime_plugins.clone(),
             &self.handle.conf,
             self.config_override,
         );
         crate::operation::empty_input_output::EmptyInputOutput::orchestrate(&runtime_plugins, input).await
-99
+    }
-100
     /// Consumes this builder, creating a customizable operation that can be modified before being sent.
     pub fn customize(
         self,
     ) -> crate::client::customize::CustomizableOperation<
         crate::operation::empty_input_output::EmptyInputOutputOutput,
         crate::operation::empty_input_output::EmptyInputOutputError,
         Self,
     > {
         crate::client::customize::CustomizableOperation::new(self)
-110
+    }
     /* FluentBuilderGenerator.kt:315 */
     pub(crate) fn config_override(mut self, config_override: impl ::std::convert::Into<crate::config::Builder>) -> Self {
         self.set_config_override(::std::option::Option::Some(config_override.into()));
         self
-115
+    }
-116
     pub(crate) fn set_config_override(&mut self, config_override: ::std::option::Option<crate::config::Builder>) -> &mut Self {
         self.config_override = config_override;
         self
-120
+    }
     /* FluentBuilderGenerator.kt:282 */
-122
+}

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/float16.rs

@@ -1,1 +40,49 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* OperationGenerator.kt:77 */
 /// Orchestration and serialization glue logic for `Float16`.
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* OperationGenerator.kt:84 */
 pub struct Float16;
 /* OperationGenerator.kt:85 */
 impl Float16 {
     /// Creates a new `Float16`
     /// /* OperationGenerator.kt:86 */Creates a new `Float16`
     /* OperationGenerator.kt:87 */
     pub fn new() -> Self {
         /* OperationGenerator.kt:88 */
         Self
         /* OperationGenerator.kt:87 */
-18
+    }
     /* OperationGenerator.kt:138 */
     pub(crate) async fn orchestrate(
         runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         input: crate::operation::float16::Float16Input,
     ) -> ::std::result::Result<
         crate::operation::float16::Float16Output,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::float16::Float16Error,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {

↧ Expand context

         let map_err =
             |err: ::aws_smithy_runtime_api::client::result::SdkError<
                 ::aws_smithy_runtime_api::client::interceptors::context::Error,
                 ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
             >| { err.map_service_error(|err| err.downcast::<crate::operation::float16::Float16Error>().expect("correct error type")) };
         let context = Self::orchestrate_with_stop_point(runtime_plugins, input, ::aws_smithy_runtime::client::orchestrator::StopPoint::None)
             .await
             .map_err(map_err)?;
         let output = context.finalize().map_err(map_err)?;
         ::std::result::Result::Ok(
             output
                 .downcast::<crate::operation::float16::Float16Output>()
                 .expect("correct output type"),
-43
+        )
-44
+    }
-45
     pub(crate) async fn orchestrate_with_stop_point(
         runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         input: crate::operation::float16::Float16Input,
         stop_point: ::aws_smithy_runtime::client::orchestrator::StopPoint,

@@ -53,62 +257,274 @@

↥ Expand context

             .instrument(::tracing::debug_span!(
                 "RpcV2Protocol.Float16",
                 "rpc.service" = "RpcV2Protocol",
                 "rpc.method" = "Float16",
                 "sdk_invocation_id" = ::fastrand::u32(1_000_000..10_000_000),
             ))
             .await
-69
+    }
-70
     pub(crate) fn operation_runtime_plugins(
         client_runtime_plugins: ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         client_config: &crate::config::Config,
         config_override: ::std::option::Option<crate::config::Builder>,
     ) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
         let mut runtime_plugins = client_runtime_plugins.with_operation_plugin(Self::new());
         runtime_plugins = runtime_plugins.with_client_plugin(crate::auth_plugin::DefaultAuthOptionsPlugin::new(vec![
             ::aws_smithy_runtime::client::auth::no_auth::NO_AUTH_SCHEME_ID,
         ]));
         if let ::std::option::Option::Some(config_override) = config_override {
             for plugin in config_override.runtime_plugins.iter().cloned() {

                 runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
-83
+            }
             runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
                 config_override,
                 client_config.config.clone(),
                 &client_config.runtime_components,
             ));
-89
+        }
         runtime_plugins
-91
+    }
     /* OperationGenerator.kt:85 */
-93
+}
 /* OperationRuntimePluginGenerator.kt:55 */
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for Float16 {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         let mut cfg = ::aws_smithy_types::config_bag::Layer::new("Float16");
-98
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
             Float16RequestSerializer,
         ));
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
             Float16ResponseDeserializer,
         ));
-105
         cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
             ::aws_smithy_runtime_api::client::auth::static_resolver::StaticAuthSchemeOptionResolverParams::new(),
         ));
-109
         cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new("Float16", "RpcV2Protocol"));
-111
         ::std::option::Option::Some(cfg.freeze())
-113
+    }
-114
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         #[allow(unused_mut)]
         let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("Float16")
             .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
             .with_interceptor(Float16EndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::float16::Float16Error,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::float16::Float16Error,
             >::new());
-129
         ::std::borrow::Cow::Owned(rcb)
-131
+    }
-132
+}
-133
 /* ResponseDeserializerGenerator.kt:64 */
 #[derive(Debug)]
 struct Float16ResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for Float16ResponseDeserializer {
     fn deserialize_nonstreaming(
         &self,
         response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
     ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
         let (success, status) = (response.status().is_success(), response.status().as_u16());
         let headers = response.headers();
         let body = response.body().bytes().expect("body loaded");
         #[allow(unused_mut)]
         let mut force_error = false;
-147
         let parse_result = if !success && status != 200 || force_error {
             crate::protocol_serde::shape_float16::de_float16_http_error(status, headers, body)
         } else {
             crate::protocol_serde::shape_float16::de_float16_http_response(status, headers, body)
         };
         crate::protocol_serde::type_erase_result(parse_result)
-154
+    }
-155
+}
 /* RequestSerializerGenerator.kt:67 */
 #[derive(Debug)]
 struct Float16RequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for Float16RequestSerializer {
     #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
     fn serialize_input(
         &self,
         input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
         _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
         let input = input.downcast::<crate::operation::float16::Float16Input>().expect("correct type");
         let _header_serialization_settings = _cfg
             .load::<crate::serialization_settings::HeaderSerializationSettings>()
             .cloned()
             .unwrap_or_default();
         let mut request_builder = {
             fn uri_base(
                 _input: &crate::operation::float16::Float16Input,
                 output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 use ::std::fmt::Write as _;
                 ::std::write!(output, "/service/RpcV2Protocol/operation/Float16").expect("formatting should succeed");
                 ::std::result::Result::Ok(())
-179
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::float16::Float16Input,
                 builder: ::http::request::Builder,
             ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
                 let mut uri = ::std::string::String::new();
                 uri_base(input, &mut uri)?;
                 ::std::result::Result::Ok(builder.method("POST").uri(uri))
-188
+            }
             let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
             builder =
                 _header_serialization_settings.set_default_header(builder, ::http::header::HeaderName::from_static("smithy-protocol"), "rpc-v2-cbor");
             builder =
                 _header_serialization_settings.set_default_header(builder, ::http::header::HeaderName::from_static("accept"), "application/cbor");
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from("");
         if let Some(content_length) = body.content_length() {
             let content_length = content_length.to_string();
             request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
-200
+        }
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
-202
+    }
-203
+}
 /* EndpointParamsInterceptorGenerator.kt:86 */
 #[derive(Debug)]
 struct Float16EndpointParamsInterceptor;
-207
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for Float16EndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "Float16EndpointParamsInterceptor"
-211
+    }
-212
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<Float16Input>()
             .ok_or("failed to downcast to Float16Input")?;
-227
         let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
             ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
         })?;
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
         ::std::result::Result::Ok(())
-234
+    }
-235
+}
-236
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-239
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod float16_test {
     use ::aws_smithy_protocol_test::FloatEquals;
-247
     /// Ensures that clients can correctly parse float16 +Inf.
     /// Test ID: RpcV2CborFloat16Inf
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn rpc_v2_cbor_float16_inf_response() {
         let expected_output = crate::operation::float16::Float16Output::builder()
             .set_value(::std::option::Option::Some(

↧ Expand context

                 <f64 as ::aws_smithy_types::primitive::Parse>::parse_smithy_primitive("Infinity").expect("invalid string for number"),
             ))
             .build();
         let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(
             ::http::response::Builder::new()
                 .header("Content-Type", "application/cbor")
                 .header("smithy-protocol", "rpc-v2-cbor")
                 .status(200)
                 .body(::aws_smithy_types::body::SdkBody::from("oWV2YWx1Zfl8AA=="))
                 .unwrap(),
-265
+        )
         .unwrap();
         use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
         use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;
-269
         let op = crate::operation::float16::Float16::new();
         let config = op.config().expect("the operation has config");
         let de = config
             .load::<::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer>()
             .expect("the config must have a deserializer");

@@ -448,465 +577,653 @@

↥ Expand context

         use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
         use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;
-467
         let op = crate::operation::float16::Float16::new();
         let config = op.config().expect("the operation has config");
         let de = config
             .load::<::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer>()
             .expect("the config must have a deserializer");
-473
         let parsed = de.deserialize_streaming(&mut http_response);
         let parsed = parsed.unwrap_or_else(|| {
             let http_response = http_response.map(|body| {
                 ::aws_smithy_types::body::SdkBody::from(::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                     body.bytes().unwrap(),
                     ::aws_smithy_protocol_test::MediaType::from("application/cbor"),
                 )))
             });
             de.deserialize_nonstreaming(&http_response)
         });
         let parsed = parsed

             .expect("should be successful response")
             .downcast::<crate::operation::float16::Float16Output>()
             .unwrap();
         assert!(
             parsed.value.float_equals(&expected_output.value),
             "Unexpected value for `value` {:?} vs. {:?}",
             expected_output.value,
             parsed.value
         );
-494
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-497
+}
-498
 /* OperationErrorGenerator.kt:79 */
 /// Error type for the `Float16Error` operation.
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::fmt::Debug)]
 pub enum Float16Error {
 pub /* OperationErrorGenerator.kt:81 */ enum Float16Error {
     /* OperationErrorGenerator.kt:88 */
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-510
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-512
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-Float16Error) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
     /* OperationErrorGenerator.kt:81 */
-516
+}
 /* OperationErrorGenerator.kt:218 */
 impl Float16Error {
     /* OperationErrorGenerator.kt:219 */
     /// Creates the `Float16Error::Unhandled` variant from any error type.
     pub fn unhandled(
         err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
     ) -> Self {
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source: err.into(),
             meta: ::std::default::Default::default(),
         })
-528
+    }
-529
     /// Creates the `Float16Error::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
     pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source: err.clone().into(),
             meta: err,
         })
-536
+    }
     ///
     /// /* OperationErrorGenerator.kt:236 */
     /// Returns error metadata, which includes the error code, message,
     /// request ID, and potentially additional information.
     ///
     /* OperationErrorGenerator.kt:242 */
     pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         /* OperationErrorGenerator.kt:243 */
         match self {
             Self::Unhandled(e) => &e.meta,
             /* OperationErrorGenerator.kt:251 */ Self::Unhandled(e) => &e.meta,
             /* OperationErrorGenerator.kt:243 */
-547
+        }
         /* OperationErrorGenerator.kt:242 */
-549
+    }
     /* OperationErrorGenerator.kt:218 */
-551
+}
 /* OperationErrorGenerator.kt:269 */
 impl ::std::error::Error for Float16Error {
     /* OperationErrorGenerator.kt:270 */
     fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
         /* OperationErrorGenerator.kt:318 */
         match self {
             Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:279 */
                 ::std::option::Option::Some(&*_inner.source)
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-564
+        }
         /* OperationErrorGenerator.kt:270 */
-566
+    }
     /* OperationErrorGenerator.kt:269 */
-568
+}
 /* OperationErrorGenerator.kt:133 */
 impl ::std::fmt::Display for Float16Error {
     /* OperationErrorGenerator.kt:134 */
     fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
         /* OperationErrorGenerator.kt:318 */
         match self {
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:139 */
                 if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
                     write!(f, "unhandled error ({code})")
                 } else {
                     f.write_str("unhandled error")
-582
+                }
--
+            }
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-585
+        }
         /* OperationErrorGenerator.kt:134 */
-587
+    }
     /* OperationErrorGenerator.kt:133 */
-589
+}
 /* OperationErrorGenerator.kt:182 */
 impl ::aws_smithy_types::retry::ProvideErrorKind for Float16Error {
     /* OperationErrorGenerator.kt:186 */
     fn code(&self) -> ::std::option::Option<&str> {
         /* OperationErrorGenerator.kt:187 */
         ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
         /* OperationErrorGenerator.kt:186 */
-597
+    }
     /* OperationErrorGenerator.kt:190 */
     fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
         /* OperationErrorGenerator.kt:197 */
         ::std::option::Option::None
         /* OperationErrorGenerator.kt:190 */
-603
+    }
     /* OperationErrorGenerator.kt:182 */
-605
+}
 /* OperationErrorGenerator.kt:163 */
 impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for Float16Error {
     /* OperationErrorGenerator.kt:164 */
     fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         /* OperationErrorGenerator.kt:318 */
         match self {
             Self::Unhandled(_inner) => &_inner.meta,
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:168 */
                 &_inner.meta
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-618
+        }
         /* OperationErrorGenerator.kt:164 */
-620
+    }
     /* OperationErrorGenerator.kt:163 */
-622
+}
 /* OperationErrorGenerator.kt:109 */
 impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for Float16Error {
     /* OperationErrorGenerator.kt:110 */
     fn create_unhandled_error(
         source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
         meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
     ) -> Self {
         /* OperationErrorGenerator.kt:121 */
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source,
             meta: meta.unwrap_or_default(),
         })
         /* OperationErrorGenerator.kt:110 */
-636
+    }
     /* OperationErrorGenerator.kt:109 */
-638
+}
-639
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::float16::_float16_output::Float16Output;
-642
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::float16::_float16_input::Float16Input;
-645
 /* RustModule.kt:172 */
 mod _float16_input;
-648
 /* RustModule.kt:172 */
 mod _float16_output;
-651
 /// Builders
 /// /* CodegenDelegator.kt:51 */Builders
 pub mod builders;

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/float16/_float16_input.rs

@@ -1,1 +22,42 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct Float16Input {}
 pub /* StructureGenerator.kt:201 */ struct Float16Input {/* StructureGenerator.kt:201 */}
 /* ClientCodegenVisitor.kt:237 */
 impl Float16Input {
     /// Creates a new builder-style object to manufacture [`Float16Input`](crate::operation::float16::Float16Input).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`Float16Input`](crate::operation::float16::Float16Input).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::float16::builders::Float16InputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::float16::builders::Float16InputBuilder::default()
         /* BuilderGenerator.kt:175 */
-17
+    }
     /* ClientCodegenVisitor.kt:237 */
-19
+}
-20
 /// A builder for [`Float16Input`](crate::operation::float16::Float16Input).
 /// /* BuilderGenerator.kt:342 */A builder for [`Float16Input`](crate::operation::float16::Float16Input).
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 pub struct Float16InputBuilder {}
 /* BuilderGenerator.kt:345 */
 pub struct Float16InputBuilder {/* BuilderGenerator.kt:345 */}
 /* BuilderGenerator.kt:355 */
 impl Float16InputBuilder {
     /// Consumes the builder and constructs a [`Float16Input`](crate::operation::float16::Float16Input).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`Float16Input`](crate::operation::float16::Float16Input).
     /* BuilderGenerator.kt:253 */
     pub fn build(self) -> ::std::result::Result<crate::operation::float16::Float16Input, ::aws_smithy_types::error::operation::BuildError> {
         ::std::result::Result::Ok(crate::operation::float16::Float16Input {})
         /* BuilderGenerator.kt:254 */
         ::std::result::Result::Ok(
             /* BuilderGenerator.kt:477 */
             crate::operation::float16::Float16Input {
             /* BuilderGenerator.kt:477 */}, /* BuilderGenerator.kt:254 */
-+
+        )
         /* BuilderGenerator.kt:253 */
-40
+    }
     /* BuilderGenerator.kt:355 */
-42
+}

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/float16/_float16_output.rs

@@ -1,1 +47,88 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct Float16Output {
 pub /* StructureGenerator.kt:201 */ struct Float16Output {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
     pub value: ::std::option::Option<f64>,
     /* StructureGenerator.kt:201 */
-13
+}
 /* StructureGenerator.kt:135 */
 impl Float16Output {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
                            /* StructureGenerator.kt:166 */
     pub fn value(&self) -> ::std::option::Option<f64> {
         /* StructureGenerator.kt:168 */
         self.value
         /* StructureGenerator.kt:166 */
-23
+    }
     /* StructureGenerator.kt:135 */
-25
+}
 /* ClientCodegenVisitor.kt:237 */
 impl Float16Output {
     /// Creates a new builder-style object to manufacture [`Float16Output`](crate::operation::float16::Float16Output).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`Float16Output`](crate::operation::float16::Float16Output).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::float16::builders::Float16OutputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::float16::builders::Float16OutputBuilder::default()
         /* BuilderGenerator.kt:175 */
-34
+    }
     /* ClientCodegenVisitor.kt:237 */
-36
+}
-37
 /// A builder for [`Float16Output`](crate::operation::float16::Float16Output).
 /// /* BuilderGenerator.kt:342 */A builder for [`Float16Output`](crate::operation::float16::Float16Output).
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* BuilderGenerator.kt:345 */
 pub struct Float16OutputBuilder {
     pub(crate) value: ::std::option::Option<f64>,
     /* BuilderGenerator.kt:275 */ pub(crate) value: ::std::option::Option<f64>,
     /* BuilderGenerator.kt:345 */
-47
+}
 /* BuilderGenerator.kt:355 */
 impl Float16OutputBuilder {
     /* BuilderGenerator.kt:286 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:291 */
     pub fn value(mut self, input: f64) -> Self {
         /* BuilderGenerator.kt:292 */
         self.value = ::std::option::Option::Some(input);
         /* BuilderGenerator.kt:293 */
         self
         /* BuilderGenerator.kt:291 */
-59
+    }
     /* BuilderGenerator.kt:312 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:314 */
     pub fn set_value(mut self, input: ::std::option::Option<f64>) -> Self {
         /* BuilderGenerator.kt:315 */
         self.value = input;
         self
         /* BuilderGenerator.kt:314 */
-68
+    }
     /* BuilderGenerator.kt:334 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:336 */
     pub fn get_value(&self) -> &::std::option::Option<f64> {
         /* BuilderGenerator.kt:337 */
         &self.value
         /* BuilderGenerator.kt:336 */
-76
+    }
     /// Consumes the builder and constructs a [`Float16Output`](crate::operation::float16::Float16Output).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`Float16Output`](crate::operation::float16::Float16Output).
     /* BuilderGenerator.kt:253 */
     pub fn build(self) -> crate::operation::float16::Float16Output {
         crate::operation::float16::Float16Output { value: self.value }
         /* BuilderGenerator.kt:477 */
         crate::operation::float16::Float16Output {
             /* BuilderGenerator.kt:481 */ value: self.value,
             /* BuilderGenerator.kt:477 */
-+
+        }
         /* BuilderGenerator.kt:253 */
-86
+    }
     /* BuilderGenerator.kt:355 */
-88
+}

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/float16/builders.rs

@@ -1,1 +101,113 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::float16::_float16_output::Float16OutputBuilder;
-4
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::float16::_float16_input::Float16InputBuilder;
-7
 /* FluentBuilderGenerator.kt:408 */
 impl crate::operation::float16::builders::Float16InputBuilder {
     /// Sends a request with this input using the given client.
     pub async fn send_with(
         self,
         client: &crate::Client,
     ) -> ::std::result::Result<
         crate::operation::float16::Float16Output,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::float16::Float16Error,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {
         let mut fluent_builder = client.float16();
         fluent_builder.inner = self;
         fluent_builder.send().await
-24
+    }
-25
+}
 /// Fluent builder constructing a request to `Float16`.
 /// /* FluentBuilderGenerator.kt:129 */Fluent builder constructing a request to `Float16`.
 ///
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::fmt::Debug)]
 /* FluentBuilderGenerator.kt:270 */
 pub struct Float16FluentBuilder {
     handle: ::std::sync::Arc<crate::client::Handle>,
     inner: crate::operation::float16::builders::Float16InputBuilder,
     config_override: ::std::option::Option<crate::config::Builder>,
-35
+}
 /* FluentBuilderGenerator.kt:381 */
 impl crate::client::customize::internal::CustomizableSend<crate::operation::float16::Float16Output, crate::operation::float16::Float16Error>
     for Float16FluentBuilder
-39
+{
     fn send(
         self,
         config_override: crate::config::Builder,
     ) -> crate::client::customize::internal::BoxFuture<
         crate::client::customize::internal::SendResult<crate::operation::float16::Float16Output, crate::operation::float16::Float16Error>,
     > {
         ::std::boxed::Box::pin(async move { self.config_override(config_override).send().await })
-47
+    }
-48
+}
 /* FluentBuilderGenerator.kt:282 */
 impl Float16FluentBuilder {
     /* FluentBuilderGenerator.kt:288 */
     /// Creates a new `Float16FluentBuilder`.
     pub(crate) fn new(handle: ::std::sync::Arc<crate::client::Handle>) -> Self {
         Self {
             handle,
             inner: ::std::default::Default::default(),
             config_override: ::std::option::Option::None,
-58
+        }
-59
+    }
     /* FluentBuilderGenerator.kt:301 */
     /// Access the Float16 as a reference.
     pub fn as_input(&self) -> &crate::operation::float16::builders::Float16InputBuilder {
         &self.inner
-64
+    }
     /* FluentBuilderGenerator.kt:145 */
     /// Sends the request and returns the response.
     ///
     /// If an error occurs, an `SdkError` will be returned with additional details that
     /// can be matched against.
     ///
     /// By default, any retryable failures will be retried twice. Retry behavior
     /// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
     /// set when configuring the client.
     pub async fn send(
         self,
     ) -> ::std::result::Result<
         crate::operation::float16::Float16Output,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::float16::Float16Error,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {
         let input = self
             .inner
             .build()
             .map_err(::aws_smithy_runtime_api::client::result::SdkError::construction_failure)?;
         let runtime_plugins = crate::operation::float16::Float16::operation_runtime_plugins(
             self.handle.runtime_plugins.clone(),
             &self.handle.conf,
             self.config_override,
         );
         crate::operation::float16::Float16::orchestrate(&runtime_plugins, input).await
-93
+    }
-94
     /// Consumes this builder, creating a customizable operation that can be modified before being sent.
     pub fn customize(
         self,
     ) -> crate::client::customize::CustomizableOperation<crate::operation::float16::Float16Output, crate::operation::float16::Float16Error, Self>
-99
+    {
         crate::client::customize::CustomizableOperation::new(self)
-101
+    }
     /* FluentBuilderGenerator.kt:315 */
     pub(crate) fn config_override(mut self, config_override: impl ::std::convert::Into<crate::config::Builder>) -> Self {
         self.set_config_override(::std::option::Option::Some(config_override.into()));
         self
-106
+    }
-107
     pub(crate) fn set_config_override(&mut self, config_override: ::std::option::Option<crate::config::Builder>) -> &mut Self {
         self.config_override = config_override;
         self
-111
+    }
     /* FluentBuilderGenerator.kt:282 */
-113
+}

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/fractional_seconds.rs

@@ -1,1 +40,49 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* OperationGenerator.kt:77 */
 /// Orchestration and serialization glue logic for `FractionalSeconds`.
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* OperationGenerator.kt:84 */
 pub struct FractionalSeconds;
 /* OperationGenerator.kt:85 */
 impl FractionalSeconds {
     /// Creates a new `FractionalSeconds`
     /// /* OperationGenerator.kt:86 */Creates a new `FractionalSeconds`
     /* OperationGenerator.kt:87 */
     pub fn new() -> Self {
         /* OperationGenerator.kt:88 */
         Self
         /* OperationGenerator.kt:87 */
-18
+    }
     /* OperationGenerator.kt:138 */
     pub(crate) async fn orchestrate(
         runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         input: crate::operation::fractional_seconds::FractionalSecondsInput,
     ) -> ::std::result::Result<
         crate::operation::fractional_seconds::FractionalSecondsOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::fractional_seconds::FractionalSecondsError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {

↧ Expand context

         let map_err = |err: ::aws_smithy_runtime_api::client::result::SdkError<
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >| {
             err.map_service_error(|err| {
                 err.downcast::<crate::operation::fractional_seconds::FractionalSecondsError>()
                     .expect("correct error type")
             })
         };
         let context = Self::orchestrate_with_stop_point(runtime_plugins, input, ::aws_smithy_runtime::client::orchestrator::StopPoint::None)
             .await
             .map_err(map_err)?;
         let output = context.finalize().map_err(map_err)?;
         ::std::result::Result::Ok(
             output
                 .downcast::<crate::operation::fractional_seconds::FractionalSecondsOutput>()
                 .expect("correct output type"),
-47
+        )
-48
+    }
-49

@@ -57,66 +382,458 @@

↥ Expand context

             .instrument(::tracing::debug_span!(
                 "RpcV2Protocol.FractionalSeconds",
                 "rpc.service" = "RpcV2Protocol",
                 "rpc.method" = "FractionalSeconds",
                 "sdk_invocation_id" = ::fastrand::u32(1_000_000..10_000_000),
             ))
             .await
-73
+    }
-74
     pub(crate) fn operation_runtime_plugins(
         client_runtime_plugins: ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         client_config: &crate::config::Config,
         config_override: ::std::option::Option<crate::config::Builder>,
     ) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
         let mut runtime_plugins = client_runtime_plugins.with_operation_plugin(Self::new());
         runtime_plugins = runtime_plugins.with_client_plugin(crate::auth_plugin::DefaultAuthOptionsPlugin::new(vec![
             ::aws_smithy_runtime::client::auth::no_auth::NO_AUTH_SCHEME_ID,
         ]));
         if let ::std::option::Option::Some(config_override) = config_override {
             for plugin in config_override.runtime_plugins.iter().cloned() {

                 runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
-87
+            }
             runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
                 config_override,
                 client_config.config.clone(),
                 &client_config.runtime_components,
             ));
-93
+        }
         runtime_plugins
-95
+    }
     /* OperationGenerator.kt:85 */
-97
+}
 /* OperationRuntimePluginGenerator.kt:55 */
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for FractionalSeconds {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         let mut cfg = ::aws_smithy_types::config_bag::Layer::new("FractionalSeconds");
-102
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
             FractionalSecondsRequestSerializer,
         ));
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
             FractionalSecondsResponseDeserializer,
         ));
-109
         cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
             ::aws_smithy_runtime_api::client::auth::static_resolver::StaticAuthSchemeOptionResolverParams::new(),
         ));
-113
         cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
             "FractionalSeconds",
             "RpcV2Protocol",
         ));
-118
         ::std::option::Option::Some(cfg.freeze())
-120
+    }
-121
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         #[allow(unused_mut)]
         let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("FractionalSeconds")
             .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
             .with_interceptor(FractionalSecondsEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::fractional_seconds::FractionalSecondsError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::fractional_seconds::FractionalSecondsError,
             >::new());
-136
         ::std::borrow::Cow::Owned(rcb)
-138
+    }
-139
+}
-140
 /* ResponseDeserializerGenerator.kt:64 */
 #[derive(Debug)]
 struct FractionalSecondsResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for FractionalSecondsResponseDeserializer {
     fn deserialize_nonstreaming(
         &self,
         response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
     ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
         let (success, status) = (response.status().is_success(), response.status().as_u16());
         let headers = response.headers();
         let body = response.body().bytes().expect("body loaded");
         #[allow(unused_mut)]
         let mut force_error = false;
-154
         let parse_result = if !success && status != 200 || force_error {
             crate::protocol_serde::shape_fractional_seconds::de_fractional_seconds_http_error(status, headers, body)
         } else {
             crate::protocol_serde::shape_fractional_seconds::de_fractional_seconds_http_response(status, headers, body)
         };
         crate::protocol_serde::type_erase_result(parse_result)
-161
+    }
-162
+}
 /* RequestSerializerGenerator.kt:67 */
 #[derive(Debug)]
 struct FractionalSecondsRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for FractionalSecondsRequestSerializer {
     #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
     fn serialize_input(
         &self,
         input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
         _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
         let input = input
             .downcast::<crate::operation::fractional_seconds::FractionalSecondsInput>()
             .expect("correct type");
         let _header_serialization_settings = _cfg
             .load::<crate::serialization_settings::HeaderSerializationSettings>()
             .cloned()
             .unwrap_or_default();
         let mut request_builder = {
             fn uri_base(
                 _input: &crate::operation::fractional_seconds::FractionalSecondsInput,
                 output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 use ::std::fmt::Write as _;
                 ::std::write!(output, "/service/RpcV2Protocol/operation/FractionalSeconds").expect("formatting should succeed");
                 ::std::result::Result::Ok(())
-188
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::fractional_seconds::FractionalSecondsInput,
                 builder: ::http::request::Builder,
             ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
                 let mut uri = ::std::string::String::new();
                 uri_base(input, &mut uri)?;
                 ::std::result::Result::Ok(builder.method("POST").uri(uri))
-197
+            }
             let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
             builder =
                 _header_serialization_settings.set_default_header(builder, ::http::header::HeaderName::from_static("smithy-protocol"), "rpc-v2-cbor");
             builder =
                 _header_serialization_settings.set_default_header(builder, ::http::header::HeaderName::from_static("accept"), "application/cbor");
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from("");
         if let Some(content_length) = body.content_length() {
             let content_length = content_length.to_string();
             request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
-209
+        }
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
-211
+    }
-212
+}
 /* EndpointParamsInterceptorGenerator.kt:86 */
 #[derive(Debug)]
 struct FractionalSecondsEndpointParamsInterceptor;
-216
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for FractionalSecondsEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "FractionalSecondsEndpointParamsInterceptor"
-220
+    }
-221
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<FractionalSecondsInput>()
             .ok_or("failed to downcast to FractionalSecondsInput")?;
-236
         let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
             ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
         })?;
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
         ::std::result::Result::Ok(())
-243
+    }
-244
+}
-245
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-248
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod fractional_seconds_test {
-255
     /// Ensures that clients can correctly parse timestamps with fractional seconds
     /// Test ID: RpcV2CborDateTimeWithFractionalSeconds
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn rpc_v2_cbor_date_time_with_fractional_seconds_response() {
         let expected_output = crate::operation::fractional_seconds::FractionalSecondsOutput::builder()
             .set_datetime(::std::option::Option::Some(::aws_smithy_types::DateTime::from_fractional_secs(
                 946845296, 0.123_f64,
             )))
             .build();
         let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(
             ::http::response::Builder::new()
                 .header("Content-Type", "application/cbor")
                 .header("smithy-protocol", "rpc-v2-cbor")
                 .status(200)
                 .body(::aws_smithy_types::body::SdkBody::from("v2hkYXRldGltZcH7Qcw32zgPvnf/"))
                 .unwrap(),
-273
+        )
         .unwrap();
         use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
         use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;
-277
         let op = crate::operation::fractional_seconds::FractionalSeconds::new();
         let config = op.config().expect("the operation has config");
         let de = config
             .load::<::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer>()
             .expect("the config must have a deserializer");
-283
         let parsed = de.deserialize_streaming(&mut http_response);
         let parsed = parsed.unwrap_or_else(|| {
             let http_response = http_response.map(|body| {
                 ::aws_smithy_types::body::SdkBody::from(::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                     body.bytes().unwrap(),
                     ::aws_smithy_protocol_test::MediaType::from("application/cbor"),
                 )))
             });
             de.deserialize_nonstreaming(&http_response)
         });
         let parsed = parsed
             .expect("should be successful response")
             .downcast::<crate::operation::fractional_seconds::FractionalSecondsOutput>()
             .unwrap();
         ::pretty_assertions::assert_eq!(parsed.datetime, expected_output.datetime, "Unexpected value for `datetime`");
-299
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-302
+}
-303
 /* OperationErrorGenerator.kt:79 */
 /// Error type for the `FractionalSecondsError` operation.
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::fmt::Debug)]
 pub enum FractionalSecondsError {
 pub /* OperationErrorGenerator.kt:81 */ enum FractionalSecondsError {
     /* OperationErrorGenerator.kt:88 */
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-315
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-317
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-FractionalSecondsError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
     /* OperationErrorGenerator.kt:81 */
-321
+}
 /* OperationErrorGenerator.kt:218 */
 impl FractionalSecondsError {
     /* OperationErrorGenerator.kt:219 */
     /// Creates the `FractionalSecondsError::Unhandled` variant from any error type.
     pub fn unhandled(
         err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
     ) -> Self {
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source: err.into(),
             meta: ::std::default::Default::default(),
         })
-333
+    }
-334
     /// Creates the `FractionalSecondsError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
     pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source: err.clone().into(),
             meta: err,
         })
-341
+    }
     ///
     /// /* OperationErrorGenerator.kt:236 */
     /// Returns error metadata, which includes the error code, message,
     /// request ID, and potentially additional information.
     ///
     /* OperationErrorGenerator.kt:242 */
     pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         /* OperationErrorGenerator.kt:243 */
         match self {
             Self::Unhandled(e) => &e.meta,
             /* OperationErrorGenerator.kt:251 */ Self::Unhandled(e) => &e.meta,
             /* OperationErrorGenerator.kt:243 */
-352
+        }
         /* OperationErrorGenerator.kt:242 */
-354
+    }
     /* OperationErrorGenerator.kt:218 */
-356
+}
 /* OperationErrorGenerator.kt:269 */
 impl ::std::error::Error for FractionalSecondsError {
     /* OperationErrorGenerator.kt:270 */
     fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
         /* OperationErrorGenerator.kt:318 */
         match self {
             Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:279 */
                 ::std::option::Option::Some(&*_inner.source)
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-369
+        }
         /* OperationErrorGenerator.kt:270 */
-371
+    }
     /* OperationErrorGenerator.kt:269 */
-373
+}
 /* OperationErrorGenerator.kt:133 */
 impl ::std::fmt::Display for FractionalSecondsError {
     /* OperationErrorGenerator.kt:134 */
     fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
         /* OperationErrorGenerator.kt:318 */
         match self {
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:139 */
                 if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
                     write!(f, "unhandled error ({code})")
                 } else {
                     f.write_str("unhandled error")
-387
+                }
--
+            }
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-390
+        }
         /* OperationErrorGenerator.kt:134 */
-392
+    }
     /* OperationErrorGenerator.kt:133 */
-394
+}
 /* OperationErrorGenerator.kt:182 */
 impl ::aws_smithy_types::retry::ProvideErrorKind for FractionalSecondsError {
     /* OperationErrorGenerator.kt:186 */
     fn code(&self) -> ::std::option::Option<&str> {
         /* OperationErrorGenerator.kt:187 */
         ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
         /* OperationErrorGenerator.kt:186 */
-402
+    }
     /* OperationErrorGenerator.kt:190 */
     fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
         /* OperationErrorGenerator.kt:197 */
         ::std::option::Option::None
         /* OperationErrorGenerator.kt:190 */
-408
+    }
     /* OperationErrorGenerator.kt:182 */
-410
+}
 /* OperationErrorGenerator.kt:163 */
 impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for FractionalSecondsError {
     /* OperationErrorGenerator.kt:164 */
     fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         /* OperationErrorGenerator.kt:318 */
         match self {
             Self::Unhandled(_inner) => &_inner.meta,
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:168 */
                 &_inner.meta
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-423
+        }
         /* OperationErrorGenerator.kt:164 */
-425
+    }
     /* OperationErrorGenerator.kt:163 */
-427
+}
 /* OperationErrorGenerator.kt:109 */
 impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for FractionalSecondsError {
     /* OperationErrorGenerator.kt:110 */
     fn create_unhandled_error(
         source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
         meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
     ) -> Self {
         /* OperationErrorGenerator.kt:121 */
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source,
             meta: meta.unwrap_or_default(),
         })
         /* OperationErrorGenerator.kt:110 */
-441
+    }
     /* OperationErrorGenerator.kt:109 */
-443
+}
-444
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::fractional_seconds::_fractional_seconds_output::FractionalSecondsOutput;
-447
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::fractional_seconds::_fractional_seconds_input::FractionalSecondsInput;
-450
 /* RustModule.kt:172 */
 mod _fractional_seconds_input;
-453
 /* RustModule.kt:172 */
 mod _fractional_seconds_output;
-456
 /// Builders
 /// /* CodegenDelegator.kt:51 */Builders
 pub mod builders;

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/fractional_seconds/_fractional_seconds_input.rs

@@ -1,1 +24,44 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct FractionalSecondsInput {}
 pub /* StructureGenerator.kt:201 */ struct FractionalSecondsInput {/* StructureGenerator.kt:201 */}
 /* ClientCodegenVisitor.kt:237 */
 impl FractionalSecondsInput {
     /// Creates a new builder-style object to manufacture [`FractionalSecondsInput`](crate::operation::fractional_seconds::FractionalSecondsInput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`FractionalSecondsInput`](crate::operation::fractional_seconds::FractionalSecondsInput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::fractional_seconds::builders::FractionalSecondsInputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::fractional_seconds::builders::FractionalSecondsInputBuilder::default()
         /* BuilderGenerator.kt:175 */
-17
+    }
     /* ClientCodegenVisitor.kt:237 */
-19
+}
-20
 /// A builder for [`FractionalSecondsInput`](crate::operation::fractional_seconds::FractionalSecondsInput).
 /// /* BuilderGenerator.kt:342 */A builder for [`FractionalSecondsInput`](crate::operation::fractional_seconds::FractionalSecondsInput).
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 pub struct FractionalSecondsInputBuilder {}
 /* BuilderGenerator.kt:345 */
 pub struct FractionalSecondsInputBuilder {/* BuilderGenerator.kt:345 */}
 /* BuilderGenerator.kt:355 */
 impl FractionalSecondsInputBuilder {
     /// Consumes the builder and constructs a [`FractionalSecondsInput`](crate::operation::fractional_seconds::FractionalSecondsInput).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`FractionalSecondsInput`](crate::operation::fractional_seconds::FractionalSecondsInput).
     /* BuilderGenerator.kt:253 */
     pub fn build(
         self,
     ) -> ::std::result::Result<crate::operation::fractional_seconds::FractionalSecondsInput, ::aws_smithy_types::error::operation::BuildError> {
         ::std::result::Result::Ok(crate::operation::fractional_seconds::FractionalSecondsInput {})
         /* BuilderGenerator.kt:254 */
         ::std::result::Result::Ok(
             /* BuilderGenerator.kt:477 */
             crate::operation::fractional_seconds::FractionalSecondsInput {
             /* BuilderGenerator.kt:477 */}, /* BuilderGenerator.kt:254 */
-+
+        )
         /* BuilderGenerator.kt:253 */
-42
+    }
     /* BuilderGenerator.kt:355 */
-44
+}

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/fractional_seconds/_fractional_seconds_output.rs

@@ -1,1 +47,88 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct FractionalSecondsOutput {
 pub /* StructureGenerator.kt:201 */ struct FractionalSecondsOutput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
     pub datetime: ::std::option::Option<::aws_smithy_types::DateTime>,
     /* StructureGenerator.kt:201 */
-13
+}
 /* StructureGenerator.kt:135 */
 impl FractionalSecondsOutput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
                            /* StructureGenerator.kt:166 */
     pub fn datetime(&self) -> ::std::option::Option<&::aws_smithy_types::DateTime> {
         /* StructureGenerator.kt:170 */
         self.datetime.as_ref()
         /* StructureGenerator.kt:166 */
-23
+    }
     /* StructureGenerator.kt:135 */
-25
+}
 /* ClientCodegenVisitor.kt:237 */
 impl FractionalSecondsOutput {
     /// Creates a new builder-style object to manufacture [`FractionalSecondsOutput`](crate::operation::fractional_seconds::FractionalSecondsOutput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`FractionalSecondsOutput`](crate::operation::fractional_seconds::FractionalSecondsOutput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::fractional_seconds::builders::FractionalSecondsOutputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::fractional_seconds::builders::FractionalSecondsOutputBuilder::default()
         /* BuilderGenerator.kt:175 */
-34
+    }
     /* ClientCodegenVisitor.kt:237 */
-36
+}
-37
 /// A builder for [`FractionalSecondsOutput`](crate::operation::fractional_seconds::FractionalSecondsOutput).
 /// /* BuilderGenerator.kt:342 */A builder for [`FractionalSecondsOutput`](crate::operation::fractional_seconds::FractionalSecondsOutput).
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* BuilderGenerator.kt:345 */
 pub struct FractionalSecondsOutputBuilder {
     pub(crate) datetime: ::std::option::Option<::aws_smithy_types::DateTime>,
     /* BuilderGenerator.kt:275 */ pub(crate) datetime: ::std::option::Option<::aws_smithy_types::DateTime>,
     /* BuilderGenerator.kt:345 */
-47
+}
 /* BuilderGenerator.kt:355 */
 impl FractionalSecondsOutputBuilder {
     /* BuilderGenerator.kt:286 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:291 */
     pub fn datetime(mut self, input: ::aws_smithy_types::DateTime) -> Self {
         /* BuilderGenerator.kt:292 */
         self.datetime = ::std::option::Option::Some(input);
         /* BuilderGenerator.kt:293 */
         self
         /* BuilderGenerator.kt:291 */
-59
+    }
     /* BuilderGenerator.kt:312 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:314 */
     pub fn set_datetime(mut self, input: ::std::option::Option<::aws_smithy_types::DateTime>) -> Self {
         /* BuilderGenerator.kt:315 */
         self.datetime = input;
         self
         /* BuilderGenerator.kt:314 */
-68
+    }
     /* BuilderGenerator.kt:334 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:336 */
     pub fn get_datetime(&self) -> &::std::option::Option<::aws_smithy_types::DateTime> {
         /* BuilderGenerator.kt:337 */
         &self.datetime
         /* BuilderGenerator.kt:336 */
-76
+    }
     /// Consumes the builder and constructs a [`FractionalSecondsOutput`](crate::operation::fractional_seconds::FractionalSecondsOutput).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`FractionalSecondsOutput`](crate::operation::fractional_seconds::FractionalSecondsOutput).
     /* BuilderGenerator.kt:253 */
     pub fn build(self) -> crate::operation::fractional_seconds::FractionalSecondsOutput {
         crate::operation::fractional_seconds::FractionalSecondsOutput { datetime: self.datetime }
         /* BuilderGenerator.kt:477 */
         crate::operation::fractional_seconds::FractionalSecondsOutput {
             /* BuilderGenerator.kt:481 */ datetime: self.datetime,
             /* BuilderGenerator.kt:477 */
-+
+        }
         /* BuilderGenerator.kt:253 */
-86
+    }
     /* BuilderGenerator.kt:355 */
-88
+}

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/fractional_seconds/builders.rs

@@ -1,1 +110,122 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::fractional_seconds::_fractional_seconds_output::FractionalSecondsOutputBuilder;
-4
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::fractional_seconds::_fractional_seconds_input::FractionalSecondsInputBuilder;
-7
 /* FluentBuilderGenerator.kt:408 */
 impl crate::operation::fractional_seconds::builders::FractionalSecondsInputBuilder {
     /// Sends a request with this input using the given client.
     pub async fn send_with(
         self,
         client: &crate::Client,
     ) -> ::std::result::Result<
         crate::operation::fractional_seconds::FractionalSecondsOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::fractional_seconds::FractionalSecondsError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {
         let mut fluent_builder = client.fractional_seconds();
         fluent_builder.inner = self;
         fluent_builder.send().await
-24
+    }
-25
+}
 /// Fluent builder constructing a request to `FractionalSeconds`.
 /// /* FluentBuilderGenerator.kt:129 */Fluent builder constructing a request to `FractionalSeconds`.
 ///
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::fmt::Debug)]
 /* FluentBuilderGenerator.kt:270 */
 pub struct FractionalSecondsFluentBuilder {
     handle: ::std::sync::Arc<crate::client::Handle>,
     inner: crate::operation::fractional_seconds::builders::FractionalSecondsInputBuilder,
     config_override: ::std::option::Option<crate::config::Builder>,
-35
+}
 /* FluentBuilderGenerator.kt:381 */
 impl
     crate::client::customize::internal::CustomizableSend<
         crate::operation::fractional_seconds::FractionalSecondsOutput,
         crate::operation::fractional_seconds::FractionalSecondsError,
     > for FractionalSecondsFluentBuilder
-42
+{
     fn send(
         self,
         config_override: crate::config::Builder,
     ) -> crate::client::customize::internal::BoxFuture<
         crate::client::customize::internal::SendResult<
             crate::operation::fractional_seconds::FractionalSecondsOutput,
             crate::operation::fractional_seconds::FractionalSecondsError,
         >,
     > {
         ::std::boxed::Box::pin(async move { self.config_override(config_override).send().await })
-53
+    }
-54
+}
 /* FluentBuilderGenerator.kt:282 */
 impl FractionalSecondsFluentBuilder {
     /* FluentBuilderGenerator.kt:288 */
     /// Creates a new `FractionalSecondsFluentBuilder`.
     pub(crate) fn new(handle: ::std::sync::Arc<crate::client::Handle>) -> Self {
         Self {
             handle,
             inner: ::std::default::Default::default(),
             config_override: ::std::option::Option::None,
-64
+        }
-65
+    }
     /* FluentBuilderGenerator.kt:301 */
     /// Access the FractionalSeconds as a reference.
     pub fn as_input(&self) -> &crate::operation::fractional_seconds::builders::FractionalSecondsInputBuilder {
         &self.inner
-70
+    }
     /* FluentBuilderGenerator.kt:145 */
     /// Sends the request and returns the response.
     ///
     /// If an error occurs, an `SdkError` will be returned with additional details that
     /// can be matched against.
     ///
     /// By default, any retryable failures will be retried twice. Retry behavior
     /// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
     /// set when configuring the client.
     pub async fn send(
         self,
     ) -> ::std::result::Result<
         crate::operation::fractional_seconds::FractionalSecondsOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::fractional_seconds::FractionalSecondsError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {
         let input = self
             .inner
             .build()
             .map_err(::aws_smithy_runtime_api::client::result::SdkError::construction_failure)?;
         let runtime_plugins = crate::operation::fractional_seconds::FractionalSeconds::operation_runtime_plugins(
             self.handle.runtime_plugins.clone(),
             &self.handle.conf,
             self.config_override,
         );
         crate::operation::fractional_seconds::FractionalSeconds::orchestrate(&runtime_plugins, input).await
-99
+    }
-100
     /// Consumes this builder, creating a customizable operation that can be modified before being sent.
     pub fn customize(
         self,
     ) -> crate::client::customize::CustomizableOperation<
         crate::operation::fractional_seconds::FractionalSecondsOutput,
         crate::operation::fractional_seconds::FractionalSecondsError,
         Self,
     > {
         crate::client::customize::CustomizableOperation::new(self)
-110
+    }
     /* FluentBuilderGenerator.kt:315 */
     pub(crate) fn config_override(mut self, config_override: impl ::std::convert::Into<crate::config::Builder>) -> Self {
         self.set_config_override(::std::option::Option::Some(config_override.into()));
         self
-115
+    }
-116
     pub(crate) fn set_config_override(&mut self, config_override: ::std::option::Option<crate::config::Builder>) -> &mut Self {
         self.config_override = config_override;
         self
-120
+    }
     /* FluentBuilderGenerator.kt:282 */
-122
+}

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/greeting_with_errors.rs

@@ -1,1 +40,49 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* OperationGenerator.kt:77 */
 /// Orchestration and serialization glue logic for `GreetingWithErrors`.
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* OperationGenerator.kt:84 */
 pub struct GreetingWithErrors;
 /* OperationGenerator.kt:85 */
 impl GreetingWithErrors {
     /// Creates a new `GreetingWithErrors`
     /// /* OperationGenerator.kt:86 */Creates a new `GreetingWithErrors`
     /* OperationGenerator.kt:87 */
     pub fn new() -> Self {
         /* OperationGenerator.kt:88 */
         Self
         /* OperationGenerator.kt:87 */
-18
+    }
     /* OperationGenerator.kt:138 */
     pub(crate) async fn orchestrate(
         runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         input: crate::operation::greeting_with_errors::GreetingWithErrorsInput,
     ) -> ::std::result::Result<
         crate::operation::greeting_with_errors::GreetingWithErrorsOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::greeting_with_errors::GreetingWithErrorsError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {

↧ Expand context

         let map_err = |err: ::aws_smithy_runtime_api::client::result::SdkError<
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >| {
             err.map_service_error(|err| {
                 err.downcast::<crate::operation::greeting_with_errors::GreetingWithErrorsError>()
                     .expect("correct error type")
             })
         };
         let context = Self::orchestrate_with_stop_point(runtime_plugins, input, ::aws_smithy_runtime::client::orchestrator::StopPoint::None)
             .await
             .map_err(map_err)?;
         let output = context.finalize().map_err(map_err)?;
         ::std::result::Result::Ok(
             output
                 .downcast::<crate::operation::greeting_with_errors::GreetingWithErrorsOutput>()
                 .expect("correct output type"),
-47
+        )
-48
+    }
-49

@@ -57,66 +266,283 @@

↥ Expand context

             .instrument(::tracing::debug_span!(
                 "RpcV2Protocol.GreetingWithErrors",
                 "rpc.service" = "RpcV2Protocol",
                 "rpc.method" = "GreetingWithErrors",
                 "sdk_invocation_id" = ::fastrand::u32(1_000_000..10_000_000),
             ))
             .await
-73
+    }
-74
     pub(crate) fn operation_runtime_plugins(
         client_runtime_plugins: ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         client_config: &crate::config::Config,
         config_override: ::std::option::Option<crate::config::Builder>,
     ) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
         let mut runtime_plugins = client_runtime_plugins.with_operation_plugin(Self::new());
         runtime_plugins = runtime_plugins.with_client_plugin(crate::auth_plugin::DefaultAuthOptionsPlugin::new(vec![
             ::aws_smithy_runtime::client::auth::no_auth::NO_AUTH_SCHEME_ID,
         ]));
         if let ::std::option::Option::Some(config_override) = config_override {
             for plugin in config_override.runtime_plugins.iter().cloned() {

                 runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
-87
+            }
             runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
                 config_override,
                 client_config.config.clone(),
                 &client_config.runtime_components,
             ));
-93
+        }
         runtime_plugins
-95
+    }
     /* OperationGenerator.kt:85 */
-97
+}
 /* OperationRuntimePluginGenerator.kt:55 */
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for GreetingWithErrors {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         let mut cfg = ::aws_smithy_types::config_bag::Layer::new("GreetingWithErrors");
-102
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
             GreetingWithErrorsRequestSerializer,
         ));
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
             GreetingWithErrorsResponseDeserializer,
         ));
-109
         cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
             ::aws_smithy_runtime_api::client::auth::static_resolver::StaticAuthSchemeOptionResolverParams::new(),
         ));
-113
         cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
             "GreetingWithErrors",
             "RpcV2Protocol",
         ));
-118
         ::std::option::Option::Some(cfg.freeze())
-120
+    }
-121
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         #[allow(unused_mut)]
         let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("GreetingWithErrors")
             .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
             .with_interceptor(GreetingWithErrorsEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::greeting_with_errors::GreetingWithErrorsError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::greeting_with_errors::GreetingWithErrorsError,
             >::new());
-136
         ::std::borrow::Cow::Owned(rcb)
-138
+    }
-139
+}
-140
 /* ResponseDeserializerGenerator.kt:64 */
 #[derive(Debug)]
 struct GreetingWithErrorsResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for GreetingWithErrorsResponseDeserializer {
     fn deserialize_nonstreaming(
         &self,
         response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
     ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
         let (success, status) = (response.status().is_success(), response.status().as_u16());
         let headers = response.headers();
         let body = response.body().bytes().expect("body loaded");
         #[allow(unused_mut)]
         let mut force_error = false;
-154
         let parse_result = if !success && status != 200 || force_error {
             crate::protocol_serde::shape_greeting_with_errors::de_greeting_with_errors_http_error(status, headers, body)
         } else {
             crate::protocol_serde::shape_greeting_with_errors::de_greeting_with_errors_http_response(status, headers, body)
         };
         crate::protocol_serde::type_erase_result(parse_result)
-161
+    }
-162
+}
 /* RequestSerializerGenerator.kt:67 */
 #[derive(Debug)]
 struct GreetingWithErrorsRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for GreetingWithErrorsRequestSerializer {
     #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
     fn serialize_input(
         &self,
         input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
         _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
         let input = input
             .downcast::<crate::operation::greeting_with_errors::GreetingWithErrorsInput>()
             .expect("correct type");
         let _header_serialization_settings = _cfg
             .load::<crate::serialization_settings::HeaderSerializationSettings>()
             .cloned()
             .unwrap_or_default();
         let mut request_builder = {
             fn uri_base(
                 _input: &crate::operation::greeting_with_errors::GreetingWithErrorsInput,
                 output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 use ::std::fmt::Write as _;
                 ::std::write!(output, "/service/RpcV2Protocol/operation/GreetingWithErrors").expect("formatting should succeed");
                 ::std::result::Result::Ok(())
-188
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::greeting_with_errors::GreetingWithErrorsInput,
                 builder: ::http::request::Builder,
             ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
                 let mut uri = ::std::string::String::new();
                 uri_base(input, &mut uri)?;
                 ::std::result::Result::Ok(builder.method("POST").uri(uri))
-197
+            }
             let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
             builder =
                 _header_serialization_settings.set_default_header(builder, ::http::header::HeaderName::from_static("smithy-protocol"), "rpc-v2-cbor");
             builder =
                 _header_serialization_settings.set_default_header(builder, ::http::header::HeaderName::from_static("accept"), "application/cbor");
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from("");
         if let Some(content_length) = body.content_length() {
             let content_length = content_length.to_string();
             request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
-209
+        }
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
-211
+    }
-212
+}
 /* EndpointParamsInterceptorGenerator.kt:86 */
 #[derive(Debug)]
 struct GreetingWithErrorsEndpointParamsInterceptor;
-216
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for GreetingWithErrorsEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "GreetingWithErrorsEndpointParamsInterceptor"
-220
+    }
-221
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<GreetingWithErrorsInput>()
             .ok_or("failed to downcast to GreetingWithErrorsInput")?;
-236
         let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
             ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
         })?;
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
         ::std::result::Result::Ok(())
-243
+    }
-244
+}
-245
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-248
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod greeting_with_errors_test {
-255
     /// Parses simple RpcV2 Cbor errors
     /// Test ID: RpcV2CborInvalidGreetingError
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn rpc_v2_cbor_invalid_greeting_error_response() {
         let expected_output = crate::types::error::InvalidGreeting::builder()
             .set_message(::std::option::Option::Some("Hi".to_owned()))
             .build();

↧ Expand context

         let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(
             ::http::response::Builder::new()
                 .header("Content-Type", "application/cbor")
                 .header("smithy-protocol", "rpc-v2-cbor")
                 .status(400)
                 .body(::aws_smithy_types::body::SdkBody::from(
                     "v2ZfX3R5cGV4LnNtaXRoeS5wcm90b2NvbHRlc3RzLnJwY3YyQ2JvciNJbnZhbGlkR3JlZXRpbmdnTWVzc2FnZWJIaf8=",
                 ))
                 .unwrap(),
-273
+        )
         .unwrap();
         use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
         use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;
-277
         let op = crate::operation::greeting_with_errors::GreetingWithErrors::new();
         let config = op.config().expect("the operation has config");
         let de = config
             .load::<::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer>()
             .expect("the config must have a deserializer");
-283

@@ -357,374 +506,628 @@

↥ Expand context

         use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
         use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;
-376
         let op = crate::operation::greeting_with_errors::GreetingWithErrors::new();
         let config = op.config().expect("the operation has config");
         let de = config
             .load::<::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer>()
             .expect("the config must have a deserializer");
-382
         let parsed = de.deserialize_streaming(&mut http_response);
         let parsed = parsed.unwrap_or_else(|| {
             let http_response = http_response.map(|body| {
                 ::aws_smithy_types::body::SdkBody::from(::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                     body.bytes().unwrap(),
                     ::aws_smithy_protocol_test::MediaType::from("application/cbor"),
                 )))
             });
             de.deserialize_nonstreaming(&http_response)
         });
         let parsed = parsed.expect_err("should be error response");

         let parsed: &crate::operation::greeting_with_errors::GreetingWithErrorsError =
             parsed.as_operation_error().expect("operation error").downcast_ref().unwrap();
         if let crate::operation::greeting_with_errors::GreetingWithErrorsError::ComplexError(parsed) = parsed {
             ::pretty_assertions::assert_eq!(parsed.top_level, expected_output.top_level, "Unexpected value for `top_level`");
             ::pretty_assertions::assert_eq!(parsed.nested, expected_output.nested, "Unexpected value for `nested`");
             ::pretty_assertions::assert_eq!(parsed.message, expected_output.message, "Unexpected value for `message`");
         } else {
             panic!("wrong variant: Got: {:?}. Expected: {:?}", parsed, expected_output);
-402
+        }
-403
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-406
+}
-407
 /* OperationErrorGenerator.kt:79 */
 /// Error type for the `GreetingWithErrorsError` operation.
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::fmt::Debug)]
 pub enum GreetingWithErrorsError {
     /// This error is thrown when an invalid greeting value is provided.
 pub /* OperationErrorGenerator.kt:81 */ enum GreetingWithErrorsError {
     /// /* OperationErrorGenerator.kt:83 */This error is thrown when an invalid greeting value is provided.
     /* OperationErrorGenerator.kt:86 */
     InvalidGreeting(crate::types::error::InvalidGreeting),
     /// This error is thrown when a request is invalid.
     /// /* OperationErrorGenerator.kt:83 */This error is thrown when a request is invalid.
     /* OperationErrorGenerator.kt:86 */
     ComplexError(crate::types::error::ComplexError),
     /* OperationErrorGenerator.kt:88 */
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-425
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-427
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-GreetingWithErrorsError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
     /* OperationErrorGenerator.kt:81 */
-431
+}
 /* OperationErrorGenerator.kt:218 */
 impl GreetingWithErrorsError {
     /* OperationErrorGenerator.kt:219 */
     /// Creates the `GreetingWithErrorsError::Unhandled` variant from any error type.
     pub fn unhandled(
         err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
     ) -> Self {
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source: err.into(),
             meta: ::std::default::Default::default(),
         })
-443
+    }
-444
     /// Creates the `GreetingWithErrorsError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
     pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source: err.clone().into(),
             meta: err,
         })
-451
+    }
     ///
     /// /* OperationErrorGenerator.kt:236 */
     /// Returns error metadata, which includes the error code, message,
     /// request ID, and potentially additional information.
     ///
     /* OperationErrorGenerator.kt:242 */
     pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         /* OperationErrorGenerator.kt:243 */
         match self {
             Self::InvalidGreeting(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
             Self::ComplexError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
             Self::Unhandled(e) => &e.meta,
             /* OperationErrorGenerator.kt:246 */ Self::InvalidGreeting(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
             /* OperationErrorGenerator.kt:246 */ Self::ComplexError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
             /* OperationErrorGenerator.kt:251 */ Self::Unhandled(e) => &e.meta,
             /* OperationErrorGenerator.kt:243 */
-464
+        }
         /* OperationErrorGenerator.kt:242 */
-466
+    }
     /* OperationErrorGenerator.kt:257 */
     /// Returns `true` if the error kind is `GreetingWithErrorsError::InvalidGreeting`.
     /* OperationErrorGenerator.kt:258 */
     pub fn is_invalid_greeting(&self) -> bool {
         /* OperationErrorGenerator.kt:259 */
         matches!(self, Self::InvalidGreeting(_))
         /* OperationErrorGenerator.kt:258 */
-474
+    }
     /* OperationErrorGenerator.kt:257 */
     /// Returns `true` if the error kind is `GreetingWithErrorsError::ComplexError`.
     /* OperationErrorGenerator.kt:258 */
     pub fn is_complex_error(&self) -> bool {
         /* OperationErrorGenerator.kt:259 */
         matches!(self, Self::ComplexError(_))
         /* OperationErrorGenerator.kt:258 */
-482
+    }
     /* OperationErrorGenerator.kt:218 */
-484
+}
 /* OperationErrorGenerator.kt:269 */
 impl ::std::error::Error for GreetingWithErrorsError {
     /* OperationErrorGenerator.kt:270 */
     fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
         /* OperationErrorGenerator.kt:318 */
         match self {
             Self::InvalidGreeting(_inner) => ::std::option::Option::Some(_inner),
             Self::ComplexError(_inner) => ::std::option::Option::Some(_inner),
             Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
             /* OperationErrorGenerator.kt:321 */
             Self::InvalidGreeting(_inner) =>
             /* OperationErrorGenerator.kt:283 */
-+
+            {
                 ::std::option::Option::Some(_inner)
-+
+            }
-+
+            ,
             /* OperationErrorGenerator.kt:321 */
             Self::ComplexError(_inner) =>
             /* OperationErrorGenerator.kt:283 */
-+
+            {
                 ::std::option::Option::Some(_inner)
-+
+            }
-+
+            ,
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:279 */
                 ::std::option::Option::Some(&*_inner.source)
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-511
+        }
         /* OperationErrorGenerator.kt:270 */
-513
+    }
     /* OperationErrorGenerator.kt:269 */
-515
+}
 /* OperationErrorGenerator.kt:133 */
 impl ::std::fmt::Display for GreetingWithErrorsError {
     /* OperationErrorGenerator.kt:134 */
     fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
         /* OperationErrorGenerator.kt:318 */
         match self {
             Self::InvalidGreeting(_inner) => _inner.fmt(f),
             Self::ComplexError(_inner) => _inner.fmt(f),
             /* OperationErrorGenerator.kt:321 */
             Self::InvalidGreeting(_inner) =>
             /* OperationErrorGenerator.kt:151 */
-+
+            {
                 _inner.fmt(f)
-+
+            }
-+
+            ,
             /* OperationErrorGenerator.kt:321 */
             Self::ComplexError(_inner) =>
             /* OperationErrorGenerator.kt:151 */
-+
+            {
                 _inner.fmt(f)
-+
+            }
-+
+            ,
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:139 */
                 if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
                     write!(f, "unhandled error ({code})")
                 } else {
                     f.write_str("unhandled error")
-543
+                }
--
+            }
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-546
+        }
         /* OperationErrorGenerator.kt:134 */
-548
+    }
     /* OperationErrorGenerator.kt:133 */
-550
+}
 /* OperationErrorGenerator.kt:182 */
 impl ::aws_smithy_types::retry::ProvideErrorKind for GreetingWithErrorsError {
     /* OperationErrorGenerator.kt:186 */
     fn code(&self) -> ::std::option::Option<&str> {
         /* OperationErrorGenerator.kt:187 */
         ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
         /* OperationErrorGenerator.kt:186 */
-558
+    }
     /* OperationErrorGenerator.kt:190 */
     fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
         /* OperationErrorGenerator.kt:197 */
         ::std::option::Option::None
         /* OperationErrorGenerator.kt:190 */
-564
+    }
     /* OperationErrorGenerator.kt:182 */
-566
+}
 /* OperationErrorGenerator.kt:163 */
 impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for GreetingWithErrorsError {
     /* OperationErrorGenerator.kt:164 */
     fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         /* OperationErrorGenerator.kt:318 */
         match self {
             Self::InvalidGreeting(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
             Self::ComplexError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
             Self::Unhandled(_inner) => &_inner.meta,
             /* OperationErrorGenerator.kt:321 */
             Self::InvalidGreeting(_inner) =>
             /* OperationErrorGenerator.kt:169 */
-+
+            {
                 ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
-+
+            }
-+
+            ,
             /* OperationErrorGenerator.kt:321 */
             Self::ComplexError(_inner) =>
             /* OperationErrorGenerator.kt:169 */
-+
+            {
                 ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
-+
+            }
-+
+            ,
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:168 */
                 &_inner.meta
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-593
+        }
         /* OperationErrorGenerator.kt:164 */
-595
+    }
     /* OperationErrorGenerator.kt:163 */
-597
+}
 /* OperationErrorGenerator.kt:109 */
 impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for GreetingWithErrorsError {
     /* OperationErrorGenerator.kt:110 */
     fn create_unhandled_error(
         source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
         meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
     ) -> Self {
         /* OperationErrorGenerator.kt:121 */
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source,
             meta: meta.unwrap_or_default(),
         })
         /* OperationErrorGenerator.kt:110 */
-611
+    }
     /* OperationErrorGenerator.kt:109 */
-613
+}
-614
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::greeting_with_errors::_greeting_with_errors_output::GreetingWithErrorsOutput;
-617
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::greeting_with_errors::_greeting_with_errors_input::GreetingWithErrorsInput;
-620
 /* RustModule.kt:172 */
 mod _greeting_with_errors_input;
-623
 /* RustModule.kt:172 */
 mod _greeting_with_errors_output;
-626
 /// Builders
 /// /* CodegenDelegator.kt:51 */Builders
 pub mod builders;

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/greeting_with_errors/_greeting_with_errors_output.rs

@@ -1,1 +47,88 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct GreetingWithErrorsOutput {
 pub /* StructureGenerator.kt:201 */ struct GreetingWithErrorsOutput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
     pub greeting: ::std::option::Option<::std::string::String>,
     /* StructureGenerator.kt:201 */
-13
+}
 /* StructureGenerator.kt:135 */
 impl GreetingWithErrorsOutput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
                            /* StructureGenerator.kt:166 */
     pub fn greeting(&self) -> ::std::option::Option<&str> {
         /* StructureGenerator.kt:169 */
         self.greeting.as_deref()
         /* StructureGenerator.kt:166 */
-23
+    }
     /* StructureGenerator.kt:135 */
-25
+}
 /* ClientCodegenVisitor.kt:237 */
 impl GreetingWithErrorsOutput {
     /// Creates a new builder-style object to manufacture [`GreetingWithErrorsOutput`](crate::operation::greeting_with_errors::GreetingWithErrorsOutput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`GreetingWithErrorsOutput`](crate::operation::greeting_with_errors::GreetingWithErrorsOutput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::greeting_with_errors::builders::GreetingWithErrorsOutputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::greeting_with_errors::builders::GreetingWithErrorsOutputBuilder::default()
         /* BuilderGenerator.kt:175 */
-34
+    }
     /* ClientCodegenVisitor.kt:237 */
-36
+}
-37
 /// A builder for [`GreetingWithErrorsOutput`](crate::operation::greeting_with_errors::GreetingWithErrorsOutput).
 /// /* BuilderGenerator.kt:342 */A builder for [`GreetingWithErrorsOutput`](crate::operation::greeting_with_errors::GreetingWithErrorsOutput).
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* BuilderGenerator.kt:345 */
 pub struct GreetingWithErrorsOutputBuilder {
     pub(crate) greeting: ::std::option::Option<::std::string::String>,
     /* BuilderGenerator.kt:275 */ pub(crate) greeting: ::std::option::Option<::std::string::String>,
     /* BuilderGenerator.kt:345 */
-47
+}
 /* BuilderGenerator.kt:355 */
 impl GreetingWithErrorsOutputBuilder {
     /* BuilderGenerator.kt:286 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:291 */
     pub fn greeting(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
         /* BuilderGenerator.kt:292 */
         self.greeting = ::std::option::Option::Some(input.into());
         /* BuilderGenerator.kt:293 */
         self
         /* BuilderGenerator.kt:291 */
-59
+    }
     /* BuilderGenerator.kt:312 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:314 */
     pub fn set_greeting(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
         /* BuilderGenerator.kt:315 */
         self.greeting = input;
         self
         /* BuilderGenerator.kt:314 */
-68
+    }
     /* BuilderGenerator.kt:334 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:336 */
     pub fn get_greeting(&self) -> &::std::option::Option<::std::string::String> {
         /* BuilderGenerator.kt:337 */
         &self.greeting
         /* BuilderGenerator.kt:336 */
-76
+    }
     /// Consumes the builder and constructs a [`GreetingWithErrorsOutput`](crate::operation::greeting_with_errors::GreetingWithErrorsOutput).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`GreetingWithErrorsOutput`](crate::operation::greeting_with_errors::GreetingWithErrorsOutput).
     /* BuilderGenerator.kt:253 */
     pub fn build(self) -> crate::operation::greeting_with_errors::GreetingWithErrorsOutput {
         crate::operation::greeting_with_errors::GreetingWithErrorsOutput { greeting: self.greeting }
         /* BuilderGenerator.kt:477 */
         crate::operation::greeting_with_errors::GreetingWithErrorsOutput {
             /* BuilderGenerator.kt:481 */ greeting: self.greeting,
             /* BuilderGenerator.kt:477 */
-+
+        }
         /* BuilderGenerator.kt:253 */
-86
+    }
     /* BuilderGenerator.kt:355 */
-88
+}

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
--
 /// Types for the `EmptyInputOutput` operation.
 /* CodegenDelegator.kt:51 */
 /// /* CodegenDelegator.kt:51 */Types for the `EmptyInputOutput` operation.
 pub mod empty_input_output;
-5
 /// Types for the `Float16` operation.
 /// /* CodegenDelegator.kt:51 */Types for the `Float16` operation.
 pub mod float16;
-8
 /// Types for the `FractionalSeconds` operation.
 /// /* CodegenDelegator.kt:51 */Types for the `FractionalSeconds` operation.
 pub mod fractional_seconds;
-11
 /// Types for the `GreetingWithErrors` operation.
 /// /* CodegenDelegator.kt:51 */Types for the `GreetingWithErrors` operation.
 pub mod greeting_with_errors;
-14
 /// Types for the `NoInputOutput` operation.
 /// /* CodegenDelegator.kt:51 */Types for the `NoInputOutput` operation.
 pub mod no_input_output;
-17
 /// Types for the `OperationWithDefaults` operation.
 /// /* CodegenDelegator.kt:51 */Types for the `OperationWithDefaults` operation.
 pub mod operation_with_defaults;
-20
 /// Types for the `OptionalInputOutput` operation.
 /// /* CodegenDelegator.kt:51 */Types for the `OptionalInputOutput` operation.
 pub mod optional_input_output;
-23
 /// Types for the `RecursiveShapes` operation.
 /// /* CodegenDelegator.kt:51 */Types for the `RecursiveShapes` operation.
 pub mod recursive_shapes;
-26
 /// Types for the `RpcV2CborDenseMaps` operation.
 /// /* CodegenDelegator.kt:51 */Types for the `RpcV2CborDenseMaps` operation.
 pub mod rpc_v2_cbor_dense_maps;
-29
 /// Types for the `RpcV2CborLists` operation.
 /// /* CodegenDelegator.kt:51 */Types for the `RpcV2CborLists` operation.
 pub mod rpc_v2_cbor_lists;
-32
 /// Types for the `RpcV2CborSparseMaps` operation.
 /// /* CodegenDelegator.kt:51 */Types for the `RpcV2CborSparseMaps` operation.
 pub mod rpc_v2_cbor_sparse_maps;
-35
 /// Types for the `SimpleScalarProperties` operation.
 /// /* CodegenDelegator.kt:51 */Types for the `SimpleScalarProperties` operation.
 pub mod simple_scalar_properties;
-38
 /// Types for the `SparseNullsOperation` operation.
 /// /* CodegenDelegator.kt:51 */Types for the `SparseNullsOperation` operation.
 pub mod sparse_nulls_operation;

Client Test

Files changed:

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation.rs

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/empty_input_output.rs

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/empty_input_output/_empty_input_output_input.rs

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/empty_input_output/_empty_input_output_output.rs

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/empty_input_output/builders.rs

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/float16.rs

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/float16/_float16_input.rs

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/float16/_float16_output.rs

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/float16/builders.rs

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/fractional_seconds.rs

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/fractional_seconds/_fractional_seconds_input.rs

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/fractional_seconds/_fractional_seconds_output.rs

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/fractional_seconds/builders.rs

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/greeting_with_errors.rs

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/greeting_with_errors/_greeting_with_errors_input.rs

tmp-codegen-diff/codegen-client-test/rpcv2Cbor/rust-client-codegen/src/operation/greeting_with_errors/_greeting_with_errors_output.rs