Client Test

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/operation/constant_and_variable_query_string.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 `ConstantAndVariableQueryString`.
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* OperationGenerator.kt:84 */
 pub struct ConstantAndVariableQueryString;
 /* OperationGenerator.kt:85 */
 impl ConstantAndVariableQueryString {
     /// Creates a new `ConstantAndVariableQueryString`
     /// /* OperationGenerator.kt:86 */Creates a new `ConstantAndVariableQueryString`
     /* 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::constant_and_variable_query_string::ConstantAndVariableQueryStringInput,
     ) -> ::std::result::Result<
         crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringError,
             ::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::constant_and_variable_query_string::ConstantAndVariableQueryStringError>()
                     .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::constant_and_variable_query_string::ConstantAndVariableQueryStringOutput>()
                 .expect("correct output type"),
-47
+        )
-48
+    }
-49

@@ -63,72 +188,201 @@

↥ Expand context

         .instrument(::tracing::debug_span!(
             "Rest Json Protocol.ConstantAndVariableQueryString",
             "rpc.service" = "Rest Json Protocol",
             "rpc.method" = "ConstantAndVariableQueryString",
             "sdk_invocation_id" = ::fastrand::u32(1_000_000..10_000_000),
         ))
         .await
-79
+    }
-80
     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);
-93
+            }
             runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
                 config_override,
                 client_config.config.clone(),
                 &client_config.runtime_components,
             ));
-99
+        }
         runtime_plugins
-101
+    }
     /* OperationGenerator.kt:85 */
-103
+}
 /* OperationRuntimePluginGenerator.kt:55 */
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ConstantAndVariableQueryString {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         let mut cfg = ::aws_smithy_types::config_bag::Layer::new("ConstantAndVariableQueryString");
-108
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
             ConstantAndVariableQueryStringRequestSerializer,
         ));
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
             ConstantAndVariableQueryStringResponseDeserializer,
         ));
-115
         cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
             ::aws_smithy_runtime_api::client::auth::static_resolver::StaticAuthSchemeOptionResolverParams::new(),
         ));
-119
         cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
             "ConstantAndVariableQueryString",
             "Rest Json Protocol",
         ));
-124
         ::std::option::Option::Some(cfg.freeze())
-126
+    }
-127
     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("ConstantAndVariableQueryString")
             .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
             .with_interceptor(ConstantAndVariableQueryStringEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringError,
             >::new());
-142
         ::std::borrow::Cow::Owned(rcb)
-144
+    }
-145
+}
-146
 /* ResponseDeserializerGenerator.kt:64 */
 #[derive(Debug)]
 struct ConstantAndVariableQueryStringResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for ConstantAndVariableQueryStringResponseDeserializer {
     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;
-160
         let parse_result = if !success && status != 200 || force_error {
             crate::protocol_serde::shape_constant_and_variable_query_string::de_constant_and_variable_query_string_http_error(status, headers, body)
         } else {
             crate::protocol_serde::shape_constant_and_variable_query_string::de_constant_and_variable_query_string_http_response(
                 status, headers, body,
-166
+            )
         };
         crate::protocol_serde::type_erase_result(parse_result)
-169
+    }
-170
+}
 /* RequestSerializerGenerator.kt:67 */
 #[derive(Debug)]
 struct ConstantAndVariableQueryStringRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for ConstantAndVariableQueryStringRequestSerializer {
     #[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

↧ Expand context

             .downcast::<crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringInput>()
             .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::constant_and_variable_query_string::ConstantAndVariableQueryStringInput,
                 output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 use ::std::fmt::Write as _;
                 ::std::write!(output, "/ConstantAndVariableQueryString").expect("formatting should succeed");
                 ::std::result::Result::Ok(())
-196
+            }
             fn uri_query(
                 _input: &crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringInput,
                 mut output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 let mut query = ::aws_smithy_http::query::Writer::new(output);

@@ -190,203 +412,488 @@

↥ Expand context

                 if let ::std::option::Option::Some(inner_1) = &_input.baz {
-204
+                    {
                         query.push_kv("baz", &::aws_smithy_http::query::fmt_string(inner_1));
-206
+                    }
-207
+                }
                 if let ::std::option::Option::Some(inner_2) = &_input.maybe_set {
-209
+                    {
                         query.push_kv("maybeSet", &::aws_smithy_http::query::fmt_string(inner_2));
-211
+                    }
-212
+                }
                 ::std::result::Result::Ok(())
-214
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringInput,
                 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)?;
                 uri_query(input, &mut uri)?;

                 ::std::result::Result::Ok(builder.method("GET").uri(uri))
-224
+            }
             let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from("");
-229
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
-231
+    }
-232
+}
 /* EndpointParamsInterceptorGenerator.kt:86 */
 #[derive(Debug)]
 struct ConstantAndVariableQueryStringEndpointParamsInterceptor;
-236
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for ConstantAndVariableQueryStringEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "ConstantAndVariableQueryStringEndpointParamsInterceptor"
-240
+    }
-241
     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::<ConstantAndVariableQueryStringInput>()
             .ok_or("failed to downcast to ConstantAndVariableQueryStringInput")?;
-256
         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(())
-263
+    }
-264
+}
-265
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-268
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod constant_and_variable_query_string_test {
-275
     /// Mixes constant and variable query string parameters
     /// Test ID: RestJsonConstantAndVariableQueryStringMissingOneValue
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn rest_json_constant_and_variable_query_string_missing_one_value_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");
-283
         let client = crate::Client::from_conf(config_builder.http_client(http_client).build());
         let result = client
             .constant_and_variable_query_string()
             .set_baz(::std::option::Option::Some("bam".to_owned()))
             .send()
             .await;
         let _ = dbg!(result);
         let http_request = request_receiver.expect_request();
         let expected_query_params = &["foo=bar", "baz=bam"];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_query_string(&http_request, expected_query_params));
         let forbid_params = &["maybeSet"];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::forbid_query_params(&http_request, forbid_params));
         let body = http_request.body().bytes().expect("body should be strict");
         // No body.
         ::pretty_assertions::assert_eq!(&body, &bytes::Bytes::new());
         let uri: ::http::Uri = http_request.uri().parse().expect("invalid URI sent");
         ::pretty_assertions::assert_eq!(http_request.method(), "GET", "method was incorrect");
         ::pretty_assertions::assert_eq!(uri.path(), "/ConstantAndVariableQueryString", "path was incorrect");
-302
+    }
-303
     /// Mixes constant and variable query string parameters
     /// Test ID: RestJsonConstantAndVariableQueryStringAllValues
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn rest_json_constant_and_variable_query_string_all_values_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");
-311
         let client = crate::Client::from_conf(config_builder.http_client(http_client).build());
         let result = client
             .constant_and_variable_query_string()
             .set_baz(::std::option::Option::Some("bam".to_owned()))
             .set_maybe_set(::std::option::Option::Some("yes".to_owned()))
             .send()
             .await;
         let _ = dbg!(result);
         let http_request = request_receiver.expect_request();
         let expected_query_params = &["foo=bar", "baz=bam", "maybeSet=yes"];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_query_string(&http_request, expected_query_params));
         let body = http_request.body().bytes().expect("body should be strict");
         // No body.
         ::pretty_assertions::assert_eq!(&body, &bytes::Bytes::new());
         let uri: ::http::Uri = http_request.uri().parse().expect("invalid URI sent");
         ::pretty_assertions::assert_eq!(http_request.method(), "GET", "method was incorrect");
         ::pretty_assertions::assert_eq!(uri.path(), "/ConstantAndVariableQueryString", "path was incorrect");
-329
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-332
+}
-333
 /* OperationErrorGenerator.kt:79 */
 /// Error type for the `ConstantAndVariableQueryStringError` operation.
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::fmt::Debug)]
 pub enum ConstantAndVariableQueryStringError {
 pub /* OperationErrorGenerator.kt:81 */ enum ConstantAndVariableQueryStringError {
     /* 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()`:
-345
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-347
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-ConstantAndVariableQueryStringError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
     /* OperationErrorGenerator.kt:81 */
-351
+}
 /* OperationErrorGenerator.kt:218 */
 impl ConstantAndVariableQueryStringError {
     /* OperationErrorGenerator.kt:219 */
     /// Creates the `ConstantAndVariableQueryStringError::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(),
         })
-363
+    }
-364
     /// Creates the `ConstantAndVariableQueryStringError::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,
         })
-371
+    }
     ///
     /// /* 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 */
-382
+        }
         /* OperationErrorGenerator.kt:242 */
-384
+    }
     /* OperationErrorGenerator.kt:218 */
-386
+}
 /* OperationErrorGenerator.kt:269 */
 impl ::std::error::Error for ConstantAndVariableQueryStringError {
     /* 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 */
-399
+        }
         /* OperationErrorGenerator.kt:270 */
-401
+    }
     /* OperationErrorGenerator.kt:269 */
-403
+}
 /* OperationErrorGenerator.kt:133 */
 impl ::std::fmt::Display for ConstantAndVariableQueryStringError {
     /* 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")
-417
+                }
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-420
+        }
         /* OperationErrorGenerator.kt:134 */
-422
+    }
--
+    }
     /* OperationErrorGenerator.kt:133 */
-424
+}
 /* OperationErrorGenerator.kt:182 */
 impl ::aws_smithy_types::retry::ProvideErrorKind for ConstantAndVariableQueryStringError {
     /* OperationErrorGenerator.kt:186 */
     fn code(&self) -> ::std::option::Option<&str> {
         /* OperationErrorGenerator.kt:187 */
         ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
         /* OperationErrorGenerator.kt:186 */
-432
+    }
     /* 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 */
-438
+    }
     /* OperationErrorGenerator.kt:182 */
-440
+}
 /* OperationErrorGenerator.kt:163 */
 impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for ConstantAndVariableQueryStringError {
     /* 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 */
-453
+        }
         /* OperationErrorGenerator.kt:164 */
-455
+    }
     /* OperationErrorGenerator.kt:163 */
-457
+}
 /* OperationErrorGenerator.kt:109 */
 impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for ConstantAndVariableQueryStringError {
     /* 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 */
-471
+    }
     /* OperationErrorGenerator.kt:109 */
-473
+}
-474
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::constant_and_variable_query_string::_constant_and_variable_query_string_output::ConstantAndVariableQueryStringOutput;
-477
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::constant_and_variable_query_string::_constant_and_variable_query_string_input::ConstantAndVariableQueryStringInput;
-480
 /* RustModule.kt:172 */
 mod _constant_and_variable_query_string_input;
-483
 /* RustModule.kt:172 */
 mod _constant_and_variable_query_string_output;
-486
 /// Builders
 /// /* CodegenDelegator.kt:51 */Builders
 pub mod builders;

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/operation/constant_and_variable_query_string/_constant_and_variable_query_string_input.rs

@@ -1,1 +78,137 @@

 // 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 ConstantAndVariableQueryStringInput {
 pub /* StructureGenerator.kt:201 */ struct ConstantAndVariableQueryStringInput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
     pub baz: ::std::option::Option<::std::string::String>,
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
     pub maybe_set: ::std::option::Option<::std::string::String>,
     /* StructureGenerator.kt:201 */
-16
+}
 /* StructureGenerator.kt:135 */
 impl ConstantAndVariableQueryStringInput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
                            /* StructureGenerator.kt:166 */
     pub fn baz(&self) -> ::std::option::Option<&str> {
         /* StructureGenerator.kt:169 */
         self.baz.as_deref()
         /* StructureGenerator.kt:166 */
-26
+    }
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
                            /* StructureGenerator.kt:166 */
     pub fn maybe_set(&self) -> ::std::option::Option<&str> {
         /* StructureGenerator.kt:169 */
         self.maybe_set.as_deref()
         /* StructureGenerator.kt:166 */
-34
+    }
     /* StructureGenerator.kt:135 */
-36
+}
 /* ClientCodegenVisitor.kt:237 */
 impl ConstantAndVariableQueryStringInput {
     /// Creates a new builder-style object to manufacture [`ConstantAndVariableQueryStringInput`](crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringInput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`ConstantAndVariableQueryStringInput`](crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringInput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::constant_and_variable_query_string::builders::ConstantAndVariableQueryStringInputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::constant_and_variable_query_string::builders::ConstantAndVariableQueryStringInputBuilder::default()
         /* BuilderGenerator.kt:175 */
-45
+    }
     /* ClientCodegenVisitor.kt:237 */
-47
+}
-48
 /// A builder for [`ConstantAndVariableQueryStringInput`](crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringInput).
 /// /* BuilderGenerator.kt:342 */A builder for [`ConstantAndVariableQueryStringInput`](crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringInput).
 /* 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 ConstantAndVariableQueryStringInputBuilder {
     pub(crate) baz: ::std::option::Option<::std::string::String>,
     pub(crate) maybe_set: ::std::option::Option<::std::string::String>,
     /* BuilderGenerator.kt:275 */ pub(crate) baz: ::std::option::Option<::std::string::String>,
     /* BuilderGenerator.kt:275 */ pub(crate) maybe_set: ::std::option::Option<::std::string::String>,
     /* BuilderGenerator.kt:345 */
-59
+}
 /* BuilderGenerator.kt:355 */
 impl ConstantAndVariableQueryStringInputBuilder {
     /* BuilderGenerator.kt:286 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:291 */
     pub fn baz(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
         /* BuilderGenerator.kt:292 */
         self.baz = ::std::option::Option::Some(input.into());
         /* BuilderGenerator.kt:293 */
         self
         /* BuilderGenerator.kt:291 */
-71
+    }
     /* BuilderGenerator.kt:312 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:314 */
     pub fn set_baz(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
         /* BuilderGenerator.kt:315 */
         self.baz = input;
         self
         /* BuilderGenerator.kt:314 */
-80
+    }
     /* BuilderGenerator.kt:334 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:336 */
     pub fn get_baz(&self) -> &::std::option::Option<::std::string::String> {
         /* BuilderGenerator.kt:337 */
         &self.baz
         /* BuilderGenerator.kt:336 */
-88
+    }
     /* BuilderGenerator.kt:286 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:291 */
     pub fn maybe_set(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
         /* BuilderGenerator.kt:292 */
         self.maybe_set = ::std::option::Option::Some(input.into());
         /* BuilderGenerator.kt:293 */
         self
         /* BuilderGenerator.kt:291 */
-98
+    }
     /* BuilderGenerator.kt:312 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:314 */
     pub fn set_maybe_set(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
         /* BuilderGenerator.kt:315 */
         self.maybe_set = input;
         self
         /* BuilderGenerator.kt:314 */
-107
+    }
     /* BuilderGenerator.kt:334 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:336 */
     pub fn get_maybe_set(&self) -> &::std::option::Option<::std::string::String> {
         /* BuilderGenerator.kt:337 */
         &self.maybe_set
         /* BuilderGenerator.kt:336 */
-115
+    }
     /// Consumes the builder and constructs a [`ConstantAndVariableQueryStringInput`](crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringInput).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`ConstantAndVariableQueryStringInput`](crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringInput).
     /* BuilderGenerator.kt:253 */
     pub fn build(
         self,
     ) -> ::std::result::Result<
         crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringInput,
         ::aws_smithy_types::error::operation::BuildError,
     > {
         /* BuilderGenerator.kt:254 */
         ::std::result::Result::Ok(
             /* BuilderGenerator.kt:477 */
             crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringInput {
                 baz: self.baz,
                 /* BuilderGenerator.kt:481 */ baz: self.baz,
                 /* BuilderGenerator.kt:481 */
                 maybe_set: self.maybe_set,
             },
                 /* BuilderGenerator.kt:477 */
             }, /* BuilderGenerator.kt:254 */
-133
+        )
         /* BuilderGenerator.kt:253 */
-135
+    }
     /* BuilderGenerator.kt:355 */
-137
+}

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/operation/constant_and_variable_query_string/_constant_and_variable_query_string_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 ConstantAndVariableQueryStringOutput {}
 pub /* StructureGenerator.kt:201 */ struct ConstantAndVariableQueryStringOutput {/* StructureGenerator.kt:201 */}
 /* ClientCodegenVisitor.kt:237 */
 impl ConstantAndVariableQueryStringOutput {
     /// Creates a new builder-style object to manufacture [`ConstantAndVariableQueryStringOutput`](crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringOutput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`ConstantAndVariableQueryStringOutput`](crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringOutput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::constant_and_variable_query_string::builders::ConstantAndVariableQueryStringOutputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::constant_and_variable_query_string::builders::ConstantAndVariableQueryStringOutputBuilder::default()
         /* BuilderGenerator.kt:175 */
-17
+    }
     /* ClientCodegenVisitor.kt:237 */
-19
+}
-20
 /// A builder for [`ConstantAndVariableQueryStringOutput`](crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringOutput).
 /// /* BuilderGenerator.kt:342 */A builder for [`ConstantAndVariableQueryStringOutput`](crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringOutput).
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 pub struct ConstantAndVariableQueryStringOutputBuilder {}
 /* BuilderGenerator.kt:345 */
 pub struct ConstantAndVariableQueryStringOutputBuilder {/* BuilderGenerator.kt:345 */}
 /* BuilderGenerator.kt:355 */
 impl ConstantAndVariableQueryStringOutputBuilder {
     /// Consumes the builder and constructs a [`ConstantAndVariableQueryStringOutput`](crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringOutput).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`ConstantAndVariableQueryStringOutput`](crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringOutput).
     /* BuilderGenerator.kt:253 */
     pub fn build(self) -> crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringOutput {
         crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringOutput {}
         /* BuilderGenerator.kt:477 */
         crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringOutput {
         /* BuilderGenerator.kt:477 */}
         /* BuilderGenerator.kt:253 */
-37
+    }
     /* BuilderGenerator.kt:355 */
-39
+}

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/operation/constant_and_variable_query_string/builders.rs

@@ -1,1 +139,163 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::constant_and_variable_query_string::_constant_and_variable_query_string_output::ConstantAndVariableQueryStringOutputBuilder;
-4
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::constant_and_variable_query_string::_constant_and_variable_query_string_input::ConstantAndVariableQueryStringInputBuilder;
-7
 /* FluentBuilderGenerator.kt:408 */
 impl crate::operation::constant_and_variable_query_string::builders::ConstantAndVariableQueryStringInputBuilder {
     /// Sends a request with this input using the given client.
     pub async fn send_with(
         self,
         client: &crate::Client,
     ) -> ::std::result::Result<
         crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {
         let mut fluent_builder = client.constant_and_variable_query_string();
         fluent_builder.inner = self;
         fluent_builder.send().await
-24
+    }
-25
+}
 /// Fluent builder constructing a request to `ConstantAndVariableQueryString`.
 /// /* FluentBuilderGenerator.kt:129 */Fluent builder constructing a request to `ConstantAndVariableQueryString`.
 ///
 /// This example uses fixed query string params and variable query string params. The fixed query string parameters and variable parameters must both be serialized (implementations may need to merge them together).
 /// /* FluentBuilderGenerator.kt:130 */This example uses fixed query string params and variable query string params. The fixed query string parameters and variable parameters must both be serialized (implementations may need to merge them together).
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::fmt::Debug)]
 /* FluentBuilderGenerator.kt:270 */
 pub struct ConstantAndVariableQueryStringFluentBuilder {
     handle: ::std::sync::Arc<crate::client::Handle>,
     inner: crate::operation::constant_and_variable_query_string::builders::ConstantAndVariableQueryStringInputBuilder,
     config_override: ::std::option::Option<crate::config::Builder>,
-36
+}
 /* FluentBuilderGenerator.kt:381 */
 impl
     crate::client::customize::internal::CustomizableSend<
         crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringOutput,
         crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringError,
     > for ConstantAndVariableQueryStringFluentBuilder
-43
+{
     fn send(
         self,
         config_override: crate::config::Builder,
     ) -> crate::client::customize::internal::BoxFuture<
         crate::client::customize::internal::SendResult<
             crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringOutput,
             crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringError,
         >,
     > {
         ::std::boxed::Box::pin(async move { self.config_override(config_override).send().await })
-54
+    }
-55
+}
 /* FluentBuilderGenerator.kt:282 */
 impl ConstantAndVariableQueryStringFluentBuilder {
     /* FluentBuilderGenerator.kt:288 */
     /// Creates a new `ConstantAndVariableQueryStringFluentBuilder`.
     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,
-65
+        }
-66
+    }
     /* FluentBuilderGenerator.kt:301 */
     /// Access the ConstantAndVariableQueryString as a reference.
     pub fn as_input(&self) -> &crate::operation::constant_and_variable_query_string::builders::ConstantAndVariableQueryStringInputBuilder {
         &self.inner
-71
+    }
     /* 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::constant_and_variable_query_string::ConstantAndVariableQueryStringOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringError,
             ::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::constant_and_variable_query_string::ConstantAndVariableQueryString::operation_runtime_plugins(
             self.handle.runtime_plugins.clone(),
             &self.handle.conf,
             self.config_override,
         );
         crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryString::orchestrate(&runtime_plugins, input).await
-100
+    }
-101
     /// Consumes this builder, creating a customizable operation that can be modified before being sent.
     pub fn customize(
         self,
     ) -> crate::client::customize::CustomizableOperation<
         crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringOutput,
         crate::operation::constant_and_variable_query_string::ConstantAndVariableQueryStringError,
         Self,
     > {
         crate::client::customize::CustomizableOperation::new(self)
-111
+    }
     /* 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
-116
+    }
-117
     pub(crate) fn set_config_override(&mut self, config_override: ::std::option::Option<crate::config::Builder>) -> &mut Self {
         self.config_override = config_override;
         self
-121
+    }
     /* FluentBuilderGenerator.kt:498 */
     #[allow(missing_docs)] // documentation missing in model
                            /* FluentBuilderGenerator.kt:500 */
     pub fn baz(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
         self.inner = self.inner.baz(input.into());
         self
-128
+    }
     /* FluentBuilderGenerator.kt:498 */
     #[allow(missing_docs)] // documentation missing in model
                            /* FluentBuilderGenerator.kt:500 */
     pub fn set_baz(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
         self.inner = self.inner.set_baz(input);
         self
-135
+    }
     /* FluentBuilderGenerator.kt:518 */
     #[allow(missing_docs)] // documentation missing in model
                            /* FluentBuilderGenerator.kt:520 */
     pub fn get_baz(&self) -> &::std::option::Option<::std::string::String> {
         self.inner.get_baz()
-141
+    }
     /* FluentBuilderGenerator.kt:498 */
     #[allow(missing_docs)] // documentation missing in model
                            /* FluentBuilderGenerator.kt:500 */
     pub fn maybe_set(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
         self.inner = self.inner.maybe_set(input.into());
         self
-148
+    }
     /* FluentBuilderGenerator.kt:498 */
     #[allow(missing_docs)] // documentation missing in model
                            /* FluentBuilderGenerator.kt:500 */
     pub fn set_maybe_set(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
         self.inner = self.inner.set_maybe_set(input);
         self
-155
+    }
     /* FluentBuilderGenerator.kt:518 */
     #[allow(missing_docs)] // documentation missing in model
                            /* FluentBuilderGenerator.kt:520 */
     pub fn get_maybe_set(&self) -> &::std::option::Option<::std::string::String> {
         self.inner.get_maybe_set()
-161
+    }
     /* FluentBuilderGenerator.kt:282 */
-163
+}

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/operation/constant_query_string.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 `ConstantQueryString`.
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* OperationGenerator.kt:84 */
 pub struct ConstantQueryString;
 /* OperationGenerator.kt:85 */
 impl ConstantQueryString {
     /// Creates a new `ConstantQueryString`
     /// /* OperationGenerator.kt:86 */Creates a new `ConstantQueryString`
     /* 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::constant_query_string::ConstantQueryStringInput,
     ) -> ::std::result::Result<
         crate::operation::constant_query_string::ConstantQueryStringOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::constant_query_string::ConstantQueryStringError,
             ::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::constant_query_string::ConstantQueryStringError>()
                     .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::constant_query_string::ConstantQueryStringOutput>()
                 .expect("correct output type"),
-47
+        )
-48
+    }
-49

@@ -63,72 +186,199 @@

↥ Expand context

         .instrument(::tracing::debug_span!(
             "Rest Json Protocol.ConstantQueryString",
             "rpc.service" = "Rest Json Protocol",
             "rpc.method" = "ConstantQueryString",
             "sdk_invocation_id" = ::fastrand::u32(1_000_000..10_000_000),
         ))
         .await
-79
+    }
-80
     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);
-93
+            }
             runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
                 config_override,
                 client_config.config.clone(),
                 &client_config.runtime_components,
             ));
-99
+        }
         runtime_plugins
-101
+    }
     /* OperationGenerator.kt:85 */
-103
+}
 /* OperationRuntimePluginGenerator.kt:55 */
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ConstantQueryString {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         let mut cfg = ::aws_smithy_types::config_bag::Layer::new("ConstantQueryString");
-108
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
             ConstantQueryStringRequestSerializer,
         ));
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
             ConstantQueryStringResponseDeserializer,
         ));
-115
         cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
             ::aws_smithy_runtime_api::client::auth::static_resolver::StaticAuthSchemeOptionResolverParams::new(),
         ));
-119
         cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
             "ConstantQueryString",
             "Rest Json Protocol",
         ));
-124
         ::std::option::Option::Some(cfg.freeze())
-126
+    }
-127
     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("ConstantQueryString")
             .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
             .with_interceptor(ConstantQueryStringEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::constant_query_string::ConstantQueryStringError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::constant_query_string::ConstantQueryStringError,
             >::new());
-142
         ::std::borrow::Cow::Owned(rcb)
-144
+    }
-145
+}
-146
 /* ResponseDeserializerGenerator.kt:64 */
 #[derive(Debug)]
 struct ConstantQueryStringResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for ConstantQueryStringResponseDeserializer {
     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;
-160
         let parse_result = if !success && status != 200 || force_error {
             crate::protocol_serde::shape_constant_query_string::de_constant_query_string_http_error(status, headers, body)
         } else {
             crate::protocol_serde::shape_constant_query_string::de_constant_query_string_http_response(status, headers, body)
         };
         crate::protocol_serde::type_erase_result(parse_result)
-167
+    }
-168
+}
 /* RequestSerializerGenerator.kt:67 */
 #[derive(Debug)]
 struct ConstantQueryStringRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for ConstantQueryStringRequestSerializer {
     #[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

↧ Expand context

             .downcast::<crate::operation::constant_query_string::ConstantQueryStringInput>()
             .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::constant_query_string::ConstantQueryStringInput,
                 output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 use ::std::fmt::Write as _;
                 let input_1 = &_input.hello;
                 let input_1 = input_1
                     .as_ref()
                     .ok_or_else(|| ::aws_smithy_types::error::operation::BuildError::missing_field("hello", "cannot be empty or unset"))?;
                 let hello = ::aws_smithy_http::label::fmt_string(input_1, ::aws_smithy_http::label::EncodingStrategy::Default);
                 if hello.is_empty() {
                     return ::std::result::Result::Err(::aws_smithy_types::error::operation::BuildError::missing_field(
                         "hello",

@@ -190,203 +383,459 @@

↥ Expand context

                 ::std::write!(output, "/ConstantQueryString/{hello}", hello = hello).expect("formatting should succeed");
                 ::std::result::Result::Ok(())
-205
+            }
             fn uri_query(
                 _input: &crate::operation::constant_query_string::ConstantQueryStringInput,
                 mut output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 let mut query = ::aws_smithy_http::query::Writer::new(output);
                 query.push_kv("foo", "bar");
                 query.push_v("hello");
                 ::std::result::Result::Ok(())
-214
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::constant_query_string::ConstantQueryStringInput,
                 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)?;
                 uri_query(input, &mut uri)?;

                 ::std::result::Result::Ok(builder.method("GET").uri(uri))
-224
+            }
             let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from("");
-229
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
-231
+    }
-232
+}
 /* EndpointParamsInterceptorGenerator.kt:86 */
 #[derive(Debug)]
 struct ConstantQueryStringEndpointParamsInterceptor;
-236
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for ConstantQueryStringEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "ConstantQueryStringEndpointParamsInterceptor"
-240
+    }
-241
     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::<ConstantQueryStringInput>()
             .ok_or("failed to downcast to ConstantQueryStringInput")?;
-256
         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(())
-263
+    }
-264
+}
-265
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-268
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod constant_query_string_test {
-275
     /// Includes constant query string parameters
     /// Test ID: RestJsonConstantQueryString
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn rest_json_constant_query_string_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");
-283
         let client = crate::Client::from_conf(config_builder.http_client(http_client).build());
         let result = client
             .constant_query_string()
             .set_hello(::std::option::Option::Some("hi".to_owned()))
             .send()
             .await;
         let _ = dbg!(result);
         let http_request = request_receiver.expect_request();
         let expected_query_params = &["foo=bar", "hello"];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_query_string(&http_request, expected_query_params));
         let body = http_request.body().bytes().expect("body should be strict");
         // No body.
         ::pretty_assertions::assert_eq!(&body, &bytes::Bytes::new());
         let uri: ::http::Uri = http_request.uri().parse().expect("invalid URI sent");
         ::pretty_assertions::assert_eq!(http_request.method(), "GET", "method was incorrect");
         ::pretty_assertions::assert_eq!(uri.path(), "/ConstantQueryString/hi", "path was incorrect");
-300
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-303
+}
-304
 /* OperationErrorGenerator.kt:79 */
 /// Error type for the `ConstantQueryStringError` operation.
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::fmt::Debug)]
 pub enum ConstantQueryStringError {
 pub /* OperationErrorGenerator.kt:81 */ enum ConstantQueryStringError {
     /* 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()`:
-316
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-318
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-ConstantQueryStringError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
     /* OperationErrorGenerator.kt:81 */
-322
+}
 /* OperationErrorGenerator.kt:218 */
 impl ConstantQueryStringError {
     /* OperationErrorGenerator.kt:219 */
     /// Creates the `ConstantQueryStringError::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(),
         })
-334
+    }
-335
     /// Creates the `ConstantQueryStringError::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,
         })
-342
+    }
     ///
     /// /* 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 */
-353
+        }
         /* OperationErrorGenerator.kt:242 */
-355
+    }
     /* OperationErrorGenerator.kt:218 */
-357
+}
 /* OperationErrorGenerator.kt:269 */
 impl ::std::error::Error for ConstantQueryStringError {
     /* 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 */
-370
+        }
         /* OperationErrorGenerator.kt:270 */
-372
+    }
     /* OperationErrorGenerator.kt:269 */
-374
+}
 /* OperationErrorGenerator.kt:133 */
 impl ::std::fmt::Display for ConstantQueryStringError {
     /* 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")
-388
+                }
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-391
+        }
         /* OperationErrorGenerator.kt:134 */
-393
+    }
--
+    }
     /* OperationErrorGenerator.kt:133 */
-395
+}
 /* OperationErrorGenerator.kt:182 */
 impl ::aws_smithy_types::retry::ProvideErrorKind for ConstantQueryStringError {
     /* OperationErrorGenerator.kt:186 */
     fn code(&self) -> ::std::option::Option<&str> {
         /* OperationErrorGenerator.kt:187 */
         ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
         /* OperationErrorGenerator.kt:186 */
-403
+    }
     /* 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 */
-409
+    }
     /* OperationErrorGenerator.kt:182 */
-411
+}
 /* OperationErrorGenerator.kt:163 */
 impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for ConstantQueryStringError {
     /* 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 */
-424
+        }
         /* OperationErrorGenerator.kt:164 */
-426
+    }
     /* OperationErrorGenerator.kt:163 */
-428
+}
 /* OperationErrorGenerator.kt:109 */
 impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for ConstantQueryStringError {
     /* 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 */
-442
+    }
     /* OperationErrorGenerator.kt:109 */
-444
+}
-445
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::constant_query_string::_constant_query_string_output::ConstantQueryStringOutput;
-448
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::constant_query_string::_constant_query_string_input::ConstantQueryStringInput;
-451
 /* RustModule.kt:172 */
 mod _constant_query_string_input;
-454
 /* RustModule.kt:172 */
 mod _constant_query_string_output;
-457
 /// Builders
 /// /* CodegenDelegator.kt:51 */Builders
 pub mod builders;

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/operation/constant_query_string/_constant_query_string_input.rs

@@ -1,1 +51,95 @@

 // 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 ConstantQueryStringInput {
 pub /* StructureGenerator.kt:201 */ struct ConstantQueryStringInput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
     pub hello: ::std::option::Option<::std::string::String>,
     /* StructureGenerator.kt:201 */
-13
+}
 /* StructureGenerator.kt:135 */
 impl ConstantQueryStringInput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
                            /* StructureGenerator.kt:166 */
     pub fn hello(&self) -> ::std::option::Option<&str> {
         /* StructureGenerator.kt:169 */
         self.hello.as_deref()
         /* StructureGenerator.kt:166 */
-23
+    }
     /* StructureGenerator.kt:135 */
-25
+}
 /* ClientCodegenVisitor.kt:237 */
 impl ConstantQueryStringInput {
     /// Creates a new builder-style object to manufacture [`ConstantQueryStringInput`](crate::operation::constant_query_string::ConstantQueryStringInput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`ConstantQueryStringInput`](crate::operation::constant_query_string::ConstantQueryStringInput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::constant_query_string::builders::ConstantQueryStringInputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::constant_query_string::builders::ConstantQueryStringInputBuilder::default()
         /* BuilderGenerator.kt:175 */
-34
+    }
     /* ClientCodegenVisitor.kt:237 */
-36
+}
-37
 /// A builder for [`ConstantQueryStringInput`](crate::operation::constant_query_string::ConstantQueryStringInput).
 /// /* BuilderGenerator.kt:342 */A builder for [`ConstantQueryStringInput`](crate::operation::constant_query_string::ConstantQueryStringInput).
 /* 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 ConstantQueryStringInputBuilder {
     pub(crate) hello: ::std::option::Option<::std::string::String>,
     /* BuilderGenerator.kt:275 */ pub(crate) hello: ::std::option::Option<::std::string::String>,
     /* BuilderGenerator.kt:345 */
-47
+}
 /* BuilderGenerator.kt:355 */
 impl ConstantQueryStringInputBuilder {
     /* BuilderGenerator.kt:286 */
     #[allow(missing_docs)] // documentation missing in model
     /// This field is required.
     /// /* BuilderGenerator.kt:288 */This field is required.
     /* BuilderGenerator.kt:291 */
     pub fn hello(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
         /* BuilderGenerator.kt:292 */
         self.hello = ::std::option::Option::Some(input.into());
         /* BuilderGenerator.kt:293 */
         self
         /* BuilderGenerator.kt:291 */
-60
+    }
     /* BuilderGenerator.kt:312 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:314 */
     pub fn set_hello(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
         /* BuilderGenerator.kt:315 */
         self.hello = input;
         self
         /* BuilderGenerator.kt:314 */
-69
+    }
     /* BuilderGenerator.kt:334 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:336 */
     pub fn get_hello(&self) -> &::std::option::Option<::std::string::String> {
         /* BuilderGenerator.kt:337 */
         &self.hello
         /* BuilderGenerator.kt:336 */
-77
+    }
     /// Consumes the builder and constructs a [`ConstantQueryStringInput`](crate::operation::constant_query_string::ConstantQueryStringInput).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`ConstantQueryStringInput`](crate::operation::constant_query_string::ConstantQueryStringInput).
     /* BuilderGenerator.kt:253 */
     pub fn build(
         self,
     ) -> ::std::result::Result<crate::operation::constant_query_string::ConstantQueryStringInput, ::aws_smithy_types::error::operation::BuildError>
-83
+    {
         ::std::result::Result::Ok(crate::operation::constant_query_string::ConstantQueryStringInput { hello: self.hello })
         /* BuilderGenerator.kt:254 */
         ::std::result::Result::Ok(
             /* BuilderGenerator.kt:477 */
             crate::operation::constant_query_string::ConstantQueryStringInput {
                 /* BuilderGenerator.kt:481 */ hello: self.hello,
                 /* BuilderGenerator.kt:477 */
             }, /* BuilderGenerator.kt:254 */
-+
+        )
         /* BuilderGenerator.kt:253 */
-93
+    }
     /* BuilderGenerator.kt:355 */
-95
+}

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/operation/constant_query_string/_constant_query_string_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 ConstantQueryStringOutput {}
 pub /* StructureGenerator.kt:201 */ struct ConstantQueryStringOutput {/* StructureGenerator.kt:201 */}
 /* ClientCodegenVisitor.kt:237 */
 impl ConstantQueryStringOutput {
     /// Creates a new builder-style object to manufacture [`ConstantQueryStringOutput`](crate::operation::constant_query_string::ConstantQueryStringOutput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`ConstantQueryStringOutput`](crate::operation::constant_query_string::ConstantQueryStringOutput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::constant_query_string::builders::ConstantQueryStringOutputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::constant_query_string::builders::ConstantQueryStringOutputBuilder::default()
         /* BuilderGenerator.kt:175 */
-17
+    }
     /* ClientCodegenVisitor.kt:237 */
-19
+}
-20
 /// A builder for [`ConstantQueryStringOutput`](crate::operation::constant_query_string::ConstantQueryStringOutput).
 /// /* BuilderGenerator.kt:342 */A builder for [`ConstantQueryStringOutput`](crate::operation::constant_query_string::ConstantQueryStringOutput).
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 pub struct ConstantQueryStringOutputBuilder {}
 /* BuilderGenerator.kt:345 */
 pub struct ConstantQueryStringOutputBuilder {/* BuilderGenerator.kt:345 */}
 /* BuilderGenerator.kt:355 */
 impl ConstantQueryStringOutputBuilder {
     /// Consumes the builder and constructs a [`ConstantQueryStringOutput`](crate::operation::constant_query_string::ConstantQueryStringOutput).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`ConstantQueryStringOutput`](crate::operation::constant_query_string::ConstantQueryStringOutput).
     /* BuilderGenerator.kt:253 */
     pub fn build(self) -> crate::operation::constant_query_string::ConstantQueryStringOutput {
         crate::operation::constant_query_string::ConstantQueryStringOutput {}
         /* BuilderGenerator.kt:477 */
         crate::operation::constant_query_string::ConstantQueryStringOutput {
         /* BuilderGenerator.kt:477 */}
         /* BuilderGenerator.kt:253 */
-37
+    }
     /* BuilderGenerator.kt:355 */
-39
+}

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/operation/constant_query_string/builders.rs

@@ -1,1 +125,143 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::constant_query_string::_constant_query_string_output::ConstantQueryStringOutputBuilder;
-4
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::constant_query_string::_constant_query_string_input::ConstantQueryStringInputBuilder;
-7
 /* FluentBuilderGenerator.kt:408 */
 impl crate::operation::constant_query_string::builders::ConstantQueryStringInputBuilder {
     /// Sends a request with this input using the given client.
     pub async fn send_with(
         self,
         client: &crate::Client,
     ) -> ::std::result::Result<
         crate::operation::constant_query_string::ConstantQueryStringOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::constant_query_string::ConstantQueryStringError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {
         let mut fluent_builder = client.constant_query_string();
         fluent_builder.inner = self;
         fluent_builder.send().await
-24
+    }
-25
+}
 /// Fluent builder constructing a request to `ConstantQueryString`.
 /// /* FluentBuilderGenerator.kt:129 */Fluent builder constructing a request to `ConstantQueryString`.
 ///
 /// This example uses a constant query string parameters and a label. This simply tests that labels and query string parameters are compatible. The fixed query string parameter named "hello" should in no way conflict with the label, `{hello}`.
 /// /* FluentBuilderGenerator.kt:130 */This example uses a constant query string parameters and a label. This simply tests that labels and query string parameters are compatible. The fixed query string parameter named "hello" should in no way conflict with the label, `{hello}`.
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::fmt::Debug)]
 /* FluentBuilderGenerator.kt:270 */
 pub struct ConstantQueryStringFluentBuilder {
     handle: ::std::sync::Arc<crate::client::Handle>,
     inner: crate::operation::constant_query_string::builders::ConstantQueryStringInputBuilder,
     config_override: ::std::option::Option<crate::config::Builder>,
-36
+}
 /* FluentBuilderGenerator.kt:381 */
 impl
     crate::client::customize::internal::CustomizableSend<
         crate::operation::constant_query_string::ConstantQueryStringOutput,
         crate::operation::constant_query_string::ConstantQueryStringError,
     > for ConstantQueryStringFluentBuilder
-43
+{
     fn send(
         self,
         config_override: crate::config::Builder,
     ) -> crate::client::customize::internal::BoxFuture<
         crate::client::customize::internal::SendResult<
             crate::operation::constant_query_string::ConstantQueryStringOutput,
             crate::operation::constant_query_string::ConstantQueryStringError,
         >,
     > {
         ::std::boxed::Box::pin(async move { self.config_override(config_override).send().await })
-54
+    }
-55
+}
 /* FluentBuilderGenerator.kt:282 */
 impl ConstantQueryStringFluentBuilder {
     /* FluentBuilderGenerator.kt:288 */
     /// Creates a new `ConstantQueryStringFluentBuilder`.
     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,
-65
+        }
-66
+    }
     /* FluentBuilderGenerator.kt:301 */
     /// Access the ConstantQueryString as a reference.
     pub fn as_input(&self) -> &crate::operation::constant_query_string::builders::ConstantQueryStringInputBuilder {
         &self.inner
-71
+    }
     /* 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::constant_query_string::ConstantQueryStringOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::constant_query_string::ConstantQueryStringError,
             ::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::constant_query_string::ConstantQueryString::operation_runtime_plugins(
             self.handle.runtime_plugins.clone(),
             &self.handle.conf,
             self.config_override,
         );
         crate::operation::constant_query_string::ConstantQueryString::orchestrate(&runtime_plugins, input).await
-100
+    }
-101
     /// Consumes this builder, creating a customizable operation that can be modified before being sent.
     pub fn customize(
         self,
     ) -> crate::client::customize::CustomizableOperation<
         crate::operation::constant_query_string::ConstantQueryStringOutput,
         crate::operation::constant_query_string::ConstantQueryStringError,
         Self,
     > {
         crate::client::customize::CustomizableOperation::new(self)
-111
+    }
     /* 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
-116
+    }
-117
     pub(crate) fn set_config_override(&mut self, config_override: ::std::option::Option<crate::config::Builder>) -> &mut Self {
         self.config_override = config_override;
         self
-121
+    }
     /* FluentBuilderGenerator.kt:498 */
     #[allow(missing_docs)] // documentation missing in model
                            /* FluentBuilderGenerator.kt:500 */
     pub fn hello(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
         self.inner = self.inner.hello(input.into());
         self
-128
+    }
     /* FluentBuilderGenerator.kt:498 */
     #[allow(missing_docs)] // documentation missing in model
                            /* FluentBuilderGenerator.kt:500 */
     pub fn set_hello(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
         self.inner = self.inner.set_hello(input);
         self
-135
+    }
     /* FluentBuilderGenerator.kt:518 */
     #[allow(missing_docs)] // documentation missing in model
                            /* FluentBuilderGenerator.kt:520 */
     pub fn get_hello(&self) -> &::std::option::Option<::std::string::String> {
         self.inner.get_hello()
-141
+    }
     /* FluentBuilderGenerator.kt:282 */
-143
+}

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/operation/content_type_parameters.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 `ContentTypeParameters`.
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* OperationGenerator.kt:84 */
 pub struct ContentTypeParameters;
 /* OperationGenerator.kt:85 */
 impl ContentTypeParameters {
     /// Creates a new `ContentTypeParameters`
     /// /* OperationGenerator.kt:86 */Creates a new `ContentTypeParameters`
     /* 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::content_type_parameters::ContentTypeParametersInput,
     ) -> ::std::result::Result<
         crate::operation::content_type_parameters::ContentTypeParametersOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::content_type_parameters::ContentTypeParametersError,
             ::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::content_type_parameters::ContentTypeParametersError>()
                     .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::content_type_parameters::ContentTypeParametersOutput>()
                 .expect("correct output type"),
-47
+        )
-48
+    }
-49

@@ -63,72 +337,408 @@

↥ Expand context

         .instrument(::tracing::debug_span!(
             "Rest Json Protocol.ContentTypeParameters",
             "rpc.service" = "Rest Json Protocol",
             "rpc.method" = "ContentTypeParameters",
             "sdk_invocation_id" = ::fastrand::u32(1_000_000..10_000_000),
         ))
         .await
-79
+    }
-80
     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);
-93
+            }
             runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
                 config_override,
                 client_config.config.clone(),
                 &client_config.runtime_components,
             ));
-99
+        }
         runtime_plugins
-101
+    }
     /* OperationGenerator.kt:85 */
-103
+}
 /* OperationRuntimePluginGenerator.kt:55 */
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ContentTypeParameters {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         let mut cfg = ::aws_smithy_types::config_bag::Layer::new("ContentTypeParameters");
-108
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
             ContentTypeParametersRequestSerializer,
         ));
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
             ContentTypeParametersResponseDeserializer,
         ));
-115
         cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
             ::aws_smithy_runtime_api::client::auth::static_resolver::StaticAuthSchemeOptionResolverParams::new(),
         ));
-119
         cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
             "ContentTypeParameters",
             "Rest Json Protocol",
         ));
-124
         ::std::option::Option::Some(cfg.freeze())
-126
+    }
-127
     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("ContentTypeParameters")
             .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
             .with_interceptor(ContentTypeParametersEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::content_type_parameters::ContentTypeParametersError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::content_type_parameters::ContentTypeParametersError,
             >::new());
-142
         ::std::borrow::Cow::Owned(rcb)
-144
+    }
-145
+}
-146
 /* ResponseDeserializerGenerator.kt:64 */
 #[derive(Debug)]
 struct ContentTypeParametersResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for ContentTypeParametersResponseDeserializer {
     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;
-160
         let parse_result = if !success && status != 200 || force_error {
             crate::protocol_serde::shape_content_type_parameters::de_content_type_parameters_http_error(status, headers, body)
         } else {
             crate::protocol_serde::shape_content_type_parameters::de_content_type_parameters_http_response(status, headers, body)
         };
         crate::protocol_serde::type_erase_result(parse_result)
-167
+    }
-168
+}
 /* RequestSerializerGenerator.kt:67 */
 #[derive(Debug)]
 struct ContentTypeParametersRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for ContentTypeParametersRequestSerializer {
     #[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::content_type_parameters::ContentTypeParametersInput>()
             .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::content_type_parameters::ContentTypeParametersInput,
                 output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 use ::std::fmt::Write as _;
                 ::std::write!(output, "/ContentTypeParameters").expect("formatting should succeed");
                 ::std::result::Result::Ok(())
-194
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::content_type_parameters::ContentTypeParametersInput,
                 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))
-203
+            }
             let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
             builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/json");
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_content_type_parameters::ser_content_type_parameters_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);
-214
+        }
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
-216
+    }
-217
+}
 /* EndpointParamsInterceptorGenerator.kt:86 */
 #[derive(Debug)]
 struct ContentTypeParametersEndpointParamsInterceptor;
-221
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for ContentTypeParametersEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "ContentTypeParametersEndpointParamsInterceptor"
-225
+    }
-226
     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::<ContentTypeParametersInput>()
             .ok_or("failed to downcast to ContentTypeParametersInput")?;
-241
         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(())
-248
+    }
-249
+}
-250
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-253
 /* OperationErrorGenerator.kt:79 */
 /// Error type for the `ContentTypeParametersError` operation.
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::fmt::Debug)]
 pub enum ContentTypeParametersError {
 pub /* OperationErrorGenerator.kt:81 */ enum ContentTypeParametersError {
     /* 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()`:
-265
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-267
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-ContentTypeParametersError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
     /* OperationErrorGenerator.kt:81 */
-271
+}
 /* OperationErrorGenerator.kt:218 */
 impl ContentTypeParametersError {
     /* OperationErrorGenerator.kt:219 */
     /// Creates the `ContentTypeParametersError::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(),
         })
-283
+    }
-284
     /// Creates the `ContentTypeParametersError::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,
         })
-291
+    }
     ///
     /// /* 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 */
-302
+        }
         /* OperationErrorGenerator.kt:242 */
-304
+    }
     /* OperationErrorGenerator.kt:218 */
-306
+}
 /* OperationErrorGenerator.kt:269 */
 impl ::std::error::Error for ContentTypeParametersError {
     /* 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 */
-319
+        }
         /* OperationErrorGenerator.kt:270 */
-321
+    }
     /* OperationErrorGenerator.kt:269 */
-323
+}
 /* OperationErrorGenerator.kt:133 */
 impl ::std::fmt::Display for ContentTypeParametersError {
     /* 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")
-337
+                }
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-340
+        }
         /* OperationErrorGenerator.kt:134 */
-342
+    }
--
+    }
     /* OperationErrorGenerator.kt:133 */
-344
+}
 /* OperationErrorGenerator.kt:182 */
 impl ::aws_smithy_types::retry::ProvideErrorKind for ContentTypeParametersError {
     /* OperationErrorGenerator.kt:186 */
     fn code(&self) -> ::std::option::Option<&str> {
         /* OperationErrorGenerator.kt:187 */
         ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
         /* OperationErrorGenerator.kt:186 */
-352
+    }
     /* 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 */
-358
+    }
     /* OperationErrorGenerator.kt:182 */
-360
+}
 /* OperationErrorGenerator.kt:163 */
 impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for ContentTypeParametersError {
     /* 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 */
-373
+        }
         /* OperationErrorGenerator.kt:164 */
-375
+    }
     /* OperationErrorGenerator.kt:163 */
-377
+}
 /* OperationErrorGenerator.kt:109 */
 impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for ContentTypeParametersError {
     /* 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 */
-391
+    }
     /* OperationErrorGenerator.kt:109 */
-393
+}
-394
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::content_type_parameters::_content_type_parameters_output::ContentTypeParametersOutput;
-397
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::content_type_parameters::_content_type_parameters_input::ContentTypeParametersInput;
-400
 /* RustModule.kt:172 */
 mod _content_type_parameters_input;
-403
 /* RustModule.kt:172 */
 mod _content_type_parameters_output;
-406
 /// Builders
 /// /* CodegenDelegator.kt:51 */Builders
 pub mod builders;

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/operation/content_type_parameters/_content_type_parameters_input.rs

@@ -1,1 +50,94 @@

 // 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 ContentTypeParametersInput {
 pub /* StructureGenerator.kt:201 */ struct ContentTypeParametersInput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
     pub value: ::std::option::Option<i32>,
     /* StructureGenerator.kt:201 */
-13
+}
 /* StructureGenerator.kt:135 */
 impl ContentTypeParametersInput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
                            /* StructureGenerator.kt:166 */
     pub fn value(&self) -> ::std::option::Option<i32> {
         /* StructureGenerator.kt:168 */
         self.value
         /* StructureGenerator.kt:166 */
-23
+    }
     /* StructureGenerator.kt:135 */
-25
+}
 /* ClientCodegenVisitor.kt:237 */
 impl ContentTypeParametersInput {
     /// Creates a new builder-style object to manufacture [`ContentTypeParametersInput`](crate::operation::content_type_parameters::ContentTypeParametersInput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`ContentTypeParametersInput`](crate::operation::content_type_parameters::ContentTypeParametersInput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::content_type_parameters::builders::ContentTypeParametersInputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::content_type_parameters::builders::ContentTypeParametersInputBuilder::default()
         /* BuilderGenerator.kt:175 */
-34
+    }
     /* ClientCodegenVisitor.kt:237 */
-36
+}
-37
 /// A builder for [`ContentTypeParametersInput`](crate::operation::content_type_parameters::ContentTypeParametersInput).
 /// /* BuilderGenerator.kt:342 */A builder for [`ContentTypeParametersInput`](crate::operation::content_type_parameters::ContentTypeParametersInput).
 /* 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 ContentTypeParametersInputBuilder {
     pub(crate) value: ::std::option::Option<i32>,
     /* BuilderGenerator.kt:275 */ pub(crate) value: ::std::option::Option<i32>,
     /* BuilderGenerator.kt:345 */
-47
+}
 /* BuilderGenerator.kt:355 */
 impl ContentTypeParametersInputBuilder {
     /* BuilderGenerator.kt:286 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:291 */
     pub fn value(mut self, input: i32) -> 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<i32>) -> 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<i32> {
         /* BuilderGenerator.kt:337 */
         &self.value
         /* BuilderGenerator.kt:336 */
-76
+    }
     /// Consumes the builder and constructs a [`ContentTypeParametersInput`](crate::operation::content_type_parameters::ContentTypeParametersInput).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`ContentTypeParametersInput`](crate::operation::content_type_parameters::ContentTypeParametersInput).
     /* BuilderGenerator.kt:253 */
     pub fn build(
         self,
     ) -> ::std::result::Result<crate::operation::content_type_parameters::ContentTypeParametersInput, ::aws_smithy_types::error::operation::BuildError>
-82
+    {
         ::std::result::Result::Ok(crate::operation::content_type_parameters::ContentTypeParametersInput { value: self.value })
         /* BuilderGenerator.kt:254 */
         ::std::result::Result::Ok(
             /* BuilderGenerator.kt:477 */
             crate::operation::content_type_parameters::ContentTypeParametersInput {
                 /* BuilderGenerator.kt:481 */ value: self.value,
                 /* BuilderGenerator.kt:477 */
             }, /* BuilderGenerator.kt:254 */
-+
+        )
         /* BuilderGenerator.kt:253 */
-92
+    }
     /* BuilderGenerator.kt:355 */
-94
+}

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/operation/content_type_parameters/_content_type_parameters_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 ContentTypeParametersOutput {}
 pub /* StructureGenerator.kt:201 */ struct ContentTypeParametersOutput {/* StructureGenerator.kt:201 */}
 /* ClientCodegenVisitor.kt:237 */
 impl ContentTypeParametersOutput {
     /// Creates a new builder-style object to manufacture [`ContentTypeParametersOutput`](crate::operation::content_type_parameters::ContentTypeParametersOutput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`ContentTypeParametersOutput`](crate::operation::content_type_parameters::ContentTypeParametersOutput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::content_type_parameters::builders::ContentTypeParametersOutputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::content_type_parameters::builders::ContentTypeParametersOutputBuilder::default()
         /* BuilderGenerator.kt:175 */
-17
+    }
     /* ClientCodegenVisitor.kt:237 */
-19
+}
-20
 /// A builder for [`ContentTypeParametersOutput`](crate::operation::content_type_parameters::ContentTypeParametersOutput).
 /// /* BuilderGenerator.kt:342 */A builder for [`ContentTypeParametersOutput`](crate::operation::content_type_parameters::ContentTypeParametersOutput).
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 pub struct ContentTypeParametersOutputBuilder {}
 /* BuilderGenerator.kt:345 */
 pub struct ContentTypeParametersOutputBuilder {/* BuilderGenerator.kt:345 */}
 /* BuilderGenerator.kt:355 */
 impl ContentTypeParametersOutputBuilder {
     /// Consumes the builder and constructs a [`ContentTypeParametersOutput`](crate::operation::content_type_parameters::ContentTypeParametersOutput).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`ContentTypeParametersOutput`](crate::operation::content_type_parameters::ContentTypeParametersOutput).
     /* BuilderGenerator.kt:253 */
     pub fn build(self) -> crate::operation::content_type_parameters::ContentTypeParametersOutput {
         crate::operation::content_type_parameters::ContentTypeParametersOutput {}
         /* BuilderGenerator.kt:477 */
         crate::operation::content_type_parameters::ContentTypeParametersOutput {
         /* BuilderGenerator.kt:477 */}
         /* BuilderGenerator.kt:253 */
-37
+    }
     /* BuilderGenerator.kt:355 */
-39
+}

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/operation/content_type_parameters/builders.rs

@@ -1,1 +125,143 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::content_type_parameters::_content_type_parameters_output::ContentTypeParametersOutputBuilder;
-4
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::content_type_parameters::_content_type_parameters_input::ContentTypeParametersInputBuilder;
-7
 /* FluentBuilderGenerator.kt:408 */
 impl crate::operation::content_type_parameters::builders::ContentTypeParametersInputBuilder {
     /// Sends a request with this input using the given client.
     pub async fn send_with(
         self,
         client: &crate::Client,
     ) -> ::std::result::Result<
         crate::operation::content_type_parameters::ContentTypeParametersOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::content_type_parameters::ContentTypeParametersError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {
         let mut fluent_builder = client.content_type_parameters();
         fluent_builder.inner = self;
         fluent_builder.send().await
-24
+    }
-25
+}
 /// Fluent builder constructing a request to `ContentTypeParameters`.
 /// /* FluentBuilderGenerator.kt:129 */Fluent builder constructing a request to `ContentTypeParameters`.
 ///
 /// The example tests how servers must support requests containing a `Content-Type` header with parameters.
 /// /* FluentBuilderGenerator.kt:130 */The example tests how servers must support requests containing a `Content-Type` header with parameters.
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::fmt::Debug)]
 /* FluentBuilderGenerator.kt:270 */
 pub struct ContentTypeParametersFluentBuilder {
     handle: ::std::sync::Arc<crate::client::Handle>,
     inner: crate::operation::content_type_parameters::builders::ContentTypeParametersInputBuilder,
     config_override: ::std::option::Option<crate::config::Builder>,
-36
+}
 /* FluentBuilderGenerator.kt:381 */
 impl
     crate::client::customize::internal::CustomizableSend<
         crate::operation::content_type_parameters::ContentTypeParametersOutput,
         crate::operation::content_type_parameters::ContentTypeParametersError,
     > for ContentTypeParametersFluentBuilder
-43
+{
     fn send(
         self,
         config_override: crate::config::Builder,
     ) -> crate::client::customize::internal::BoxFuture<
         crate::client::customize::internal::SendResult<
             crate::operation::content_type_parameters::ContentTypeParametersOutput,
             crate::operation::content_type_parameters::ContentTypeParametersError,
         >,
     > {
         ::std::boxed::Box::pin(async move { self.config_override(config_override).send().await })
-54
+    }
-55
+}
 /* FluentBuilderGenerator.kt:282 */
 impl ContentTypeParametersFluentBuilder {
     /* FluentBuilderGenerator.kt:288 */
     /// Creates a new `ContentTypeParametersFluentBuilder`.
     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,
-65
+        }
-66
+    }
     /* FluentBuilderGenerator.kt:301 */
     /// Access the ContentTypeParameters as a reference.
     pub fn as_input(&self) -> &crate::operation::content_type_parameters::builders::ContentTypeParametersInputBuilder {
         &self.inner
-71
+    }
     /* 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::content_type_parameters::ContentTypeParametersOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::content_type_parameters::ContentTypeParametersError,
             ::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::content_type_parameters::ContentTypeParameters::operation_runtime_plugins(
             self.handle.runtime_plugins.clone(),
             &self.handle.conf,
             self.config_override,
         );
         crate::operation::content_type_parameters::ContentTypeParameters::orchestrate(&runtime_plugins, input).await
-100
+    }
-101
     /// Consumes this builder, creating a customizable operation that can be modified before being sent.
     pub fn customize(
         self,
     ) -> crate::client::customize::CustomizableOperation<
         crate::operation::content_type_parameters::ContentTypeParametersOutput,
         crate::operation::content_type_parameters::ContentTypeParametersError,
         Self,
     > {
         crate::client::customize::CustomizableOperation::new(self)
-111
+    }
     /* 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
-116
+    }
-117
     pub(crate) fn set_config_override(&mut self, config_override: ::std::option::Option<crate::config::Builder>) -> &mut Self {
         self.config_override = config_override;
         self
-121
+    }
     /* FluentBuilderGenerator.kt:498 */
     #[allow(missing_docs)] // documentation missing in model
                            /* FluentBuilderGenerator.kt:500 */
     pub fn value(mut self, input: i32) -> Self {
         self.inner = self.inner.value(input);
         self
-128
+    }
     /* FluentBuilderGenerator.kt:498 */
     #[allow(missing_docs)] // documentation missing in model
                            /* FluentBuilderGenerator.kt:500 */
     pub fn set_value(mut self, input: ::std::option::Option<i32>) -> Self {
         self.inner = self.inner.set_value(input);
         self
-135
+    }
     /* FluentBuilderGenerator.kt:518 */
     #[allow(missing_docs)] // documentation missing in model
                            /* FluentBuilderGenerator.kt:520 */
     pub fn get_value(&self) -> &::std::option::Option<i32> {
         self.inner.get_value()
-141
+    }
     /* FluentBuilderGenerator.kt:282 */
-143
+}

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/operation/datetime_offsets.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 `DatetimeOffsets`.
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* OperationGenerator.kt:84 */
 pub struct DatetimeOffsets;
 /* OperationGenerator.kt:85 */
 impl DatetimeOffsets {
     /// Creates a new `DatetimeOffsets`
     /// /* OperationGenerator.kt:86 */Creates a new `DatetimeOffsets`
     /* 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::datetime_offsets::DatetimeOffsetsInput,
     ) -> ::std::result::Result<
         crate::operation::datetime_offsets::DatetimeOffsetsOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::datetime_offsets::DatetimeOffsetsError,
             ::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::datetime_offsets::DatetimeOffsetsError>()
                     .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::datetime_offsets::DatetimeOffsetsOutput>()
                 .expect("correct output type"),
-47
+        )
-48
+    }
-49

@@ -63,72 +265,282 @@

↥ Expand context

         .instrument(::tracing::debug_span!(
             "Rest Json Protocol.DatetimeOffsets",
             "rpc.service" = "Rest Json Protocol",
             "rpc.method" = "DatetimeOffsets",
             "sdk_invocation_id" = ::fastrand::u32(1_000_000..10_000_000),
         ))
         .await
-79
+    }
-80
     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);
-93
+            }
             runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
                 config_override,
                 client_config.config.clone(),
                 &client_config.runtime_components,
             ));
-99
+        }
         runtime_plugins
-101
+    }
     /* OperationGenerator.kt:85 */
-103
+}
 /* OperationRuntimePluginGenerator.kt:55 */
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for DatetimeOffsets {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         let mut cfg = ::aws_smithy_types::config_bag::Layer::new("DatetimeOffsets");
-108
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
             DatetimeOffsetsRequestSerializer,
         ));
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
             DatetimeOffsetsResponseDeserializer,
         ));
-115
         cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
             ::aws_smithy_runtime_api::client::auth::static_resolver::StaticAuthSchemeOptionResolverParams::new(),
         ));
-119
         cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
             "DatetimeOffsets",
             "Rest Json Protocol",
         ));
-124
         ::std::option::Option::Some(cfg.freeze())
-126
+    }
-127
     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("DatetimeOffsets")
             .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
             .with_interceptor(DatetimeOffsetsEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::datetime_offsets::DatetimeOffsetsError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::datetime_offsets::DatetimeOffsetsError,
             >::new());
-142
         ::std::borrow::Cow::Owned(rcb)
-144
+    }
-145
+}
-146
 /* ResponseDeserializerGenerator.kt:64 */
 #[derive(Debug)]
 struct DatetimeOffsetsResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for DatetimeOffsetsResponseDeserializer {
     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;
-160
         let parse_result = if !success && status != 200 || force_error {
             crate::protocol_serde::shape_datetime_offsets::de_datetime_offsets_http_error(status, headers, body)
         } else {
             crate::protocol_serde::shape_datetime_offsets::de_datetime_offsets_http_response(status, headers, body)
         };
         crate::protocol_serde::type_erase_result(parse_result)
-167
+    }
-168
+}
 /* RequestSerializerGenerator.kt:67 */
 #[derive(Debug)]
 struct DatetimeOffsetsRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for DatetimeOffsetsRequestSerializer {
     #[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::datetime_offsets::DatetimeOffsetsInput>()
             .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::datetime_offsets::DatetimeOffsetsInput,
                 output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 use ::std::fmt::Write as _;
                 ::std::write!(output, "/DatetimeOffsets").expect("formatting should succeed");
                 ::std::result::Result::Ok(())
-194
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::datetime_offsets::DatetimeOffsetsInput,
                 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))
-203
+            }
             let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from("");
-208
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
-210
+    }
-211
+}
 /* EndpointParamsInterceptorGenerator.kt:86 */
 #[derive(Debug)]
 struct DatetimeOffsetsEndpointParamsInterceptor;
-215
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for DatetimeOffsetsEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "DatetimeOffsetsEndpointParamsInterceptor"
-219
+    }
-220
     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::<DatetimeOffsetsInput>()
             .ok_or("failed to downcast to DatetimeOffsetsInput")?;
-235
         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(())
-242
+    }
-243
+}
-244
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-247
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod datetime_offsets_test {
-254
     /// Ensures that clients can correctly parse datetime (timestamps) with offsets
     /// Test ID: RestJsonDateTimeWithNegativeOffset
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn rest_json_date_time_with_negative_offset_response() {
         let expected_output = crate::operation::datetime_offsets::DatetimeOffsetsOutput::builder()
             .set_datetime(::std::option::Option::Some(::aws_smithy_types::DateTime::from_fractional_secs(
                 1576540098, 0_f64,

↧ Expand context

             )))
             .build();
         let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(
             ::http::response::Builder::new()
                 .status(200)
                 .body(::aws_smithy_types::body::SdkBody::from(
                     "      {\n          \"datetime\": \"2019-12-16T22:48:18-01:00\"\n      }\n",
                 ))
                 .unwrap(),
-272
+        )
         .unwrap();
         use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
         use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;
-276
         let op = crate::operation::datetime_offsets::DatetimeOffsets::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");
-282

@@ -297,314 +426,502 @@

↥ Expand context

                     "      {\n          \"datetime\": \"2019-12-17T00:48:18+01:00\"\n      }\n",
                 ))
                 .unwrap(),
-317
+        )
         .unwrap();
         use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
         use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;
-321
         let op = crate::operation::datetime_offsets::DatetimeOffsets::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");
-327
         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/json"),

                 )))
             });
             de.deserialize_nonstreaming(&http_response)
         });
         let parsed = parsed
             .expect("should be successful response")
             .downcast::<crate::operation::datetime_offsets::DatetimeOffsetsOutput>()
             .unwrap();
         ::pretty_assertions::assert_eq!(parsed.datetime, expected_output.datetime, "Unexpected value for `datetime`");
-343
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-346
+}
-347
 /* OperationErrorGenerator.kt:79 */
 /// Error type for the `DatetimeOffsetsError` operation.
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::fmt::Debug)]
 pub enum DatetimeOffsetsError {
 pub /* OperationErrorGenerator.kt:81 */ enum DatetimeOffsetsError {
     /* 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()`:
-359
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-361
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-DatetimeOffsetsError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
     /* OperationErrorGenerator.kt:81 */
-365
+}
 /* OperationErrorGenerator.kt:218 */
 impl DatetimeOffsetsError {
     /* OperationErrorGenerator.kt:219 */
     /// Creates the `DatetimeOffsetsError::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(),
         })
-377
+    }
-378
     /// Creates the `DatetimeOffsetsError::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,
         })
-385
+    }
     ///
     /// /* 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 */
-396
+        }
         /* OperationErrorGenerator.kt:242 */
-398
+    }
     /* OperationErrorGenerator.kt:218 */
-400
+}
 /* OperationErrorGenerator.kt:269 */
 impl ::std::error::Error for DatetimeOffsetsError {
     /* 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 */
-413
+        }
         /* OperationErrorGenerator.kt:270 */
-415
+    }
     /* OperationErrorGenerator.kt:269 */
-417
+}
 /* OperationErrorGenerator.kt:133 */
 impl ::std::fmt::Display for DatetimeOffsetsError {
     /* 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")
-431
+                }
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-434
+        }
         /* OperationErrorGenerator.kt:134 */
-436
+    }
--
+    }
     /* OperationErrorGenerator.kt:133 */
-438
+}
 /* OperationErrorGenerator.kt:182 */
 impl ::aws_smithy_types::retry::ProvideErrorKind for DatetimeOffsetsError {
     /* OperationErrorGenerator.kt:186 */
     fn code(&self) -> ::std::option::Option<&str> {
         /* OperationErrorGenerator.kt:187 */
         ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
         /* OperationErrorGenerator.kt:186 */
-446
+    }
     /* 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 */
-452
+    }
     /* OperationErrorGenerator.kt:182 */
-454
+}
 /* OperationErrorGenerator.kt:163 */
 impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for DatetimeOffsetsError {
     /* 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 */
-467
+        }
         /* OperationErrorGenerator.kt:164 */
-469
+    }
     /* OperationErrorGenerator.kt:163 */
-471
+}
 /* OperationErrorGenerator.kt:109 */
 impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for DatetimeOffsetsError {
     /* 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 */
-485
+    }
     /* OperationErrorGenerator.kt:109 */
-487
+}
-488
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::datetime_offsets::_datetime_offsets_output::DatetimeOffsetsOutput;
-491
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::datetime_offsets::_datetime_offsets_input::DatetimeOffsetsInput;
-494
 /* RustModule.kt:172 */
 mod _datetime_offsets_input;
-497
 /* RustModule.kt:172 */
 mod _datetime_offsets_output;
-500
 /// Builders
 /// /* CodegenDelegator.kt:51 */Builders
 pub mod builders;

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/operation/datetime_offsets/_datetime_offsets_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 DatetimeOffsetsInput {}
 pub /* StructureGenerator.kt:201 */ struct DatetimeOffsetsInput {/* StructureGenerator.kt:201 */}
 /* ClientCodegenVisitor.kt:237 */
 impl DatetimeOffsetsInput {
     /// Creates a new builder-style object to manufacture [`DatetimeOffsetsInput`](crate::operation::datetime_offsets::DatetimeOffsetsInput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`DatetimeOffsetsInput`](crate::operation::datetime_offsets::DatetimeOffsetsInput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::datetime_offsets::builders::DatetimeOffsetsInputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::datetime_offsets::builders::DatetimeOffsetsInputBuilder::default()
         /* BuilderGenerator.kt:175 */
-17
+    }
     /* ClientCodegenVisitor.kt:237 */
-19
+}
-20
 /// A builder for [`DatetimeOffsetsInput`](crate::operation::datetime_offsets::DatetimeOffsetsInput).
 /// /* BuilderGenerator.kt:342 */A builder for [`DatetimeOffsetsInput`](crate::operation::datetime_offsets::DatetimeOffsetsInput).
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 pub struct DatetimeOffsetsInputBuilder {}
 /* BuilderGenerator.kt:345 */
 pub struct DatetimeOffsetsInputBuilder {/* BuilderGenerator.kt:345 */}
 /* BuilderGenerator.kt:355 */
 impl DatetimeOffsetsInputBuilder {
     /// Consumes the builder and constructs a [`DatetimeOffsetsInput`](crate::operation::datetime_offsets::DatetimeOffsetsInput).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`DatetimeOffsetsInput`](crate::operation::datetime_offsets::DatetimeOffsetsInput).
     /* BuilderGenerator.kt:253 */
     pub fn build(
         self,
     ) -> ::std::result::Result<crate::operation::datetime_offsets::DatetimeOffsetsInput, ::aws_smithy_types::error::operation::BuildError> {
         ::std::result::Result::Ok(crate::operation::datetime_offsets::DatetimeOffsetsInput {})
         /* BuilderGenerator.kt:254 */
         ::std::result::Result::Ok(
             /* BuilderGenerator.kt:477 */
             crate::operation::datetime_offsets::DatetimeOffsetsInput {
             /* BuilderGenerator.kt:477 */}, /* BuilderGenerator.kt:254 */
-+
+        )
         /* BuilderGenerator.kt:253 */
-42
+    }
     /* BuilderGenerator.kt:355 */
-44
+}

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/operation/datetime_offsets/_datetime_offsets_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 DatetimeOffsetsOutput {
 pub /* StructureGenerator.kt:201 */ struct DatetimeOffsetsOutput {
     /* 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 DatetimeOffsetsOutput {
     /* 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 DatetimeOffsetsOutput {
     /// Creates a new builder-style object to manufacture [`DatetimeOffsetsOutput`](crate::operation::datetime_offsets::DatetimeOffsetsOutput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`DatetimeOffsetsOutput`](crate::operation::datetime_offsets::DatetimeOffsetsOutput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::datetime_offsets::builders::DatetimeOffsetsOutputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::datetime_offsets::builders::DatetimeOffsetsOutputBuilder::default()
         /* BuilderGenerator.kt:175 */
-34
+    }
     /* ClientCodegenVisitor.kt:237 */
-36
+}
-37
 /// A builder for [`DatetimeOffsetsOutput`](crate::operation::datetime_offsets::DatetimeOffsetsOutput).
 /// /* BuilderGenerator.kt:342 */A builder for [`DatetimeOffsetsOutput`](crate::operation::datetime_offsets::DatetimeOffsetsOutput).
 /* 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 DatetimeOffsetsOutputBuilder {
     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 DatetimeOffsetsOutputBuilder {
     /* 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 [`DatetimeOffsetsOutput`](crate::operation::datetime_offsets::DatetimeOffsetsOutput).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`DatetimeOffsetsOutput`](crate::operation::datetime_offsets::DatetimeOffsetsOutput).
     /* BuilderGenerator.kt:253 */
     pub fn build(self) -> crate::operation::datetime_offsets::DatetimeOffsetsOutput {
         crate::operation::datetime_offsets::DatetimeOffsetsOutput { datetime: self.datetime }
         /* BuilderGenerator.kt:477 */
         crate::operation::datetime_offsets::DatetimeOffsetsOutput {
             /* BuilderGenerator.kt:481 */ datetime: self.datetime,
             /* BuilderGenerator.kt:477 */
-84
+        }
         /* BuilderGenerator.kt:253 */
-+
+    }
     /* BuilderGenerator.kt:355 */
-88
+}

tmp-codegen-diff/codegen-client-test/rest_json/rust-client-codegen/src/operation/datetime_offsets/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::datetime_offsets::_datetime_offsets_output::DatetimeOffsetsOutputBuilder;
-4
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::datetime_offsets::_datetime_offsets_input::DatetimeOffsetsInputBuilder;
-7
 /* FluentBuilderGenerator.kt:408 */
 impl crate::operation::datetime_offsets::builders::DatetimeOffsetsInputBuilder {
     /// Sends a request with this input using the given client.
     pub async fn send_with(
         self,
         client: &crate::Client,
     ) -> ::std::result::Result<
         crate::operation::datetime_offsets::DatetimeOffsetsOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::datetime_offsets::DatetimeOffsetsError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {
         let mut fluent_builder = client.datetime_offsets();
         fluent_builder.inner = self;
         fluent_builder.send().await
-24
+    }
-25
+}
 /// Fluent builder constructing a request to `DatetimeOffsets`.
 /// /* FluentBuilderGenerator.kt:129 */Fluent builder constructing a request to `DatetimeOffsets`.
 ///
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::fmt::Debug)]
 /* FluentBuilderGenerator.kt:270 */
 pub struct DatetimeOffsetsFluentBuilder {
     handle: ::std::sync::Arc<crate::client::Handle>,
     inner: crate::operation::datetime_offsets::builders::DatetimeOffsetsInputBuilder,
     config_override: ::std::option::Option<crate::config::Builder>,
-35
+}
 /* FluentBuilderGenerator.kt:381 */
 impl
     crate::client::customize::internal::CustomizableSend<
         crate::operation::datetime_offsets::DatetimeOffsetsOutput,
         crate::operation::datetime_offsets::DatetimeOffsetsError,
     > for DatetimeOffsetsFluentBuilder
-42
+{
     fn send(
         self,
         config_override: crate::config::Builder,
     ) -> crate::client::customize::internal::BoxFuture<
         crate::client::customize::internal::SendResult<
             crate::operation::datetime_offsets::DatetimeOffsetsOutput,
             crate::operation::datetime_offsets::DatetimeOffsetsError,
         >,
     > {
         ::std::boxed::Box::pin(async move { self.config_override(config_override).send().await })
-53
+    }
-54
+}
 /* FluentBuilderGenerator.kt:282 */
 impl DatetimeOffsetsFluentBuilder {
     /* FluentBuilderGenerator.kt:288 */
     /// Creates a new `DatetimeOffsetsFluentBuilder`.
     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 DatetimeOffsets as a reference.
     pub fn as_input(&self) -> &crate::operation::datetime_offsets::builders::DatetimeOffsetsInputBuilder {
         &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::datetime_offsets::DatetimeOffsetsOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::datetime_offsets::DatetimeOffsetsError,
             ::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::datetime_offsets::DatetimeOffsets::operation_runtime_plugins(
             self.handle.runtime_plugins.clone(),
             &self.handle.conf,
             self.config_override,
         );
         crate::operation::datetime_offsets::DatetimeOffsets::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::datetime_offsets::DatetimeOffsetsOutput,
         crate::operation::datetime_offsets::DatetimeOffsetsError,
         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
+}

Client Test

Files changed: