Client Test

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/error_meta.rs

@@ -1,1 +208,334 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* ServiceErrorGenerator.kt:252 */
 /// All possible error types for this service.
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::fmt::Debug)]
 pub enum Error {
 pub /* ServiceErrorGenerator.kt:257 */ enum Error {
     /* ServiceErrorGenerator.kt:259 */
     #[allow(missing_docs)] // documentation missing in model
     /* ServiceErrorGenerator.kt:262 */
     InvalidPokeballError(crate::types::error::InvalidPokeballError),
     /* ServiceErrorGenerator.kt:259 */
     #[allow(missing_docs)] // documentation missing in model
     /* ServiceErrorGenerator.kt:262 */
     MasterBallUnsuccessful(crate::types::error::MasterBallUnsuccessful),
     /* ServiceErrorGenerator.kt:259 */
     #[allow(missing_docs)] // documentation missing in model
     /* ServiceErrorGenerator.kt:262 */
     ThrottlingError(crate::types::error::ThrottlingError),
     /* ServiceErrorGenerator.kt:259 */
     #[allow(missing_docs)] // documentation missing in model
     /* ServiceErrorGenerator.kt:262 */
     UnsupportedRegionError(crate::types::error::UnsupportedRegionError),
     /// A standard error for input validation failures. This should be thrown by services when a member of the input structure falls outside of the modeled or documented constraints.
     /// /* ServiceErrorGenerator.kt:259 */A standard error for input validation failures. This should be thrown by services when a member of the input structure falls outside of the modeled or documented constraints.
     /* ServiceErrorGenerator.kt:262 */
     ValidationError(crate::types::error::ValidationError),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     /// /* ServiceErrorGenerator.kt:264 */An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     /* ServiceErrorGenerator.kt:320 */
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-32
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-34
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-Error) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
     /* ServiceErrorGenerator.kt:266 */
     Unhandled(crate::error::sealed_unhandled::Unhandled), /* ServiceErrorGenerator.kt:257 */
-38
+}
 /* ServiceErrorGenerator.kt:131 */
 impl ::std::fmt::Display for Error {
     /* ServiceErrorGenerator.kt:132 */
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
         /* ServiceErrorGenerator.kt:133 */
         match self {
             Error::InvalidPokeballError(inner) => inner.fmt(f),
             Error::MasterBallUnsuccessful(inner) => inner.fmt(f),
             Error::ThrottlingError(inner) => inner.fmt(f),
             Error::UnsupportedRegionError(inner) => inner.fmt(f),
             Error::ValidationError(inner) => inner.fmt(f),
             /* ServiceErrorGenerator.kt:135 */ Error::InvalidPokeballError(inner) => inner.fmt(f),
             /* ServiceErrorGenerator.kt:135 */ Error::MasterBallUnsuccessful(inner) => inner.fmt(f),
             /* ServiceErrorGenerator.kt:135 */ Error::ThrottlingError(inner) => inner.fmt(f),
             /* ServiceErrorGenerator.kt:135 */ Error::UnsupportedRegionError(inner) => inner.fmt(f),
             /* ServiceErrorGenerator.kt:135 */ Error::ValidationError(inner) => inner.fmt(f),
             /* ServiceErrorGenerator.kt:137 */
             Error::Unhandled(_) => {
                 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")
-56
+                }
--
+            }
             } /* ServiceErrorGenerator.kt:133 */
-58
+        }
         /* ServiceErrorGenerator.kt:132 */
-60
+    }
     /* ServiceErrorGenerator.kt:131 */
-62
+}
 /* ServiceErrorGenerator.kt:154 */
 impl From<::aws_smithy_types::error::operation::BuildError> for Error {
     fn from(value: ::aws_smithy_types::error::operation::BuildError) -> Self {
         Error::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source: value.into(),
             meta: ::std::default::Default::default(),
         })
-70
+    }
-71
+}
 /* ServiceErrorGenerator.kt:223 */
 impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for Error {
     fn meta(&self) -> &::aws_smithy_types::error::metadata::ErrorMetadata {
         match self {
             Self::InvalidPokeballError(inner) => inner.meta(),
             Self::MasterBallUnsuccessful(inner) => inner.meta(),
             Self::ThrottlingError(inner) => inner.meta(),
             Self::UnsupportedRegionError(inner) => inner.meta(),
             Self::ValidationError(inner) => inner.meta(),
             Self::Unhandled(inner) => &inner.meta,
-82
+        }
-83
+    }
-84
+}
 /* ServiceErrorGenerator.kt:174 */
 impl<R> From<::aws_smithy_runtime_api::client::result::SdkError<crate::operation::capture_pokemon::CapturePokemonError, R>> for Error
 where
     R: Send + Sync + std::fmt::Debug + 'static,
-89
+{
     /* ServiceErrorGenerator.kt:179 */
     fn from(err: ::aws_smithy_runtime_api::client::result::SdkError<crate::operation::capture_pokemon::CapturePokemonError, R>) -> Self {
         /* ServiceErrorGenerator.kt:184 */
         match err {
             /* ServiceErrorGenerator.kt:185 */
             ::aws_smithy_runtime_api::client::result::SdkError::ServiceError(context) => Self::from(context.into_err()),
             /* ServiceErrorGenerator.kt:186 */
             _ => Error::Unhandled(crate::error::sealed_unhandled::Unhandled {
                 meta: ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(&err).clone(),
                 source: err.into(),
             }),
             /* ServiceErrorGenerator.kt:184 */
-102
+        }
         /* ServiceErrorGenerator.kt:179 */
-104
+    }
     /* ServiceErrorGenerator.kt:174 */
-106
+}
 /* ServiceErrorGenerator.kt:202 */
 impl From<crate::operation::capture_pokemon::CapturePokemonError> for Error {
     /* ServiceErrorGenerator.kt:203 */
     fn from(err: crate::operation::capture_pokemon::CapturePokemonError) -> Self {
         /* ServiceErrorGenerator.kt:204 */
         match err {
             /* ServiceErrorGenerator.kt:207 */
             crate::operation::capture_pokemon::CapturePokemonError::ValidationError(inner) => Error::ValidationError(inner),
             /* ServiceErrorGenerator.kt:207 */
             crate::operation::capture_pokemon::CapturePokemonError::MasterBallUnsuccessful(inner) => Error::MasterBallUnsuccessful(inner),
             /* ServiceErrorGenerator.kt:207 */
             crate::operation::capture_pokemon::CapturePokemonError::InvalidPokeballError(inner) => Error::InvalidPokeballError(inner),
             /* ServiceErrorGenerator.kt:207 */
             crate::operation::capture_pokemon::CapturePokemonError::ThrottlingError(inner) => Error::ThrottlingError(inner),
             /* ServiceErrorGenerator.kt:207 */
             crate::operation::capture_pokemon::CapturePokemonError::UnsupportedRegionError(inner) => Error::UnsupportedRegionError(inner),
             /* ServiceErrorGenerator.kt:212 */
             crate::operation::capture_pokemon::CapturePokemonError::Unhandled(inner) => Error::Unhandled(inner),
             /* ServiceErrorGenerator.kt:204 */
-126
+        }
         /* ServiceErrorGenerator.kt:203 */
-128
+    }
     /* ServiceErrorGenerator.kt:202 */
-130
+}
 /* ServiceErrorGenerator.kt:174 */
 impl<R> From<::aws_smithy_runtime_api::client::result::SdkError<crate::operation::check_health::CheckHealthError, R>> for Error
 where
     R: Send + Sync + std::fmt::Debug + 'static,
-135
+{
     /* ServiceErrorGenerator.kt:179 */
     fn from(err: ::aws_smithy_runtime_api::client::result::SdkError<crate::operation::check_health::CheckHealthError, R>) -> Self {
         /* ServiceErrorGenerator.kt:184 */
         match err {
             /* ServiceErrorGenerator.kt:185 */
             ::aws_smithy_runtime_api::client::result::SdkError::ServiceError(context) => Self::from(context.into_err()),
             /* ServiceErrorGenerator.kt:186 */
             _ => Error::Unhandled(crate::error::sealed_unhandled::Unhandled {
                 meta: ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(&err).clone(),
                 source: err.into(),
             }),
             /* ServiceErrorGenerator.kt:184 */
-148
+        }
         /* ServiceErrorGenerator.kt:179 */
-150
+    }
     /* ServiceErrorGenerator.kt:174 */
-152
+}
 /* ServiceErrorGenerator.kt:202 */
 impl From<crate::operation::check_health::CheckHealthError> for Error {
     /* ServiceErrorGenerator.kt:203 */
     fn from(err: crate::operation::check_health::CheckHealthError) -> Self {
         /* ServiceErrorGenerator.kt:204 */
         match err {
             /* ServiceErrorGenerator.kt:212 */
             crate::operation::check_health::CheckHealthError::Unhandled(inner) => Error::Unhandled(inner),
             /* ServiceErrorGenerator.kt:204 */
-162
+        }
         /* ServiceErrorGenerator.kt:203 */
-164
+    }
     /* ServiceErrorGenerator.kt:202 */
-166
+}
 /* ServiceErrorGenerator.kt:174 */
 impl<R> From<::aws_smithy_runtime_api::client::result::SdkError<crate::operation::do_nothing::DoNothingError, R>> for Error
 where
     R: Send + Sync + std::fmt::Debug + 'static,
-171
+{
     /* ServiceErrorGenerator.kt:179 */
     fn from(err: ::aws_smithy_runtime_api::client::result::SdkError<crate::operation::do_nothing::DoNothingError, R>) -> Self {
         /* ServiceErrorGenerator.kt:184 */
         match err {
             /* ServiceErrorGenerator.kt:185 */
             ::aws_smithy_runtime_api::client::result::SdkError::ServiceError(context) => Self::from(context.into_err()),
             /* ServiceErrorGenerator.kt:186 */
             _ => Error::Unhandled(crate::error::sealed_unhandled::Unhandled {
                 meta: ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(&err).clone(),
                 source: err.into(),
             }),
             /* ServiceErrorGenerator.kt:184 */
-184
+        }
         /* ServiceErrorGenerator.kt:179 */
-186
+    }
     /* ServiceErrorGenerator.kt:174 */
-188
+}
 /* ServiceErrorGenerator.kt:202 */
 impl From<crate::operation::do_nothing::DoNothingError> for Error {
     /* ServiceErrorGenerator.kt:203 */
     fn from(err: crate::operation::do_nothing::DoNothingError) -> Self {
         /* ServiceErrorGenerator.kt:204 */
         match err {
             /* ServiceErrorGenerator.kt:212 */
             crate::operation::do_nothing::DoNothingError::Unhandled(inner) => Error::Unhandled(inner),
             /* ServiceErrorGenerator.kt:204 */
-198
+        }
         /* ServiceErrorGenerator.kt:203 */
-200
+    }
     /* ServiceErrorGenerator.kt:202 */
-202
+}
 /* ServiceErrorGenerator.kt:174 */
 impl<R> From<::aws_smithy_runtime_api::client::result::SdkError<crate::operation::get_server_statistics::GetServerStatisticsError, R>> for Error
 where
     R: Send + Sync + std::fmt::Debug + 'static,
-207
+{
     /* ServiceErrorGenerator.kt:179 */
     fn from(err: ::aws_smithy_runtime_api::client::result::SdkError<crate::operation::get_server_statistics::GetServerStatisticsError, R>) -> Self {
         /* ServiceErrorGenerator.kt:184 */
         match err {
             /* ServiceErrorGenerator.kt:185 */
             ::aws_smithy_runtime_api::client::result::SdkError::ServiceError(context) => Self::from(context.into_err()),
             /* ServiceErrorGenerator.kt:186 */
             _ => Error::Unhandled(crate::error::sealed_unhandled::Unhandled {
                 meta: ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(&err).clone(),
                 source: err.into(),
             }),
             /* ServiceErrorGenerator.kt:184 */
-220
+        }
         /* ServiceErrorGenerator.kt:179 */
-222
+    }
     /* ServiceErrorGenerator.kt:174 */
-224
+}
 /* ServiceErrorGenerator.kt:202 */
 impl From<crate::operation::get_server_statistics::GetServerStatisticsError> for Error {
     /* ServiceErrorGenerator.kt:203 */
     fn from(err: crate::operation::get_server_statistics::GetServerStatisticsError) -> Self {
         /* ServiceErrorGenerator.kt:204 */
         match err {
             /* ServiceErrorGenerator.kt:212 */
             crate::operation::get_server_statistics::GetServerStatisticsError::Unhandled(inner) => Error::Unhandled(inner),
             /* ServiceErrorGenerator.kt:204 */
-234
+        }
         /* ServiceErrorGenerator.kt:203 */
-236
+    }
     /* ServiceErrorGenerator.kt:202 */
-238
+}
 /* ServiceErrorGenerator.kt:174 */
 impl<R> From<::aws_smithy_runtime_api::client::result::SdkError<crate::types::error::AttemptCapturingPokemonEventError, R>> for Error
 where
     R: Send + Sync + std::fmt::Debug + 'static,
-243
+{
     /* ServiceErrorGenerator.kt:179 */
     fn from(err: ::aws_smithy_runtime_api::client::result::SdkError<crate::types::error::AttemptCapturingPokemonEventError, R>) -> Self {
         /* ServiceErrorGenerator.kt:184 */
         match err {
             /* ServiceErrorGenerator.kt:185 */
             ::aws_smithy_runtime_api::client::result::SdkError::ServiceError(context) => Self::from(context.into_err()),
             /* ServiceErrorGenerator.kt:186 */
             _ => Error::Unhandled(crate::error::sealed_unhandled::Unhandled {
                 meta: ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(&err).clone(),
                 source: err.into(),
             }),
             /* ServiceErrorGenerator.kt:184 */
-256
+        }
         /* ServiceErrorGenerator.kt:179 */
-258
+    }
     /* ServiceErrorGenerator.kt:174 */
-260
+}
 /* ServiceErrorGenerator.kt:202 */
 impl From<crate::types::error::AttemptCapturingPokemonEventError> for Error {
     /* ServiceErrorGenerator.kt:203 */
     fn from(err: crate::types::error::AttemptCapturingPokemonEventError) -> Self {
         /* ServiceErrorGenerator.kt:204 */
         match err {
             /* ServiceErrorGenerator.kt:207 */
             crate::types::error::AttemptCapturingPokemonEventError::MasterBallUnsuccessful(inner) => Error::MasterBallUnsuccessful(inner),
             /* ServiceErrorGenerator.kt:212 */
             crate::types::error::AttemptCapturingPokemonEventError::Unhandled(inner) => Error::Unhandled(inner),
             /* ServiceErrorGenerator.kt:204 */
-272
+        }
         /* ServiceErrorGenerator.kt:203 */
-274
+    }
     /* ServiceErrorGenerator.kt:202 */
-276
+}
 /* ServiceErrorGenerator.kt:174 */
 impl<R> From<::aws_smithy_runtime_api::client::result::SdkError<crate::types::error::CapturePokemonEventsError, R>> for Error
 where
     R: Send + Sync + std::fmt::Debug + 'static,
-281
+{
     /* ServiceErrorGenerator.kt:179 */
     fn from(err: ::aws_smithy_runtime_api::client::result::SdkError<crate::types::error::CapturePokemonEventsError, R>) -> Self {
         /* ServiceErrorGenerator.kt:184 */
         match err {
             /* ServiceErrorGenerator.kt:185 */
             ::aws_smithy_runtime_api::client::result::SdkError::ServiceError(context) => Self::from(context.into_err()),
             /* ServiceErrorGenerator.kt:186 */
             _ => Error::Unhandled(crate::error::sealed_unhandled::Unhandled {
                 meta: ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(&err).clone(),
                 source: err.into(),
             }),
             /* ServiceErrorGenerator.kt:184 */
-294
+        }
         /* ServiceErrorGenerator.kt:179 */
-296
+    }
     /* ServiceErrorGenerator.kt:174 */
-298
+}
 /* ServiceErrorGenerator.kt:202 */
 impl From<crate::types::error::CapturePokemonEventsError> for Error {
     /* ServiceErrorGenerator.kt:203 */
     fn from(err: crate::types::error::CapturePokemonEventsError) -> Self {
         /* ServiceErrorGenerator.kt:204 */
         match err {
             /* ServiceErrorGenerator.kt:207 */
             crate::types::error::CapturePokemonEventsError::InvalidPokeballError(inner) => Error::InvalidPokeballError(inner),
             /* ServiceErrorGenerator.kt:207 */
             crate::types::error::CapturePokemonEventsError::ThrottlingError(inner) => Error::ThrottlingError(inner),
             /* ServiceErrorGenerator.kt:212 */
             crate::types::error::CapturePokemonEventsError::Unhandled(inner) => Error::Unhandled(inner),
             /* ServiceErrorGenerator.kt:204 */
-312
+        }
         /* ServiceErrorGenerator.kt:203 */
-314
+    }
     /* ServiceErrorGenerator.kt:202 */
-316
+}
 /* ServiceErrorGenerator.kt:115 */
 impl ::std::error::Error for Error {
     /* ServiceErrorGenerator.kt:116 */
     fn source(&self) -> std::option::Option<&(dyn ::std::error::Error + 'static)> {
         /* ServiceErrorGenerator.kt:117 */
         match self {
             Error::InvalidPokeballError(inner) => inner.source(),
             Error::MasterBallUnsuccessful(inner) => inner.source(),
             Error::ThrottlingError(inner) => inner.source(),
             Error::UnsupportedRegionError(inner) => inner.source(),
             Error::ValidationError(inner) => inner.source(),
             Error::Unhandled(inner) => ::std::option::Option::Some(&*inner.source),
             /* ServiceErrorGenerator.kt:119 */ Error::InvalidPokeballError(inner) => inner.source(),
             /* ServiceErrorGenerator.kt:119 */ Error::MasterBallUnsuccessful(inner) => inner.source(),
             /* ServiceErrorGenerator.kt:119 */ Error::ThrottlingError(inner) => inner.source(),
             /* ServiceErrorGenerator.kt:119 */ Error::UnsupportedRegionError(inner) => inner.source(),
             /* ServiceErrorGenerator.kt:119 */ Error::ValidationError(inner) => inner.source(),
             /* ServiceErrorGenerator.kt:121 */
             Error::Unhandled(inner) => ::std::option::Option::Some(&*inner.source), /* ServiceErrorGenerator.kt:117 */
-330
+        }
         /* ServiceErrorGenerator.kt:116 */
-332
+    }
     /* ServiceErrorGenerator.kt:115 */
-334
+}

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/event_stream_serde.rs

@@ -1,1 +186,282 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* EventStreamErrorMarshallerGenerator.kt:79 */
 #[non_exhaustive]
 #[derive(Debug)]
 pub struct AttemptCapturingPokemonEventErrorMarshaller;
-6
 impl AttemptCapturingPokemonEventErrorMarshaller {
     pub fn new() -> Self {
         AttemptCapturingPokemonEventErrorMarshaller
-10
+    }
-11
+}
 /* EventStreamErrorMarshallerGenerator.kt:93 */
 impl ::aws_smithy_eventstream::frame::MarshallMessage for AttemptCapturingPokemonEventErrorMarshaller {
     /* EventStreamErrorMarshallerGenerator.kt:97 */
     type Input = crate::types::error::AttemptCapturingPokemonEventError;
     /* EventStreamErrorMarshallerGenerator.kt:99 */
     fn marshall(
         &self,
         _input: Self::Input,
     ) -> std::result::Result<::aws_smithy_types::event_stream::Message, ::aws_smithy_eventstream::error::Error> {
         /* EventStreamErrorMarshallerGenerator.kt:103 */
         let mut headers = Vec::new();
         /* EventStreamMarshallerGenerator.kt:322 */
         headers.push(::aws_smithy_types::event_stream::Header::new(
             ":message-type",
             ::aws_smithy_types::event_stream::HeaderValue::String("exception".into()),
         ));
         /* EventStreamErrorMarshallerGenerator.kt:108 */
         let payload = match _input {
             crate::types::error::AttemptCapturingPokemonEventError::MasterBallUnsuccessful(inner) =>  {
                 headers.push(::aws_smithy_types::event_stream::Header::new(":exception-type", ::aws_smithy_types::event_stream::HeaderValue::String("masterball_unsuccessful".into())));
                 headers.push(::aws_smithy_types::event_stream::Header::new(":content-type", ::aws_smithy_types::event_stream::HeaderValue::String("application/json".into())));
                 crate::protocol_serde::shape_master_ball_unsuccessful::ser_master_ball_unsuccessful_error(&inner)
             /* EventStreamErrorMarshallerGenerator.kt:113 */crate::types::error::AttemptCapturingPokemonEventError::MasterBallUnsuccessful(inner) =>  {
                 /* EventStreamMarshallerGenerator.kt:322 */headers.push(::aws_smithy_types::event_stream::Header::new(":exception-type", ::aws_smithy_types::event_stream::HeaderValue::String("masterball_unsuccessful".into())));
                 /* EventStreamMarshallerGenerator.kt:322 */headers.push(::aws_smithy_types::event_stream::Header::new(":content-type", ::aws_smithy_types::event_stream::HeaderValue::String("application/json".into())));
                 /* EventStreamMarshallerGenerator.kt:283 */crate::protocol_serde::shape_master_ball_unsuccessful::ser_master_ball_unsuccessful_error(&inner)
                                             .map_err(|err| ::aws_smithy_eventstream::error::Error::marshalling(format!("{}", err)))?
--
+            }
             crate::types::error::AttemptCapturingPokemonEventError::Unhandled(_inner) => return Err(
             /* EventStreamErrorMarshallerGenerator.kt:113 */}
             /* EventStreamErrorMarshallerGenerator.kt:119 */crate::types::error::AttemptCapturingPokemonEventError::Unhandled(_inner) => return Err(
                                                 ::aws_smithy_eventstream::error::Error::marshalling("Cannot serialize `AttemptCapturingPokemonEvent::Unknown` for the request. The `Unknown` variant is intended for responses only. It occurs when an outdated client is used after a new enum variant was added on the server side.".to_owned())
                                             ),
--
+        }
--
+        ;
         /* EventStreamErrorMarshallerGenerator.kt:108 */}
         /* EventStreamErrorMarshallerGenerator.kt:131 */;
         Ok(::aws_smithy_types::event_stream::Message::new_from_parts(headers, payload))
         /* EventStreamErrorMarshallerGenerator.kt:99 */
-43
+    }
     /* EventStreamErrorMarshallerGenerator.kt:93 */
-45
+}
-46
 /* EventStreamMarshallerGenerator.kt:115 */
 #[non_exhaustive]
 #[derive(Debug)]
 pub struct AttemptCapturingPokemonEventMarshaller;
-51
 impl AttemptCapturingPokemonEventMarshaller {
     pub fn new() -> Self {
         AttemptCapturingPokemonEventMarshaller
-55
+    }
-56
+}
 /* EventStreamMarshallerGenerator.kt:129 */
 impl ::aws_smithy_eventstream::frame::MarshallMessage for AttemptCapturingPokemonEventMarshaller {
     /* EventStreamMarshallerGenerator.kt:133 */
     type Input = crate::types::AttemptCapturingPokemonEvent;
     /* EventStreamMarshallerGenerator.kt:135 */
     fn marshall(&self, input: Self::Input) -> std::result::Result<::aws_smithy_types::event_stream::Message, ::aws_smithy_eventstream::error::Error> {
         /* EventStreamMarshallerGenerator.kt:139 */
         let mut headers = Vec::new();
         /* EventStreamMarshallerGenerator.kt:322 */
         headers.push(::aws_smithy_types::event_stream::Header::new(
             ":message-type",
             ::aws_smithy_types::event_stream::HeaderValue::String("event".into()),
         ));
         /* EventStreamMarshallerGenerator.kt:141 */
         let payload = match input {
             Self::Input::Event(inner) =>  {
                 headers.push(::aws_smithy_types::event_stream::Header::new(":event-type", ::aws_smithy_types::event_stream::HeaderValue::String("event".into())));
                 headers.push(::aws_smithy_types::event_stream::Header::new(":content-type", ::aws_smithy_types::event_stream::HeaderValue::String("application/json".into())));
                 if let Some(inner_payload) = inner.payload {
                     crate::protocol_serde::shape_capturing_event::ser_payload_payload(&inner_payload)
             /* EventStreamMarshallerGenerator.kt:152 */Self::Input::Event(inner) =>  {
                 /* EventStreamMarshallerGenerator.kt:322 */headers.push(::aws_smithy_types::event_stream::Header::new(":event-type", ::aws_smithy_types::event_stream::HeaderValue::String("event".into())));
                 /* EventStreamMarshallerGenerator.kt:322 */headers.push(::aws_smithy_types::event_stream::Header::new(":content-type", ::aws_smithy_types::event_stream::HeaderValue::String("application/json".into())));
                 /* EventStreamMarshallerGenerator.kt:305 */if let Some(inner_payload) = inner.payload {
                     /* EventStreamMarshallerGenerator.kt:283 */crate::protocol_serde::shape_capturing_event::ser_payload_payload(&inner_payload)
                                                 .map_err(|err| ::aws_smithy_eventstream::error::Error::marshalling(format!("{}", err)))?
--
+                }
                  else  {
                     unimplemented!("TODO(EventStream): Figure out what to do when there's no payload")
--
+                }
--
+            }
             Self::Input::Unknown => return Err(
                 /* EventStreamMarshallerGenerator.kt:305 */}
                 /* EventStreamMarshallerGenerator.kt:309 */ else  {
                     /* EventStreamMarshallerGenerator.kt:292 */unimplemented!("TODO(EventStream): Figure out what to do when there's no payload")
                 /* EventStreamMarshallerGenerator.kt:309 */}
             /* EventStreamMarshallerGenerator.kt:152 */}
             /* EventStreamMarshallerGenerator.kt:159 */Self::Input::Unknown => return Err(
                                             ::aws_smithy_eventstream::error::Error::marshalling("Cannot serialize `AttemptCapturingPokemonEvent::Unknown` for the request. The `Unknown` variant is intended for responses only. It occurs when an outdated client is used after a new enum variant was added on the server side.".to_owned())
-85
+                                        )
--
+        }
--
+        ;
         /* EventStreamMarshallerGenerator.kt:141 */}
         /* EventStreamMarshallerGenerator.kt:169 */;
         Ok(::aws_smithy_types::event_stream::Message::new_from_parts(headers, payload))
         /* EventStreamMarshallerGenerator.kt:135 */
-90
+    }
     /* EventStreamMarshallerGenerator.kt:129 */
-92
+}
-93
 /* EventStreamUnmarshallerGenerator.kt:98 */
 #[non_exhaustive]
 #[derive(Debug)]
 pub struct CapturePokemonEventsUnmarshaller;
-98
 impl CapturePokemonEventsUnmarshaller {
     pub fn new() -> Self {
         CapturePokemonEventsUnmarshaller
-102
+    }
-103
+}
 /* EventStreamUnmarshallerGenerator.kt:112 */
 impl ::aws_smithy_eventstream::frame::UnmarshallMessage for CapturePokemonEventsUnmarshaller {
     /* EventStreamUnmarshallerGenerator.kt:116 */
     type Output = crate::types::CapturePokemonEvents;
     /* EventStreamUnmarshallerGenerator.kt:117 */
     type Error = crate::types::error::CapturePokemonEventsError;
     /* EventStreamUnmarshallerGenerator.kt:119 */
     fn unmarshall(
         &self,
         message: &::aws_smithy_types::event_stream::Message,
     ) -> std::result::Result<::aws_smithy_eventstream::frame::UnmarshalledMessage<Self::Output, Self::Error>, ::aws_smithy_eventstream::error::Error>
-115
+    {
         /* EventStreamUnmarshallerGenerator.kt:128 */
         let response_headers = ::aws_smithy_eventstream::smithy::parse_response_headers(message)?;
         /* EventStreamUnmarshallerGenerator.kt:129 */
         match response_headers.message_type.as_str() {
             /* EventStreamUnmarshallerGenerator.kt:130 */
             "event" => {
                 /* EventStreamUnmarshallerGenerator.kt:155 */
                 match response_headers.smithy_type.as_str() {
                     /* EventStreamUnmarshallerGenerator.kt:158 */
                     "event" => {
                         /* EventStreamUnmarshallerGenerator.kt:221 */
                         let mut builder = crate::types::builders::CaptureEventBuilder::default();
                         /* EventStreamUnmarshallerGenerator.kt:275 */
                         let content_type = response_headers.content_type().unwrap_or_default();
                         if content_type != "application/octet-stream" {
                             return Err(::aws_smithy_eventstream::error::Error::unmarshalling(format!(
                                 "expected :content-type to be 'application/octet-stream', but was '{}'",
                                 content_type
                             )));
-135
+                        }
                         builder = builder.set_pokedex_update(Some(::aws_smithy_types::Blob::new(message.payload().as_ref())));
                         /* EventStreamUnmarshallerGenerator.kt:288 */
                         builder = builder.set_pokedex_update(
                             /* EventStreamUnmarshallerGenerator.kt:289 */
                             Some(
                                 /* EventStreamUnmarshallerGenerator.kt:292 */
                                 ::aws_smithy_types::Blob::new(message.payload().as_ref()), /* EventStreamUnmarshallerGenerator.kt:289 */
                             ), /* EventStreamUnmarshallerGenerator.kt:288 */
                         );
                         /* EventStreamUnmarshallerGenerator.kt:228 */
                         for header in message.headers() {
                             /* EventStreamUnmarshallerGenerator.kt:229 */
                             match header.name().as_str() {
                                 /* EventStreamUnmarshallerGenerator.kt:231 */
                                 "name" => {
                                     builder = builder.set_name(Some(::aws_smithy_eventstream::smithy::expect_string(header)?));
                                     /* EventStreamUnmarshallerGenerator.kt:255 */
                                     builder = builder.set_name(
                                         /* EventStreamUnmarshallerGenerator.kt:256 */
                                         Some(
                                             /* EventStreamUnmarshallerGenerator.kt:264 */
                                             ::aws_smithy_eventstream::smithy::expect_string(header)?, /* EventStreamUnmarshallerGenerator.kt:256 */
                                         ), /* EventStreamUnmarshallerGenerator.kt:255 */
                                     );
                                     /* EventStreamUnmarshallerGenerator.kt:231 */
-159
+                                }
                                 /* EventStreamUnmarshallerGenerator.kt:231 */
                                 "captured" => {
                                     builder = builder.set_captured(Some(::aws_smithy_eventstream::smithy::expect_bool(header)?));
                                     /* EventStreamUnmarshallerGenerator.kt:255 */
                                     builder = builder.set_captured(
                                         /* EventStreamUnmarshallerGenerator.kt:256 */
                                         Some(
                                             /* EventStreamUnmarshallerGenerator.kt:258 */
                                             ::aws_smithy_eventstream::smithy::expect_bool(header)?, /* EventStreamUnmarshallerGenerator.kt:256 */
                                         ), /* EventStreamUnmarshallerGenerator.kt:255 */
                                     );
                                     /* EventStreamUnmarshallerGenerator.kt:231 */
-171
+                                }
                                 /* EventStreamUnmarshallerGenerator.kt:231 */
                                 "shiny" => {
                                     builder = builder.set_shiny(Some(::aws_smithy_eventstream::smithy::expect_bool(header)?));
                                     /* EventStreamUnmarshallerGenerator.kt:255 */
                                     builder = builder.set_shiny(
                                         /* EventStreamUnmarshallerGenerator.kt:256 */
                                         Some(
                                             /* EventStreamUnmarshallerGenerator.kt:258 */
                                             ::aws_smithy_eventstream::smithy::expect_bool(header)?, /* EventStreamUnmarshallerGenerator.kt:256 */
                                         ), /* EventStreamUnmarshallerGenerator.kt:255 */
                                     );
                                     /* EventStreamUnmarshallerGenerator.kt:231 */
-183
+                                }
                                 // Event stream protocol headers start with ':'
                                 /* EventStreamUnmarshallerGenerator.kt:235 */// Event stream protocol headers start with ':'
                                 /* EventStreamUnmarshallerGenerator.kt:236 */
                                 name => {
                                     if !name.starts_with(':') {
                                         /* EventStreamUnmarshallerGenerator.kt:237 */
                                         ::tracing::trace!("Unrecognized event stream message header: {}", name);
                                         /* EventStreamUnmarshallerGenerator.kt:236 */
-191
+                                    }
--
+                                }
                                 } /* EventStreamUnmarshallerGenerator.kt:229 */
-193
+                            }
                             /* EventStreamUnmarshallerGenerator.kt:228 */
-195
+                        }
                         /* EventStreamUnmarshallerGenerator.kt:245 */
                         Ok(::aws_smithy_eventstream::frame::UnmarshalledMessage::Event(
                             crate::types::CapturePokemonEvents::Event(builder.build()),
                         ))
                         /* EventStreamUnmarshallerGenerator.kt:158 */
-201
+                    }
                     _unknown_variant => Ok(::aws_smithy_eventstream::frame::UnmarshalledMessage::Event(
                         crate::types::CapturePokemonEvents::Unknown,
                     )),
                     /* EventStreamUnmarshallerGenerator.kt:162 */
                     _unknown_variant => {
                         /* EventStreamUnmarshallerGenerator.kt:165 */
                         Ok(::aws_smithy_eventstream::frame::UnmarshalledMessage::Event(
                             crate::types::CapturePokemonEvents::Unknown,
                         ))
                         /* EventStreamUnmarshallerGenerator.kt:162 */
                     } /* EventStreamUnmarshallerGenerator.kt:155 */
-210
+                }
                 /* EventStreamUnmarshallerGenerator.kt:130 */
-212
+            }
             /* EventStreamUnmarshallerGenerator.kt:133 */
             "exception" => {
                 /* EventStreamUnmarshallerGenerator.kt:332 */
                 let generic = match crate::protocol_serde::parse_event_stream_error_metadata(message.payload()) {
                     Ok(builder) => builder.build(),
                     Err(err) => {
                         return Ok(::aws_smithy_eventstream::frame::UnmarshalledMessage::Error(
                             crate::types::error::CapturePokemonEventsError::unhandled(err),
                         ))
-222
+                    }
                 };
                 /* EventStreamUnmarshallerGenerator.kt:356 */
                 match response_headers.smithy_type.as_str() {
                     /* EventStreamUnmarshallerGenerator.kt:358 */
                     "invalid_pokeball" => {
                         /* EventStreamUnmarshallerGenerator.kt:367 */
                         let mut builder = crate::types::error::builders::InvalidPokeballErrorBuilder::default();
                         /* EventStreamUnmarshallerGenerator.kt:368 */
                         builder =
                             crate::protocol_serde::shape_invalid_pokeball_error::de_invalid_pokeball_error_json_err(&message.payload()[..], builder)
                                 .map_err(|err| {
                                     ::aws_smithy_eventstream::error::Error::unmarshalling(format!("failed to unmarshall invalid_pokeball: {}", err))
                                 })?;
                         builder.set_meta(Some(generic));
                         return Ok(::aws_smithy_eventstream::frame::UnmarshalledMessage::Error(
                             crate::types::error::CapturePokemonEventsError::InvalidPokeballError(
                                 crate::serde_util::invalid_pokeball_error_correct_errors(builder)
                                     .build()
                                     .map_err(|err| ::aws_smithy_eventstream::error::Error::unmarshalling(format!("{}", err)))?,
                             ),
                         ));
                         /* EventStreamUnmarshallerGenerator.kt:358 */
-245
+                    }
                     /* EventStreamUnmarshallerGenerator.kt:358 */
                     "throttlingError" => {
                         /* EventStreamUnmarshallerGenerator.kt:367 */
                         let mut builder = crate::types::error::builders::ThrottlingErrorBuilder::default();
                         /* EventStreamUnmarshallerGenerator.kt:368 */
                         builder = crate::protocol_serde::shape_throttling_error::de_throttling_error_json_err(&message.payload()[..], builder)
                             .map_err(|err| {
                                 ::aws_smithy_eventstream::error::Error::unmarshalling(format!("failed to unmarshall throttlingError: {}", err))
                             })?;
                         builder.set_meta(Some(generic));
                         return Ok(::aws_smithy_eventstream::frame::UnmarshalledMessage::Error(
                             crate::types::error::CapturePokemonEventsError::ThrottlingError(builder.build()),
                         ));
                         /* EventStreamUnmarshallerGenerator.kt:358 */
-260
+                    }
                     _ => {}
                     /* EventStreamUnmarshallerGenerator.kt:434 */ _ => {} /* EventStreamUnmarshallerGenerator.kt:435 */
-262
+                }
                 /* EventStreamUnmarshallerGenerator.kt:440 */
                 Ok(::aws_smithy_eventstream::frame::UnmarshalledMessage::Error(
                     crate::types::error::CapturePokemonEventsError::generic(generic),
                 ))
                 /* EventStreamUnmarshallerGenerator.kt:133 */
-268
+            }
             /* EventStreamUnmarshallerGenerator.kt:136 */
             value => {
                 /* EventStreamUnmarshallerGenerator.kt:137 */
                 return Err(::aws_smithy_eventstream::error::Error::unmarshalling(format!(
                     "unrecognized :message-type: {}",
                     value
                 )));
--
+            }
                 /* EventStreamUnmarshallerGenerator.kt:136 */
             } /* EventStreamUnmarshallerGenerator.kt:129 */
-278
+        }
         /* EventStreamUnmarshallerGenerator.kt:119 */
-280
+    }
     /* EventStreamUnmarshallerGenerator.kt:112 */
-282
+}

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/lib.rs

@@ -18,18 +118,130 @@

↥ Expand context

 #![forbid(unsafe_code)]
 #![warn(missing_docs)]
 #![cfg_attr(docsrs, feature(doc_auto_cfg))]
 //! The Pokémon Service allows you to retrieve information about Pokémon species.
 //!
 //! # Crate Organization
 //!
 //! The entry point for most customers will be [`Client`], which exposes one method for each API
 //! offered by Pokémon Service. The return value of each of these methods is a "fluent builder",
 //! where the different inputs for that API are added by builder-style function call chaining,
 //! followed by calling `send()` to get a [`Future`](std::future::Future) that will result in
 //! either a successful output or a [`SdkError`](crate::error::SdkError).
 //!
 //! Some of these API inputs may be structs or enums to provide more complex structured information.
 //! These structs and enums live in [`types`](crate::types). There are some simpler types for
 //! representing data such as date times or binary blobs that live in [`primitives`](crate::primitives).
 //!
 //! All types required to configure a client via the [`Config`](crate::Config) struct live
 //! in [`config`](crate::config).
 //!

 //! The [`operation`](crate::operation) module has a submodule for every API, and in each submodule
 //! is the input, output, and error type for that API, as well as builders to construct each of those.
 //!
 //! There is a top-level [`Error`](crate::Error) type that encompasses all the errors that the
 //! client can return. Any other error type can be converted to this `Error` type via the
 //! [`From`](std::convert::From) trait.
 //!
 //! The other modules within this crate are not required for normal usage.
-46
 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* ServiceErrorGenerator.kt:127 */
 pub use error_meta::Error;
-50
 /* RustType.kt:516 */
 #[doc(inline)]
 /* ServiceGenerator.kt:63 */
 pub use config::Config;
-55
 /// Client for calling Pokémon Service.
 /// /* FluentClientDocs.kt:24 */Client for calling Pokémon Service.
 ///
 /// ## Constructing a `Client`
 ///
 /// A `Client` requires a config in order to be constructed. With the default set of Cargo features,
 /// this config will only require an endpoint to produce a functioning client. However, some Smithy
 /// features will require additional configuration. For example, `@auth` requires some kind of identity
 /// or identity resolver to be configured. The config is used to customize various aspects of the client,
 /// such as:
 ///
 ///   - [The underlying HTTP client](crate::config::Builder::http_client)
 ///   - [Retries](crate::config::Builder::retry_config)
 ///   - [Timeouts](crate::config::Builder::timeout_config)
 ///   - [... and more](crate::config::Builder)
 ///
 /// Below is a minimal example of how to create a client:
 ///
 /// ```rust,no_run
 /// let config = pokemon_service_awsjson_client::Config::builder()
 ///     .endpoint_url("http://localhost:1234")
 ///     .build();
 /// let client = pokemon_service_awsjson_client::Client::from_conf(config);
 /// ```
 ///
 /// _Note:_ Client construction is expensive due to connection thread pool initialization, and should be done
 /// once at application start-up. Cloning a client is cheap (it's just an [`Arc`](std::sync::Arc) under the hood),
 /// so creating it once at start-up and cloning it around the application as needed is recommended.
 pub mod client;
-84
 /// Configuration for Pokémon Service.
 /// /* ClientRustModule.kt:121 */Configuration for Pokémon Service.
 pub mod config;
-87
 /// Common errors and error handling utilities.
 /// /* ClientRustModule.kt:121 */Common errors and error handling utilities.
 pub mod error;
-90
 /* RustModule.kt:172 */
 mod error_meta;
-93
 /// Information about this crate.
 /// /* ClientRustModule.kt:121 */Information about this crate.
 pub mod meta;
-96
 /// Primitives such as `Blob` or `DateTime` used by other types.
 /// /* ClientRustModule.kt:121 */Primitives such as `Blob` or `DateTime` used by other types.
 pub mod primitives;
-99
 /// Data structures used by operation inputs/outputs.
 /// /* ClientRustModule.kt:121 */Data structures used by operation inputs/outputs.
 pub mod types;
-102
 /* RustModule.kt:172 */
 mod auth_plugin;
-105
 /* RustModule.kt:172 */
 mod event_receiver;
-108
 /* RustModule.kt:172 */
 mod event_stream_serde;
-111
 /// All operations that this crate can perform.
 /// /* ClientRustModule.kt:121 */All operations that this crate can perform.
 pub mod operation;
-114
 pub(crate) mod protocol_serde;
-116
 /* RustModule.kt:172 */
 mod sdk_feature_tracker;
-119
 /* RustModule.kt:172 */
 mod serialization_settings;
-122
 /* RustModule.kt:172 */
 mod serde_util;
-125
 /* RustModule.kt:172 */
 mod json_errors;
-128
 /* FluentClientDecorator.kt:76 */
 pub use client::Client;

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/meta.rs

@@ -1,1 +4,5 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
-2
 /* CrateVersionCustomization.kt:23 */
 /// Crate version number.
 pub static PKG_VERSION: &str = env!("CARGO_PKG_VERSION");

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/operation.rs

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

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
--
 /// Types for the `CapturePokemon` operation.
 /* CodegenDelegator.kt:51 */
 /// /* CodegenDelegator.kt:51 */Types for the `CapturePokemon` operation.
 pub mod capture_pokemon;
-5
 /// Types for the `CheckHealth` operation.
 /// /* CodegenDelegator.kt:51 */Types for the `CheckHealth` operation.
 pub mod check_health;
-8
 /// Types for the `DoNothing` operation.
 /// /* CodegenDelegator.kt:51 */Types for the `DoNothing` operation.
 pub mod do_nothing;
-11
 /// Types for the `GetServerStatistics` operation.
 /// /* CodegenDelegator.kt:51 */Types for the `GetServerStatistics` operation.
 pub mod get_server_statistics;

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

@@ -57,66 +190,203 @@

↥ Expand context

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

                 runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
-87
+            }
             runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
                 config_override,
                 client_config.config.clone(),
                 &client_config.runtime_components,
             ));
-93
+        }
         runtime_plugins
-95
+    }
     /* OperationGenerator.kt:85 */
-97
+}
 /* OperationRuntimePluginGenerator.kt:55 */
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for CapturePokemon {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         let mut cfg = ::aws_smithy_types::config_bag::Layer::new("CapturePokemon");
-102
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
             CapturePokemonRequestSerializer,
         ));
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
             CapturePokemonResponseDeserializer,
         ));
-109
         cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
             ::aws_smithy_runtime_api::client::auth::static_resolver::StaticAuthSchemeOptionResolverParams::new(),
         ));
-113
         cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
             "CapturePokemon",
             "PokemonService",
         ));
-118
         ::std::option::Option::Some(cfg.freeze())
-120
+    }
-121
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         #[allow(unused_mut)]
         let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("CapturePokemon")
             .with_interceptor(CapturePokemonEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::capture_pokemon::CapturePokemonError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::capture_pokemon::CapturePokemonError,
             >::new());
-135
         ::std::borrow::Cow::Owned(rcb)
-137
+    }
-138
+}
-139
 /* ResponseDeserializerGenerator.kt:64 */
 #[derive(Debug)]
 struct CapturePokemonResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for CapturePokemonResponseDeserializer {
     fn deserialize_streaming(
         &self,
         response: &mut ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
     ) -> ::std::option::Option<::aws_smithy_runtime_api::client::interceptors::context::OutputOrError> {
         #[allow(unused_mut)]
         let mut force_error = false;
-150
         // If this is an error, defer to the non-streaming parser
         if (!response.status().is_success() && response.status().as_u16() != 200) || force_error {
             return ::std::option::Option::None;
-154
+        }
         ::std::option::Option::Some(crate::protocol_serde::type_erase_result(
             crate::protocol_serde::shape_capture_pokemon::de_capture_pokemon_http_response(response),
         ))
-158
+    }
-159
     fn deserialize_nonstreaming(
         &self,
         response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
     ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
         // For streaming operations, we only hit this case if its an error
         let body = response.body().bytes().expect("body loaded");
         crate::protocol_serde::type_erase_result(crate::protocol_serde::shape_capture_pokemon::de_capture_pokemon_http_error(
             response.status().as_u16(),
             response.headers(),
             body,
         ))
-171
+    }
-172
+}
 /* RequestSerializerGenerator.kt:67 */
 #[derive(Debug)]
 struct CapturePokemonRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for CapturePokemonRequestSerializer {
     #[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::capture_pokemon::CapturePokemonInput>()
             .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::capture_pokemon::CapturePokemonInput,
                 output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 use ::std::fmt::Write as _;
                 ::std::write!(output, "/").expect("formatting should succeed");
                 ::std::result::Result::Ok(())
-198
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::capture_pokemon::CapturePokemonInput,
                 builder: ::http::request::Builder,
             ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {

@@ -192,205 +404,597 @@

↥ Expand context

                 uri_base(input, &mut uri)?;
                 ::std::result::Result::Ok(builder.method("POST").uri(uri))
-207
+            }
             let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
             builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/x-amz-json-1.0");
             builder = _header_serialization_settings.set_default_header(
                 builder,
                 ::http::header::HeaderName::from_static("x-amz-target"),
                 "PokemonService.CapturePokemon",
             );
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from({
             let error_marshaller = crate::event_stream_serde::AttemptCapturingPokemonEventErrorMarshaller::new();
             let marshaller = crate::event_stream_serde::AttemptCapturingPokemonEventMarshaller::new();
             let (signer, signer_sender) = ::aws_smithy_eventstream::frame::DeferredSigner::new();
             _cfg.interceptor_state().store_put(signer_sender);
             ::aws_smithy_types::body::SdkBody::from_body_0_4(::hyper::Body::wrap_stream(input.events.into_body_stream(
                 marshaller,
                 error_marshaller,

                 signer,
             )))
         });
         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);
-231
+        }
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
-233
+    }
-234
+}
 /* EndpointParamsInterceptorGenerator.kt:86 */
 #[derive(Debug)]
 struct CapturePokemonEndpointParamsInterceptor;
-238
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for CapturePokemonEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "CapturePokemonEndpointParamsInterceptor"
-242
+    }
-243
     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::<CapturePokemonInput>()
             .ok_or("failed to downcast to CapturePokemonInput")?;
-258
         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(())
-265
+    }
-266
+}
-267
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-270
 /* OperationErrorGenerator.kt:79 */
 /// Error type for the `CapturePokemonError` operation.
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::fmt::Debug)]
 pub enum CapturePokemonError {
     /// A standard error for input validation failures. This should be thrown by services when a member of the input structure falls outside of the modeled or documented constraints.
 pub /* OperationErrorGenerator.kt:81 */ enum CapturePokemonError {
     /// /* OperationErrorGenerator.kt:83 */A standard error for input validation failures. This should be thrown by services when a member of the input structure falls outside of the modeled or documented constraints.
     /* OperationErrorGenerator.kt:86 */
     ValidationError(crate::types::error::ValidationError),
     /* OperationErrorGenerator.kt:83 */
     #[allow(missing_docs)] // documentation missing in model
     /* OperationErrorGenerator.kt:86 */
     MasterBallUnsuccessful(crate::types::error::MasterBallUnsuccessful),
     /* OperationErrorGenerator.kt:83 */
     #[allow(missing_docs)] // documentation missing in model
     /* OperationErrorGenerator.kt:86 */
     InvalidPokeballError(crate::types::error::InvalidPokeballError),
     /* OperationErrorGenerator.kt:83 */
     #[allow(missing_docs)] // documentation missing in model
     /* OperationErrorGenerator.kt:86 */
     ThrottlingError(crate::types::error::ThrottlingError),
     /* OperationErrorGenerator.kt:83 */
     #[allow(missing_docs)] // documentation missing in model
     /* OperationErrorGenerator.kt:86 */
     UnsupportedRegionError(crate::types::error::UnsupportedRegionError),
     /* 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()`:
-301
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-303
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-CapturePokemonError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
     /* OperationErrorGenerator.kt:81 */
-307
+}
 /* OperationErrorGenerator.kt:218 */
 impl CapturePokemonError {
     /* OperationErrorGenerator.kt:219 */
     /// Creates the `CapturePokemonError::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(),
         })
-319
+    }
-320
     /// Creates the `CapturePokemonError::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,
         })
-327
+    }
     ///
     /// /* 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::ValidationError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
             /* OperationErrorGenerator.kt:246 */ Self::ValidationError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
             /* OperationErrorGenerator.kt:246 */
             Self::MasterBallUnsuccessful(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
             /* OperationErrorGenerator.kt:246 */
             Self::InvalidPokeballError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
             Self::ThrottlingError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
             /* OperationErrorGenerator.kt:246 */ Self::ThrottlingError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
             /* OperationErrorGenerator.kt:246 */
             Self::UnsupportedRegionError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
             Self::Unhandled(e) => &e.meta,
             /* OperationErrorGenerator.kt:251 */ Self::Unhandled(e) => &e.meta,
             /* OperationErrorGenerator.kt:243 */
-346
+        }
         /* OperationErrorGenerator.kt:242 */
-348
+    }
     /* OperationErrorGenerator.kt:257 */
     /// Returns `true` if the error kind is `CapturePokemonError::ValidationError`.
     /* OperationErrorGenerator.kt:258 */
     pub fn is_validation_error(&self) -> bool {
         /* OperationErrorGenerator.kt:259 */
         matches!(self, Self::ValidationError(_))
         /* OperationErrorGenerator.kt:258 */
-356
+    }
     /* OperationErrorGenerator.kt:257 */
     /// Returns `true` if the error kind is `CapturePokemonError::MasterBallUnsuccessful`.
     /* OperationErrorGenerator.kt:258 */
     pub fn is_master_ball_unsuccessful(&self) -> bool {
         /* OperationErrorGenerator.kt:259 */
         matches!(self, Self::MasterBallUnsuccessful(_))
         /* OperationErrorGenerator.kt:258 */
-364
+    }
     /* OperationErrorGenerator.kt:257 */
     /// Returns `true` if the error kind is `CapturePokemonError::InvalidPokeballError`.
     /* OperationErrorGenerator.kt:258 */
     pub fn is_invalid_pokeball_error(&self) -> bool {
         /* OperationErrorGenerator.kt:259 */
         matches!(self, Self::InvalidPokeballError(_))
         /* OperationErrorGenerator.kt:258 */
-372
+    }
     /* OperationErrorGenerator.kt:257 */
     /// Returns `true` if the error kind is `CapturePokemonError::ThrottlingError`.
     /* OperationErrorGenerator.kt:258 */
     pub fn is_throttling_error(&self) -> bool {
         /* OperationErrorGenerator.kt:259 */
         matches!(self, Self::ThrottlingError(_))
         /* OperationErrorGenerator.kt:258 */
-380
+    }
     /* OperationErrorGenerator.kt:257 */
     /// Returns `true` if the error kind is `CapturePokemonError::UnsupportedRegionError`.
     /* OperationErrorGenerator.kt:258 */
     pub fn is_unsupported_region_error(&self) -> bool {
         /* OperationErrorGenerator.kt:259 */
         matches!(self, Self::UnsupportedRegionError(_))
         /* OperationErrorGenerator.kt:258 */
-388
+    }
     /* OperationErrorGenerator.kt:218 */
-390
+}
 /* OperationErrorGenerator.kt:269 */
 impl ::std::error::Error for CapturePokemonError {
     /* OperationErrorGenerator.kt:270 */
     fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
         /* OperationErrorGenerator.kt:318 */
         match self {
             Self::ValidationError(_inner) => ::std::option::Option::Some(_inner),
             Self::MasterBallUnsuccessful(_inner) => ::std::option::Option::Some(_inner),
             Self::InvalidPokeballError(_inner) => ::std::option::Option::Some(_inner),
             Self::ThrottlingError(_inner) => ::std::option::Option::Some(_inner),
             Self::UnsupportedRegionError(_inner) => ::std::option::Option::Some(_inner),
             Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
             /* OperationErrorGenerator.kt:321 */
             Self::ValidationError(_inner) =>
             /* OperationErrorGenerator.kt:283 */
-+
+            {
                 ::std::option::Option::Some(_inner)
-+
+            }
-+
+            ,
             /* OperationErrorGenerator.kt:321 */
             Self::MasterBallUnsuccessful(_inner) =>
             /* OperationErrorGenerator.kt:283 */
-+
+            {
                 ::std::option::Option::Some(_inner)
-+
+            }
-+
+            ,
             /* OperationErrorGenerator.kt:321 */
             Self::InvalidPokeballError(_inner) =>
             /* OperationErrorGenerator.kt:283 */
-+
+            {
                 ::std::option::Option::Some(_inner)
-+
+            }
-+
+            ,
             /* OperationErrorGenerator.kt:321 */
             Self::ThrottlingError(_inner) =>
             /* OperationErrorGenerator.kt:283 */
-+
+            {
                 ::std::option::Option::Some(_inner)
-+
+            }
-+
+            ,
             /* OperationErrorGenerator.kt:321 */
             Self::UnsupportedRegionError(_inner) =>
             /* OperationErrorGenerator.kt:283 */
-+
+            {
                 ::std::option::Option::Some(_inner)
-+
+            }
-+
+            ,
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:279 */
                 ::std::option::Option::Some(&*_inner.source)
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-438
+        }
         /* OperationErrorGenerator.kt:270 */
-440
+    }
     /* OperationErrorGenerator.kt:269 */
-442
+}
 /* OperationErrorGenerator.kt:133 */
 impl ::std::fmt::Display for CapturePokemonError {
     /* OperationErrorGenerator.kt:134 */
     fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
         /* OperationErrorGenerator.kt:318 */
         match self {
             Self::ValidationError(_inner) => _inner.fmt(f),
             Self::MasterBallUnsuccessful(_inner) => _inner.fmt(f),
             Self::InvalidPokeballError(_inner) => _inner.fmt(f),
             Self::ThrottlingError(_inner) => _inner.fmt(f),
             Self::UnsupportedRegionError(_inner) => _inner.fmt(f),
             /* OperationErrorGenerator.kt:321 */
             Self::ValidationError(_inner) =>
             /* OperationErrorGenerator.kt:151 */
-+
+            {
                 _inner.fmt(f)
-+
+            }
-+
+            ,
             /* OperationErrorGenerator.kt:321 */
             Self::MasterBallUnsuccessful(_inner) =>
             /* OperationErrorGenerator.kt:151 */
-+
+            {
                 _inner.fmt(f)
-+
+            }
-+
+            ,
             /* OperationErrorGenerator.kt:321 */
             Self::InvalidPokeballError(_inner) =>
             /* OperationErrorGenerator.kt:151 */
-+
+            {
                 _inner.fmt(f)
-+
+            }
-+
+            ,
             /* OperationErrorGenerator.kt:321 */
             Self::ThrottlingError(_inner) =>
             /* OperationErrorGenerator.kt:151 */
-+
+            {
                 _inner.fmt(f)
-+
+            }
-+
+            ,
             /* OperationErrorGenerator.kt:321 */
             Self::UnsupportedRegionError(_inner) =>
             /* OperationErrorGenerator.kt:151 */
-+
+            {
                 _inner.fmt(f)
-+
+            }
-+
+            ,
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:139 */
                 if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
                     write!(f, "unhandled error ({code})")
                 } else {
                     f.write_str("unhandled error")
-491
+                }
--
+            }
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-494
+        }
         /* OperationErrorGenerator.kt:134 */
-496
+    }
     /* OperationErrorGenerator.kt:133 */
-498
+}
 /* OperationErrorGenerator.kt:182 */
 impl ::aws_smithy_types::retry::ProvideErrorKind for CapturePokemonError {
     /* OperationErrorGenerator.kt:186 */
     fn code(&self) -> ::std::option::Option<&str> {
         /* OperationErrorGenerator.kt:187 */
         ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
         /* OperationErrorGenerator.kt:186 */
-506
+    }
     /* 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 */
-512
+    }
     /* OperationErrorGenerator.kt:182 */
-514
+}
 /* OperationErrorGenerator.kt:163 */
 impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for CapturePokemonError {
     /* OperationErrorGenerator.kt:164 */
     fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         /* OperationErrorGenerator.kt:318 */
         match self {
             Self::ValidationError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
             Self::MasterBallUnsuccessful(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
             Self::InvalidPokeballError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
             Self::ThrottlingError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
             Self::UnsupportedRegionError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
             Self::Unhandled(_inner) => &_inner.meta,
             /* OperationErrorGenerator.kt:321 */
             Self::ValidationError(_inner) =>
             /* OperationErrorGenerator.kt:169 */
-+
+            {
                 ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
-+
+            }
-+
+            ,
             /* OperationErrorGenerator.kt:321 */
             Self::MasterBallUnsuccessful(_inner) =>
             /* OperationErrorGenerator.kt:169 */
-+
+            {
                 ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
-+
+            }
-+
+            ,
             /* OperationErrorGenerator.kt:321 */
             Self::InvalidPokeballError(_inner) =>
             /* OperationErrorGenerator.kt:169 */
-+
+            {
                 ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
-+
+            }
-+
+            ,
             /* OperationErrorGenerator.kt:321 */
             Self::ThrottlingError(_inner) =>
             /* OperationErrorGenerator.kt:169 */
-+
+            {
                 ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
-+
+            }
-+
+            ,
             /* OperationErrorGenerator.kt:321 */
             Self::UnsupportedRegionError(_inner) =>
             /* OperationErrorGenerator.kt:169 */
-+
+            {
                 ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
-+
+            }
-+
+            ,
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:168 */
                 &_inner.meta
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-562
+        }
         /* OperationErrorGenerator.kt:164 */
-564
+    }
     /* OperationErrorGenerator.kt:163 */
-566
+}
 /* OperationErrorGenerator.kt:109 */
 impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for CapturePokemonError {
     /* 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 */
-580
+    }
     /* OperationErrorGenerator.kt:109 */
-582
+}
-583
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::capture_pokemon::_capture_pokemon_output::CapturePokemonOutput;
-586
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::capture_pokemon::_capture_pokemon_input::CapturePokemonInput;
-589
 /* RustModule.kt:172 */
 mod _capture_pokemon_input;
-592
 /* RustModule.kt:172 */
 mod _capture_pokemon_output;
-595
 /// Builders
 /// /* CodegenDelegator.kt:51 */Builders
 pub mod builders;

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/operation/capture_pokemon/_capture_pokemon_input.rs

@@ -1,1 +96,142 @@

 // 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::fmt::Debug)]
 pub struct CapturePokemonInput {
 pub /* StructureGenerator.kt:201 */ struct CapturePokemonInput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
     pub events: ::aws_smithy_http::event_stream::EventStreamSender<
         crate::types::AttemptCapturingPokemonEvent,
         crate::types::error::AttemptCapturingPokemonEventError,
     >,
     /* StructureGenerator.kt:201 */
-16
+}
 /* StructureGenerator.kt:135 */
 impl CapturePokemonInput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
                            /* StructureGenerator.kt:166 */
     pub fn events(
         &self,
     ) -> &::aws_smithy_http::event_stream::EventStreamSender<
         crate::types::AttemptCapturingPokemonEvent,
         crate::types::error::AttemptCapturingPokemonEventError,
     > {
         /* StructureGenerator.kt:172 */
         &self.events
         /* StructureGenerator.kt:166 */
-31
+    }
     /* StructureGenerator.kt:135 */
-33
+}
 /* ClientCodegenVisitor.kt:237 */
 impl CapturePokemonInput {
     /// Creates a new builder-style object to manufacture [`CapturePokemonInput`](crate::operation::capture_pokemon::CapturePokemonInput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`CapturePokemonInput`](crate::operation::capture_pokemon::CapturePokemonInput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::capture_pokemon::builders::CapturePokemonInputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::capture_pokemon::builders::CapturePokemonInputBuilder::default()
         /* BuilderGenerator.kt:175 */
-42
+    }
     /* RustType.kt:516 */
     #[allow(unused)]
     /* BuilderGenerator.kt:189 */
     pub(crate) fn into_builder(self) -> crate::operation::capture_pokemon::builders::CapturePokemonInputBuilder {
         Self::builder().events(self.events)
         /* BuilderGenerator.kt:190 */
         Self::builder()
             /* BuilderGenerator.kt:199 */
             .events(self.events)
         /* BuilderGenerator.kt:189 */
-52
+    }
     /* ClientCodegenVisitor.kt:237 */
-54
+}
-55
 /// A builder for [`CapturePokemonInput`](crate::operation::capture_pokemon::CapturePokemonInput).
 /// /* BuilderGenerator.kt:342 */A builder for [`CapturePokemonInput`](crate::operation::capture_pokemon::CapturePokemonInput).
 /* RustType.kt:516 */
 #[derive(::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* BuilderGenerator.kt:345 */
 pub struct CapturePokemonInputBuilder {
     /* BuilderGenerator.kt:275 */
     pub(crate) events: ::std::option::Option<
         ::aws_smithy_http::event_stream::EventStreamSender<
             crate::types::AttemptCapturingPokemonEvent,
             crate::types::error::AttemptCapturingPokemonEventError,
         >,
     >,
     /* BuilderGenerator.kt:345 */
-71
+}
 /* BuilderGenerator.kt:355 */
 impl CapturePokemonInputBuilder {
     /* BuilderGenerator.kt:286 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:291 */
     pub fn events(
         mut self,
         input: ::aws_smithy_http::event_stream::EventStreamSender<
             crate::types::AttemptCapturingPokemonEvent,
             crate::types::error::AttemptCapturingPokemonEventError,
         >,
     ) -> Self {
         /* BuilderGenerator.kt:292 */
         self.events = ::std::option::Option::Some(input);
         /* BuilderGenerator.kt:293 */
         self
         /* BuilderGenerator.kt:291 */
-89
+    }
     /* BuilderGenerator.kt:312 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:314 */
     pub fn set_events(
         mut self,
         input: ::std::option::Option<
             ::aws_smithy_http::event_stream::EventStreamSender<
                 crate::types::AttemptCapturingPokemonEvent,
                 crate::types::error::AttemptCapturingPokemonEventError,
             >,
         >,
     ) -> Self {
         /* BuilderGenerator.kt:315 */
         self.events = input;
         self
         /* BuilderGenerator.kt:314 */
-106
+    }
     /* BuilderGenerator.kt:334 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:336 */
     pub fn get_events(
         &self,
     ) -> &::std::option::Option<
         ::aws_smithy_http::event_stream::EventStreamSender<
             crate::types::AttemptCapturingPokemonEvent,
             crate::types::error::AttemptCapturingPokemonEventError,
         >,
     > {
         /* BuilderGenerator.kt:337 */
         &self.events
         /* BuilderGenerator.kt:336 */
-121
+    }
     /// Consumes the builder and constructs a [`CapturePokemonInput`](crate::operation::capture_pokemon::CapturePokemonInput).
     /// This method will fail if any of the following fields are not set:
     /// - [`events`](crate::operation::capture_pokemon::builders::CapturePokemonInputBuilder::events)
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`CapturePokemonInput`](crate::operation::capture_pokemon::CapturePokemonInput).
     /// /* BuilderGenerator.kt:243 */This method will fail if any of the following fields are not set:
     /// /* BuilderGenerator.kt:246 */- [`events`](crate::operation::capture_pokemon::builders::CapturePokemonInputBuilder::events)
     /* BuilderGenerator.kt:253 */
     pub fn build(
         self,
     ) -> ::std::result::Result<crate::operation::capture_pokemon::CapturePokemonInput, ::aws_smithy_types::error::operation::BuildError> {
         ::std::result::Result::Ok(crate::operation::capture_pokemon::CapturePokemonInput {
             events: self.events.ok_or_else(|| {
                 ::aws_smithy_types::error::operation::BuildError::missing_field(
                     "events",
                     "events was not specified but it is required when building CapturePokemonInput",
--
+                )
             })?,
         })
         /* BuilderGenerator.kt:254 */
         ::std::result::Result::Ok(
             /* BuilderGenerator.kt:477 */crate::operation::capture_pokemon::CapturePokemonInput {
                 /* BuilderGenerator.kt:481 */events: self.events
                     /* BuilderGenerator.kt:494 */.ok_or_else(||
                         /* BuilderGenerator.kt:117 */::aws_smithy_types::error::operation::BuildError::missing_field("events", "events was not specified but it is required when building CapturePokemonInput")
                     /* BuilderGenerator.kt:494 */)?
-+
+                ,
             /* BuilderGenerator.kt:477 */}
         /* BuilderGenerator.kt:254 */)
         /* BuilderGenerator.kt:253 */
-140
+    }
     /* BuilderGenerator.kt:355 */
-142
+}

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/operation/capture_pokemon/_capture_pokemon_output.rs

@@ -1,1 +78,124 @@

 // 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::fmt::Debug)]
 pub struct CapturePokemonOutput {
 pub /* StructureGenerator.kt:201 */ struct CapturePokemonOutput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
     pub events: crate::event_receiver::EventReceiver<crate::types::CapturePokemonEvents, crate::types::error::CapturePokemonEventsError>,
     /* StructureGenerator.kt:201 */
-13
+}
 /* StructureGenerator.kt:135 */
 impl CapturePokemonOutput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
                            /* StructureGenerator.kt:166 */
     pub fn events(
         &self,
     ) -> &crate::event_receiver::EventReceiver<crate::types::CapturePokemonEvents, crate::types::error::CapturePokemonEventsError> {
         /* StructureGenerator.kt:172 */
         &self.events
         /* StructureGenerator.kt:166 */
-25
+    }
     /* StructureGenerator.kt:135 */
-27
+}
 /* ClientCodegenVisitor.kt:237 */
 impl CapturePokemonOutput {
     /// Creates a new builder-style object to manufacture [`CapturePokemonOutput`](crate::operation::capture_pokemon::CapturePokemonOutput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`CapturePokemonOutput`](crate::operation::capture_pokemon::CapturePokemonOutput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::capture_pokemon::builders::CapturePokemonOutputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::capture_pokemon::builders::CapturePokemonOutputBuilder::default()
         /* BuilderGenerator.kt:175 */
-36
+    }
     /* RustType.kt:516 */
     #[allow(unused)]
     /* BuilderGenerator.kt:189 */
     pub(crate) fn into_builder(self) -> crate::operation::capture_pokemon::builders::CapturePokemonOutputBuilder {
         Self::builder().events(self.events)
         /* BuilderGenerator.kt:190 */
         Self::builder()
             /* BuilderGenerator.kt:199 */
             .events(self.events)
         /* BuilderGenerator.kt:189 */
-46
+    }
     /* ClientCodegenVisitor.kt:237 */
-48
+}
-49
 /// A builder for [`CapturePokemonOutput`](crate::operation::capture_pokemon::CapturePokemonOutput).
 /// /* BuilderGenerator.kt:342 */A builder for [`CapturePokemonOutput`](crate::operation::capture_pokemon::CapturePokemonOutput).
 /* RustType.kt:516 */
 #[derive(::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* BuilderGenerator.kt:345 */
 pub struct CapturePokemonOutputBuilder {
     /* BuilderGenerator.kt:275 */
     pub(crate) events: ::std::option::Option<
         crate::event_receiver::EventReceiver<crate::types::CapturePokemonEvents, crate::types::error::CapturePokemonEventsError>,
     >,
     /* BuilderGenerator.kt:345 */
-62
+}
 /* BuilderGenerator.kt:355 */
 impl CapturePokemonOutputBuilder {
     /* BuilderGenerator.kt:286 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:291 */
     pub fn events(
         mut self,
         input: crate::event_receiver::EventReceiver<crate::types::CapturePokemonEvents, crate::types::error::CapturePokemonEventsError>,
     ) -> Self {
         /* BuilderGenerator.kt:292 */
         self.events = ::std::option::Option::Some(input);
         /* BuilderGenerator.kt:293 */
         self
         /* BuilderGenerator.kt:291 */
-77
+    }
     /* BuilderGenerator.kt:312 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:314 */
     pub fn set_events(
         mut self,
         input: ::std::option::Option<
             crate::event_receiver::EventReceiver<crate::types::CapturePokemonEvents, crate::types::error::CapturePokemonEventsError>,
         >,
     ) -> Self {
         /* BuilderGenerator.kt:315 */
         self.events = input;
         self
         /* BuilderGenerator.kt:314 */
-91
+    }
     /* BuilderGenerator.kt:334 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:336 */
     pub fn get_events(
         &self,
     ) -> &::std::option::Option<
         crate::event_receiver::EventReceiver<crate::types::CapturePokemonEvents, crate::types::error::CapturePokemonEventsError>,
     > {
         /* BuilderGenerator.kt:337 */
         &self.events
         /* BuilderGenerator.kt:336 */
-103
+    }
     /// Consumes the builder and constructs a [`CapturePokemonOutput`](crate::operation::capture_pokemon::CapturePokemonOutput).
     /// This method will fail if any of the following fields are not set:
     /// - [`events`](crate::operation::capture_pokemon::builders::CapturePokemonOutputBuilder::events)
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`CapturePokemonOutput`](crate::operation::capture_pokemon::CapturePokemonOutput).
     /// /* BuilderGenerator.kt:243 */This method will fail if any of the following fields are not set:
     /// /* BuilderGenerator.kt:246 */- [`events`](crate::operation::capture_pokemon::builders::CapturePokemonOutputBuilder::events)
     /* BuilderGenerator.kt:253 */
     pub fn build(
         self,
     ) -> ::std::result::Result<crate::operation::capture_pokemon::CapturePokemonOutput, ::aws_smithy_types::error::operation::BuildError> {
         ::std::result::Result::Ok(crate::operation::capture_pokemon::CapturePokemonOutput {
             events: self.events.ok_or_else(|| {
                 ::aws_smithy_types::error::operation::BuildError::missing_field(
                     "events",
                     "events was not specified but it is required when building CapturePokemonOutput",
--
+                )
             })?,
         })
         /* BuilderGenerator.kt:254 */
         ::std::result::Result::Ok(
             /* BuilderGenerator.kt:477 */crate::operation::capture_pokemon::CapturePokemonOutput {
                 /* BuilderGenerator.kt:481 */events: self.events
                     /* BuilderGenerator.kt:494 */.ok_or_else(||
                         /* BuilderGenerator.kt:117 */::aws_smithy_types::error::operation::BuildError::missing_field("events", "events was not specified but it is required when building CapturePokemonOutput")
                     /* BuilderGenerator.kt:494 */)?
-+
+                ,
             /* BuilderGenerator.kt:477 */}
         /* BuilderGenerator.kt:254 */)
         /* BuilderGenerator.kt:253 */
-122
+    }
     /* BuilderGenerator.kt:355 */
-124
+}

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/operation/capture_pokemon/builders.rs

@@ -1,1 +98,108 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::capture_pokemon::_capture_pokemon_output::CapturePokemonOutputBuilder;
-4
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::capture_pokemon::_capture_pokemon_input::CapturePokemonInputBuilder;
-7
 /* FluentBuilderGenerator.kt:408 */
 impl crate::operation::capture_pokemon::builders::CapturePokemonInputBuilder {
     /// Sends a request with this input using the given client.
     pub async fn send_with(
         self,
         client: &crate::Client,
     ) -> ::std::result::Result<
         crate::operation::capture_pokemon::CapturePokemonOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::capture_pokemon::CapturePokemonError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {
         let mut fluent_builder = client.capture_pokemon();
         fluent_builder.inner = self;
         fluent_builder.send().await
-24
+    }
-25
+}
 /// Fluent builder constructing a request to `CapturePokemon`.
 ///
 /// Capture Pokémons via event streams.
 /// /* FluentBuilderGenerator.kt:129 */Fluent builder constructing a request to `CapturePokemon`.
 ///
 /// /* FluentBuilderGenerator.kt:130 */Capture Pokémons via event streams.
 /// /* FluentBuilderGenerator.kt:132 */
 /// [`CapturePokemonOutput`](crate::operation::capture_pokemon::CapturePokemonOutput) contains an event stream field as well as one or more non-event stream fields.
 /// Due to its current implementation, the non-event stream fields are not fully deserialized
 /// until the [`send`](Self::send) method completes. As a result, accessing these fields of the operation
 /// output struct within an interceptor may return uninitialized values.
 ///
 /* RustType.kt:516 */
 #[derive(::std::fmt::Debug)]
 /* FluentBuilderGenerator.kt:270 */
 pub struct CapturePokemonFluentBuilder {
     handle: ::std::sync::Arc<crate::client::Handle>,
     inner: crate::operation::capture_pokemon::builders::CapturePokemonInputBuilder,
     config_override: ::std::option::Option<crate::config::Builder>,
-42
+}
 /* FluentBuilderGenerator.kt:381 */
 impl
     crate::client::customize::internal::CustomizableSend<
         crate::operation::capture_pokemon::CapturePokemonOutput,
         crate::operation::capture_pokemon::CapturePokemonError,
     > for CapturePokemonFluentBuilder
-49
+{
     fn send(
         self,
         config_override: crate::config::Builder,
     ) -> crate::client::customize::internal::BoxFuture<
         crate::client::customize::internal::SendResult<
             crate::operation::capture_pokemon::CapturePokemonOutput,
             crate::operation::capture_pokemon::CapturePokemonError,
         >,
     > {
         ::std::boxed::Box::pin(async move { self.config_override(config_override).send().await })
-60
+    }
-61
+}
 /* FluentBuilderGenerator.kt:282 */
 impl CapturePokemonFluentBuilder {
     /* FluentBuilderGenerator.kt:288 */
     /// Creates a new `CapturePokemonFluentBuilder`.
     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,
-71
+        }
-72
+    }
     /* FluentBuilderGenerator.kt:301 */
     /// Access the CapturePokemon as a reference.
     pub fn as_input(&self) -> &crate::operation::capture_pokemon::builders::CapturePokemonInputBuilder {
         &self.inner
-77
+    }
     /* 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,

↧ Expand context

     ) -> ::std::result::Result<
         crate::operation::capture_pokemon::CapturePokemonOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::capture_pokemon::CapturePokemonError,
             ::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::capture_pokemon::CapturePokemon::operation_runtime_plugins(
             self.handle.runtime_plugins.clone(),
             &self.handle.conf,
             self.config_override,
         );
         let mut output = crate::operation::capture_pokemon::CapturePokemon::orchestrate(&runtime_plugins, input).await?;
-106
         // Converts any error encountered beyond this point into an `SdkError` response error
         // with an `HttpResponse`. However, since we have already exited the `orchestrate`

@@ -108,118 +182,200 @@

↥ Expand context

             crate::operation::capture_pokemon::CapturePokemonError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         > {
             ::aws_smithy_runtime_api::client::result::SdkError::response_error(
                 err,
                 ::aws_smithy_runtime_api::client::orchestrator::HttpResponse::new(
                     ::aws_smithy_runtime_api::http::StatusCode::try_from(200).expect("valid successful code"),
                     ::aws_smithy_types::body::SdkBody::empty(),
                 ),
-127
+            )
-128
+        }
-129
         let message = output.events.try_recv_initial_response().await.map_err(response_error)?;
-131
         match message {
             ::std::option::Option::Some(_message) => ::std::result::Result::Ok(output),
             ::std::option::Option::None => ::std::result::Result::Ok(output),
-135
+        }
-136
+    }
-137

     /// Consumes this builder, creating a customizable operation that can be modified before being sent.
     pub fn customize(
         self,
     ) -> crate::client::customize::CustomizableOperation<
         crate::operation::capture_pokemon::CapturePokemonOutput,
         crate::operation::capture_pokemon::CapturePokemonError,
         Self,
     > {
         crate::client::customize::CustomizableOperation::new(self)
-147
+    }
     /* 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
-152
+    }
-153
     pub(crate) fn set_config_override(&mut self, config_override: ::std::option::Option<crate::config::Builder>) -> &mut Self {
         self.config_override = config_override;
         self
-157
+    }
     /* FluentBuilderGenerator.kt:498 */
     #[allow(missing_docs)] // documentation missing in model
                            /* FluentBuilderGenerator.kt:500 */
     pub fn events(
         mut self,
         input: ::aws_smithy_http::event_stream::EventStreamSender<
             crate::types::AttemptCapturingPokemonEvent,
             crate::types::error::AttemptCapturingPokemonEventError,
         >,
     ) -> Self {
         self.inner = self.inner.events(input);
         self
-170
+    }
     /* FluentBuilderGenerator.kt:498 */
     #[allow(missing_docs)] // documentation missing in model
                            /* FluentBuilderGenerator.kt:500 */
     pub fn set_events(
         mut self,
         input: ::std::option::Option<
             ::aws_smithy_http::event_stream::EventStreamSender<
                 crate::types::AttemptCapturingPokemonEvent,
                 crate::types::error::AttemptCapturingPokemonEventError,
             >,
         >,
     ) -> Self {
         self.inner = self.inner.set_events(input);
         self
-185
+    }
     /* FluentBuilderGenerator.kt:518 */
     #[allow(missing_docs)] // documentation missing in model
                            /* FluentBuilderGenerator.kt:520 */
     pub fn get_events(
         &self,
     ) -> &::std::option::Option<
         ::aws_smithy_http::event_stream::EventStreamSender<
             crate::types::AttemptCapturingPokemonEvent,
             crate::types::error::AttemptCapturingPokemonEventError,
         >,
     > {
         self.inner.get_events()
-198
+    }
     /* FluentBuilderGenerator.kt:282 */
-200
+}

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

@@ -57,66 +331,402 @@

↥ Expand context

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

                 runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
-87
+            }
             runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
                 config_override,
                 client_config.config.clone(),
                 &client_config.runtime_components,
             ));
-93
+        }
         runtime_plugins
-95
+    }
     /* OperationGenerator.kt:85 */
-97
+}
 /* OperationRuntimePluginGenerator.kt:55 */
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for CheckHealth {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         let mut cfg = ::aws_smithy_types::config_bag::Layer::new("CheckHealth");
-102
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
             CheckHealthRequestSerializer,
         ));
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
             CheckHealthResponseDeserializer,
         ));
-109
         cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
             ::aws_smithy_runtime_api::client::auth::static_resolver::StaticAuthSchemeOptionResolverParams::new(),
         ));
-113
         cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
             "CheckHealth",
             "PokemonService",
         ));
-118
         ::std::option::Option::Some(cfg.freeze())
-120
+    }
-121
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         #[allow(unused_mut)]
         let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("CheckHealth")
             .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
             .with_interceptor(CheckHealthEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::check_health::CheckHealthError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::check_health::CheckHealthError,
             >::new());
-136
         ::std::borrow::Cow::Owned(rcb)
-138
+    }
-139
+}
-140
 /* ResponseDeserializerGenerator.kt:64 */
 #[derive(Debug)]
 struct CheckHealthResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for CheckHealthResponseDeserializer {
     fn deserialize_nonstreaming(
         &self,
         response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
     ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
         let (success, status) = (response.status().is_success(), response.status().as_u16());
         let headers = response.headers();
         let body = response.body().bytes().expect("body loaded");
         #[allow(unused_mut)]
         let mut force_error = false;
-154
         let parse_result = if !success && status != 200 || force_error {
             crate::protocol_serde::shape_check_health::de_check_health_http_error(status, headers, body)
         } else {
             crate::protocol_serde::shape_check_health::de_check_health_http_response(status, headers, body)
         };
         crate::protocol_serde::type_erase_result(parse_result)
-161
+    }
-162
+}
 /* RequestSerializerGenerator.kt:67 */
 #[derive(Debug)]
 struct CheckHealthRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for CheckHealthRequestSerializer {
     #[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::check_health::CheckHealthInput>()
             .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::check_health::CheckHealthInput,
                 output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 use ::std::fmt::Write as _;
                 ::std::write!(output, "/").expect("formatting should succeed");
                 ::std::result::Result::Ok(())
-188
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::check_health::CheckHealthInput,
                 builder: ::http::request::Builder,
             ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
                 let mut uri = ::std::string::String::new();
                 uri_base(input, &mut uri)?;
                 ::std::result::Result::Ok(builder.method("POST").uri(uri))
-197
+            }
             let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
             builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/x-amz-json-1.0");
             builder = _header_serialization_settings.set_default_header(
                 builder,
                 ::http::header::HeaderName::from_static("x-amz-target"),
                 "PokemonService.CheckHealth",
             );
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_check_health::ser_check_health_input(&input)?);
-208
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
-210
+    }
-211
+}
 /* EndpointParamsInterceptorGenerator.kt:86 */
 #[derive(Debug)]
 struct CheckHealthEndpointParamsInterceptor;
-215
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for CheckHealthEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "CheckHealthEndpointParamsInterceptor"
-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::<CheckHealthInput>()
             .ok_or("failed to downcast to CheckHealthInput")?;
-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
 /* OperationErrorGenerator.kt:79 */
 /// Error type for the `CheckHealthError` operation.
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::fmt::Debug)]
 pub enum CheckHealthError {
 pub /* OperationErrorGenerator.kt:81 */ enum CheckHealthError {
     /* 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()`:
-259
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-261
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-CheckHealthError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
     /* OperationErrorGenerator.kt:81 */
-265
+}
 /* OperationErrorGenerator.kt:218 */
 impl CheckHealthError {
     /* OperationErrorGenerator.kt:219 */
     /// Creates the `CheckHealthError::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(),
         })
-277
+    }
-278
     /// Creates the `CheckHealthError::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,
         })
-285
+    }
     ///
     /// /* 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 */
-296
+        }
         /* OperationErrorGenerator.kt:242 */
-298
+    }
     /* OperationErrorGenerator.kt:218 */
-300
+}
 /* OperationErrorGenerator.kt:269 */
 impl ::std::error::Error for CheckHealthError {
     /* 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 */
-313
+        }
         /* OperationErrorGenerator.kt:270 */
-315
+    }
     /* OperationErrorGenerator.kt:269 */
-317
+}
 /* OperationErrorGenerator.kt:133 */
 impl ::std::fmt::Display for CheckHealthError {
     /* 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")
-331
+                }
--
+            }
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-334
+        }
         /* OperationErrorGenerator.kt:134 */
-336
+    }
     /* OperationErrorGenerator.kt:133 */
-338
+}
 /* OperationErrorGenerator.kt:182 */
 impl ::aws_smithy_types::retry::ProvideErrorKind for CheckHealthError {
     /* OperationErrorGenerator.kt:186 */
     fn code(&self) -> ::std::option::Option<&str> {
         /* OperationErrorGenerator.kt:187 */
         ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
         /* OperationErrorGenerator.kt:186 */
-346
+    }
     /* 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 */
-352
+    }
     /* OperationErrorGenerator.kt:182 */
-354
+}
 /* OperationErrorGenerator.kt:163 */
 impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for CheckHealthError {
     /* 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 */
-367
+        }
         /* OperationErrorGenerator.kt:164 */
-369
+    }
     /* OperationErrorGenerator.kt:163 */
-371
+}
 /* OperationErrorGenerator.kt:109 */
 impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for CheckHealthError {
     /* 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 */
-385
+    }
     /* OperationErrorGenerator.kt:109 */
-387
+}
-388
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::check_health::_check_health_output::CheckHealthOutput;
-391
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::check_health::_check_health_input::CheckHealthInput;
-394
 /* RustModule.kt:172 */
 mod _check_health_input;
-397
 /* RustModule.kt:172 */
 mod _check_health_output;
-400
 /// Builders
 /// /* CodegenDelegator.kt:51 */Builders
 pub mod builders;

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* ClientRuntimeTypesReExportGenerator.kt:60 */
 pub use ::aws_smithy_runtime_api::client::orchestrator::HttpRequest;
 pub use ::aws_smithy_runtime_api::client::orchestrator::HttpResponse;

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* ClientRuntimeTypesReExportGenerator.kt:70 */
 pub use ::aws_smithy_runtime_api::client::interceptors::context::AfterDeserializationInterceptorContextRef;
 pub use ::aws_smithy_runtime_api::client::interceptors::context::BeforeDeserializationInterceptorContextMut;
 pub use ::aws_smithy_runtime_api::client::interceptors::context::BeforeDeserializationInterceptorContextRef;
 pub use ::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextMut;
 pub use ::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef;
 pub use ::aws_smithy_runtime_api::client::interceptors::context::BeforeTransmitInterceptorContextMut;
 pub use ::aws_smithy_runtime_api::client::interceptors::context::BeforeTransmitInterceptorContextRef;
 pub use ::aws_smithy_runtime_api::client::interceptors::context::FinalizerInterceptorContextMut;
 pub use ::aws_smithy_runtime_api::client::interceptors::context::FinalizerInterceptorContextRef;
 pub use ::aws_smithy_runtime_api::client::interceptors::context::InterceptorContext;

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* ClientRuntimeTypesReExportGenerator.kt:48 */
 pub use ::aws_smithy_runtime_api::client::retries::classifiers::ClassifyRetry;
 pub use ::aws_smithy_runtime_api::client::retries::classifiers::RetryAction;
 pub use ::aws_smithy_runtime_api::client::retries::ShouldAttempt;
-6
 pub use ::aws_smithy_runtime::client::retries::RetryPartition;
 /* ResiliencyConfigCustomization.kt:324 */
 /* ResiliencyConfigCustomization.kt:329 */ pub use ::aws_smithy_runtime::client::retries::RetryPartition;
 pub use ::aws_smithy_types::retry::{ReconnectMode, RetryConfig, RetryConfigBuilder, RetryMode};

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* ClientRuntimeTypesReExportGenerator.kt:96 */
 pub use ::aws_smithy_runtime_api::box_error::BoxError;
-4
 /* RequiredCustomizations.kt:104 */
 /// Error type returned by the client.
 pub type SdkError<E, R = ::aws_smithy_runtime_api::client::orchestrator::HttpResponse> = ::aws_smithy_runtime_api::client::result::SdkError<E, R>;
 pub use ::aws_smithy_runtime_api::client::result::ConnectorError;
 pub use ::aws_smithy_types::error::operation::BuildError;
-10
 pub use ::aws_smithy_types::error::display::DisplayErrorContext;
 pub use ::aws_smithy_types::error::metadata::ErrorMetadata;
 pub use ::aws_smithy_types::error::metadata::ProvideErrorMetadata;
-14
 pub(crate) mod sealed_unhandled;

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* ServiceErrorGenerator.kt:277 */
 /// This struct is not intended to be used.
 ///
 /// This struct holds information about an unhandled error,
 /// but that information should be obtained by using the
 /// [`ProvideErrorMetadata`](::aws_smithy_types::error::metadata::ProvideErrorMetadata) trait
 /// on the error type.
 ///
 /// This struct intentionally doesn't yield any useful information itself.
 #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
 variable wildcard pattern and check `.code()`:

Client Test

Files changed:

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/config/http.rs

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/config/interceptors.rs

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/config/retry.rs

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/config/timeout.rs

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/error.rs

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/error/sealed_unhandled.rs

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/error_meta.rs

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/event_stream_serde.rs

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/lib.rs

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/meta.rs

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/operation.rs

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/operation/capture_pokemon.rs

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/operation/capture_pokemon/_capture_pokemon_input.rs

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/operation/capture_pokemon/_capture_pokemon_output.rs

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/operation/capture_pokemon/builders.rs

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/operation/check_health.rs

-13
+ \
 &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-15
+ \
 See [`ProvideErrorMetadata`](::aws_smithy_types::error::metadata::ProvideErrorMetadata) for what information is available for the error.")]
 #[derive(Debug)]
 pub struct Unhandled {
     pub(crate) source: ::aws_smithy_runtime_api::box_error::BoxError,
     pub(crate) meta: ::aws_smithy_types::error::metadata::ErrorMetadata,
-21
+}