Server Test

rev. dfb5149b65b7bcc09edd15b8e071ad43b5ac5943 (ignoring whitespace)

Files changed:

tmp-codegen-diff/codegen-server-test/rest_json_extras/rust-server-codegen/src/input.rs

@@ -1,1 +860,1305 @@

 // 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 */
 #[derive(::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct QueryPrecedenceInput {
 pub /* StructureGenerator.kt:201 */ struct QueryPrecedenceInput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
     pub foo: ::std::option::Option<::std::string::String>,
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
     pub baz: ::std::option::Option<
         ::std::collections::HashMap<::std::string::String, ::std::string::String>,
     >,
     /* StructureGenerator.kt:201 */
-16
+}
 /* StructureGenerator.kt:135 */
 impl QueryPrecedenceInput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
                            /* StructureGenerator.kt:166 */
     pub fn foo(&self) -> ::std::option::Option<&str> {
         /* StructureGenerator.kt:169 */
         self.foo.as_deref()
         /* StructureGenerator.kt:166 */
-26
+    }
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
                            /* StructureGenerator.kt:166 */
     pub fn baz(
         &self,
     ) -> ::std::option::Option<
         &::std::collections::HashMap<::std::string::String, ::std::string::String>,
     > {
         /* StructureGenerator.kt:170 */
         self.baz.as_ref()
         /* StructureGenerator.kt:166 */
-38
+    }
     /* StructureGenerator.kt:135 */
-40
+}
 /* ServerCodegenVisitor.kt:345 */
 impl QueryPrecedenceInput {
     /// Creates a new builder-style object to manufacture [`QueryPrecedenceInput`](crate::input::QueryPrecedenceInput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`QueryPrecedenceInput`](crate::input::QueryPrecedenceInput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::input::query_precedence_input::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::input::query_precedence_input::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-49
+    }
     /* ServerCodegenVisitor.kt:345 */
-51
+}
 /* ServerStructureConstrainedTraitImpl.kt:21 */
 impl crate::constrained::Constrained for crate::input::QueryPrecedenceInput {
     type Unconstrained = crate::input::query_precedence_input::Builder;
-55
+}
-56
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct EmptyStructWithContentOnWireOpInput {}
 pub /* StructureGenerator.kt:201 */ struct EmptyStructWithContentOnWireOpInput {/* StructureGenerator.kt:201 */}
 /* ServerCodegenVisitor.kt:345 */
 impl EmptyStructWithContentOnWireOpInput {
     /// Creates a new builder-style object to manufacture [`EmptyStructWithContentOnWireOpInput`](crate::input::EmptyStructWithContentOnWireOpInput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`EmptyStructWithContentOnWireOpInput`](crate::input::EmptyStructWithContentOnWireOpInput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::input::empty_struct_with_content_on_wire_op_input::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::input::empty_struct_with_content_on_wire_op_input::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-72
+    }
     /* ServerCodegenVisitor.kt:345 */
-74
+}
 /* ServerStructureConstrainedTraitImpl.kt:21 */
 impl crate::constrained::Constrained for crate::input::EmptyStructWithContentOnWireOpInput {
     type Unconstrained = crate::input::empty_struct_with_content_on_wire_op_input::Builder;
-78
+}
-79
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct CaseInsensitiveErrorOperationInput {}
 pub /* StructureGenerator.kt:201 */ struct CaseInsensitiveErrorOperationInput {/* StructureGenerator.kt:201 */}
 /* ServerCodegenVisitor.kt:345 */
 impl CaseInsensitiveErrorOperationInput {
     /// Creates a new builder-style object to manufacture [`CaseInsensitiveErrorOperationInput`](crate::input::CaseInsensitiveErrorOperationInput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`CaseInsensitiveErrorOperationInput`](crate::input::CaseInsensitiveErrorOperationInput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::input::case_insensitive_error_operation_input::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::input::case_insensitive_error_operation_input::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-95
+    }
     /* ServerCodegenVisitor.kt:345 */
-97
+}
 /* ServerStructureConstrainedTraitImpl.kt:21 */
 impl crate::constrained::Constrained for crate::input::CaseInsensitiveErrorOperationInput {
     type Unconstrained = crate::input::case_insensitive_error_operation_input::Builder;
-101
+}
-102
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct NullInNonSparseInput {}
 pub /* StructureGenerator.kt:201 */ struct NullInNonSparseInput {/* StructureGenerator.kt:201 */}
 /* ServerCodegenVisitor.kt:345 */
 impl NullInNonSparseInput {
     /// Creates a new builder-style object to manufacture [`NullInNonSparseInput`](crate::input::NullInNonSparseInput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`NullInNonSparseInput`](crate::input::NullInNonSparseInput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::input::null_in_non_sparse_input::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::input::null_in_non_sparse_input::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-118
+    }
     /* ServerCodegenVisitor.kt:345 */
-120
+}
 /* ServerStructureConstrainedTraitImpl.kt:21 */
 impl crate::constrained::Constrained for crate::input::NullInNonSparseInput {
     type Unconstrained = crate::input::null_in_non_sparse_input::Builder;
-124
+}
-125
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct EscapedStringValuesInput {
 pub /* StructureGenerator.kt:201 */ struct EscapedStringValuesInput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
     pub r#enum: ::std::option::Option<crate::model::EnumWithEscapedChars>,
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
     pub some_string: ::std::option::Option<::std::string::String>,
     /* StructureGenerator.kt:201 */
-140
+}
 /* StructureGenerator.kt:135 */
 impl EscapedStringValuesInput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
                            /* StructureGenerator.kt:166 */
     pub fn r#enum(&self) -> ::std::option::Option<&crate::model::EnumWithEscapedChars> {
         /* StructureGenerator.kt:170 */
         self.r#enum.as_ref()
         /* StructureGenerator.kt:166 */
-150
+    }
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
                            /* StructureGenerator.kt:166 */
     pub fn some_string(&self) -> ::std::option::Option<&str> {
         /* StructureGenerator.kt:169 */
         self.some_string.as_deref()
         /* StructureGenerator.kt:166 */
-158
+    }
     /* StructureGenerator.kt:135 */
-160
+}
 /* ServerCodegenVisitor.kt:345 */
 impl EscapedStringValuesInput {
     /// Creates a new builder-style object to manufacture [`EscapedStringValuesInput`](crate::input::EscapedStringValuesInput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`EscapedStringValuesInput`](crate::input::EscapedStringValuesInput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::input::escaped_string_values_input::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::input::escaped_string_values_input::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-169
+    }
     /* ServerCodegenVisitor.kt:345 */
-171
+}
 /* ServerStructureConstrainedTraitImpl.kt:21 */
 impl crate::constrained::Constrained for crate::input::EscapedStringValuesInput {
     type Unconstrained = crate::input::escaped_string_values_input::Builder;
-175
+}
-176
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct PrimitiveIntOpInput {
 pub /* StructureGenerator.kt:201 */ struct PrimitiveIntOpInput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
     pub value: i32,
     /* StructureGenerator.kt:201 */
-188
+}
 /* StructureGenerator.kt:135 */
 impl PrimitiveIntOpInput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
                            /* StructureGenerator.kt:166 */
     pub fn value(&self) -> i32 {
         /* StructureGenerator.kt:168 */
         self.value
         /* StructureGenerator.kt:166 */
-198
+    }
     /* StructureGenerator.kt:135 */
-200
+}
 /* ServerCodegenVisitor.kt:345 */
 impl PrimitiveIntOpInput {
     /// Creates a new builder-style object to manufacture [`PrimitiveIntOpInput`](crate::input::PrimitiveIntOpInput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`PrimitiveIntOpInput`](crate::input::PrimitiveIntOpInput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::input::primitive_int_op_input::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::input::primitive_int_op_input::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-209
+    }
     /* ServerCodegenVisitor.kt:345 */
-211
+}
 /* ServerStructureConstrainedTraitImpl.kt:21 */
 impl crate::constrained::Constrained for crate::input::PrimitiveIntOpInput {
     type Unconstrained = crate::input::primitive_int_op_input::Builder;
-215
+}
-216
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct MapWithEnumKeyOpInput {
 pub /* StructureGenerator.kt:201 */ struct MapWithEnumKeyOpInput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
     pub map: ::std::option::Option<
         ::std::collections::HashMap<crate::model::StringEnum, ::std::string::String>,
     >,
     /* StructureGenerator.kt:201 */
-228
+}
 /* StructureGenerator.kt:135 */
 impl MapWithEnumKeyOpInput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
                            /* StructureGenerator.kt:166 */
     pub fn map(
         &self,
     ) -> ::std::option::Option<
         &::std::collections::HashMap<crate::model::StringEnum, ::std::string::String>,
     > {
         /* StructureGenerator.kt:170 */
         self.map.as_ref()
         /* StructureGenerator.kt:166 */
-242
+    }
     /* StructureGenerator.kt:135 */
-244
+}
 /* ServerCodegenVisitor.kt:345 */
 impl MapWithEnumKeyOpInput {
     /// Creates a new builder-style object to manufacture [`MapWithEnumKeyOpInput`](crate::input::MapWithEnumKeyOpInput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`MapWithEnumKeyOpInput`](crate::input::MapWithEnumKeyOpInput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::input::map_with_enum_key_op_input::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::input::map_with_enum_key_op_input::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-253
+    }
     /* ServerCodegenVisitor.kt:345 */
-255
+}
 /* ServerStructureConstrainedTraitImpl.kt:21 */
 impl crate::constrained::Constrained for crate::input::MapWithEnumKeyOpInput {
     type Unconstrained = crate::input::map_with_enum_key_op_input::Builder;
-259
+}
-260
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct StatusResponseInput {}
 pub /* StructureGenerator.kt:201 */ struct StatusResponseInput {/* StructureGenerator.kt:201 */}
 /* ServerCodegenVisitor.kt:345 */
 impl StatusResponseInput {
     /// Creates a new builder-style object to manufacture [`StatusResponseInput`](crate::input::StatusResponseInput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`StatusResponseInput`](crate::input::StatusResponseInput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::input::status_response_input::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::input::status_response_input::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-276
+    }
     /* ServerCodegenVisitor.kt:345 */
-278
+}
 /* ServerStructureConstrainedTraitImpl.kt:21 */
 impl crate::constrained::Constrained for crate::input::StatusResponseInput {
     type Unconstrained = crate::input::status_response_input::Builder;
-282
+}
-283
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct EnumQueryInput {
 pub /* StructureGenerator.kt:201 */ struct EnumQueryInput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
     pub r#enum: crate::model::StringEnum,
     /* StructureGenerator.kt:201 */
-295
+}
 /* StructureGenerator.kt:135 */
 impl EnumQueryInput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
                            /* StructureGenerator.kt:166 */
     pub fn r#enum(&self) -> &crate::model::StringEnum {
         /* StructureGenerator.kt:172 */
         &self.r#enum
         /* StructureGenerator.kt:166 */
-305
+    }
     /* StructureGenerator.kt:135 */
-307
+}
 /* ServerCodegenVisitor.kt:345 */
 impl EnumQueryInput {
     /// Creates a new builder-style object to manufacture [`EnumQueryInput`](crate::input::EnumQueryInput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`EnumQueryInput`](crate::input::EnumQueryInput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::input::enum_query_input::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::input::enum_query_input::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-316
+    }
     /* ServerCodegenVisitor.kt:345 */
-318
+}
 /* ServerStructureConstrainedTraitImpl.kt:21 */
 impl crate::constrained::Constrained for crate::input::EnumQueryInput {
     type Unconstrained = crate::input::enum_query_input::Builder;
-322
+}
-323
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct PrimitiveIntHeaderInput {}
 pub /* StructureGenerator.kt:201 */ struct PrimitiveIntHeaderInput {/* StructureGenerator.kt:201 */}
 /* ServerCodegenVisitor.kt:345 */
 impl PrimitiveIntHeaderInput {
     /// Creates a new builder-style object to manufacture [`PrimitiveIntHeaderInput`](crate::input::PrimitiveIntHeaderInput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`PrimitiveIntHeaderInput`](crate::input::PrimitiveIntHeaderInput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::input::primitive_int_header_input::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::input::primitive_int_header_input::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-339
+    }
     /* ServerCodegenVisitor.kt:345 */
-341
+}
 /* ServerStructureConstrainedTraitImpl.kt:21 */
 impl crate::constrained::Constrained for crate::input::PrimitiveIntHeaderInput {
     type Unconstrained = crate::input::primitive_int_header_input::Builder;
-345
+}
-346
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct StringPayloadInput {
 pub /* StructureGenerator.kt:201 */ struct StringPayloadInput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
     pub payload: ::std::option::Option<::std::string::String>,
     /* StructureGenerator.kt:201 */
-358
+}
 /* StructureGenerator.kt:135 */
 impl StringPayloadInput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
                            /* StructureGenerator.kt:166 */
     pub fn payload(&self) -> ::std::option::Option<&str> {
         /* StructureGenerator.kt:169 */
         self.payload.as_deref()
         /* StructureGenerator.kt:166 */
-368
+    }
     /* StructureGenerator.kt:135 */
-370
+}
 /* ServerCodegenVisitor.kt:345 */
 impl StringPayloadInput {
     /// Creates a new builder-style object to manufacture [`StringPayloadInput`](crate::input::StringPayloadInput).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`StringPayloadInput`](crate::input::StringPayloadInput).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::input::string_payload_input::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::input::string_payload_input::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-379
+    }
     /* ServerCodegenVisitor.kt:345 */
-381
+}
 /* ServerStructureConstrainedTraitImpl.kt:21 */
 impl crate::constrained::Constrained for crate::input::StringPayloadInput {
     type Unconstrained = crate::input::string_payload_input::Builder;
-385
+}
 /// See [`QueryPrecedenceInput`](crate::input::QueryPrecedenceInput).
 /// /* ServerBuilderGenerator.kt:171 */See [`QueryPrecedenceInput`](crate::input::QueryPrecedenceInput).
 pub mod query_precedence_input {
-388
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::input::QueryPrecedenceInput {
         fn from(builder: Builder) -> Self {
             builder.build()
-393
+        }
-394
+    }
     /// A builder for [`QueryPrecedenceInput`](crate::input::QueryPrecedenceInput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`QueryPrecedenceInput`](crate::input::QueryPrecedenceInput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {
         /* ServerBuilderGenerator.kt:308 */
         pub(crate) foo: ::std::option::Option<::std::string::String>,
         /* ServerBuilderGenerator.kt:308 */
         pub(crate) baz: ::std::option::Option<
             ::std::collections::HashMap<::std::string::String, ::std::string::String>,
         >,
         /* ServerBuilderGenerator.kt:211 */
-407
+    }
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /* ServerBuilderGenerator.kt:331 */
         #[allow(missing_docs)] // documentation missing in model
                                /* ServerBuilderGenerator.kt:343 */
         pub fn foo(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
             self.foo = input;
             /* ServerBuilderGenerator.kt:344 */
             self.foo =
                 /* ServerBuilderGenerator.kt:376 */input
             /* ServerBuilderGenerator.kt:344 */;
             self
             /* ServerBuilderGenerator.kt:343 */
-420
+        }
         /* ServerBuilderGenerator.kt:426 */
         #[allow(missing_docs)] // documentation missing in model
                                /* ServerBuilderGenerator.kt:428 */
         pub(crate) fn set_foo(
             mut self,
             input: Option<impl ::std::convert::Into<::std::string::String>>,
         ) -> Self {
             /* ServerBuilderGenerator.kt:429 */
             self.foo = input.map(|v| v.into());
             self
             /* ServerBuilderGenerator.kt:428 */
-432
+        }
         /* ServerBuilderGenerator.kt:331 */
         #[allow(missing_docs)] // documentation missing in model
                                /* ServerBuilderGenerator.kt:343 */
         pub fn baz(
             mut self,
             input: ::std::option::Option<
                 ::std::collections::HashMap<::std::string::String, ::std::string::String>,
             >,
         ) -> Self {
             self.baz = input;
             /* ServerBuilderGenerator.kt:344 */
             self.baz =
                 /* ServerBuilderGenerator.kt:376 */input
             /* ServerBuilderGenerator.kt:344 */;
             self
             /* ServerBuilderGenerator.kt:343 */
-448
+        }
         /* ServerBuilderGenerator.kt:426 */
         #[allow(missing_docs)] // documentation missing in model
                                /* ServerBuilderGenerator.kt:428 */
         pub(crate) fn set_baz(
             mut self,
             input: Option<
                 impl ::std::convert::Into<
                     ::std::collections::HashMap<::std::string::String, ::std::string::String>,
                 >,
             >,
         ) -> Self {
             /* ServerBuilderGenerator.kt:429 */
             self.baz = input.map(|v| v.into());
             self
             /* ServerBuilderGenerator.kt:428 */
-464
+        }
         /// Consumes the builder and constructs a [`QueryPrecedenceInput`](crate::input::QueryPrecedenceInput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`QueryPrecedenceInput`](crate::input::QueryPrecedenceInput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::input::QueryPrecedenceInput {
             self.build_enforcing_all_constraints()
-469
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(self) -> crate::input::QueryPrecedenceInput {
             /* ServerBuilderGenerator.kt:542 */
             crate::input::QueryPrecedenceInput {
                 /* ServerBuilderGenerator.kt:546 */
                 foo: self.foo,
                 /* ServerBuilderGenerator.kt:546 */
                 baz: self.baz,
                 /* ServerBuilderGenerator.kt:542 */
-479
+            }
             /* ServerBuilderGenerator.kt:283 */
-481
+        }
         /* ServerBuilderGenerator.kt:215 */
-483
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-486
+}
 /// See [`EmptyStructWithContentOnWireOpInput`](crate::input::EmptyStructWithContentOnWireOpInput).
 /// /* ServerBuilderGenerator.kt:171 */See [`EmptyStructWithContentOnWireOpInput`](crate::input::EmptyStructWithContentOnWireOpInput).
 pub mod empty_struct_with_content_on_wire_op_input {
-489
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::input::EmptyStructWithContentOnWireOpInput {
         fn from(builder: Builder) -> Self {
             builder.build()
-494
+        }
-495
+    }
     /// A builder for [`EmptyStructWithContentOnWireOpInput`](crate::input::EmptyStructWithContentOnWireOpInput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`EmptyStructWithContentOnWireOpInput`](crate::input::EmptyStructWithContentOnWireOpInput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {}
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {/* ServerBuilderGenerator.kt:211 */}
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// Consumes the builder and constructs a [`EmptyStructWithContentOnWireOpInput`](crate::input::EmptyStructWithContentOnWireOpInput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`EmptyStructWithContentOnWireOpInput`](crate::input::EmptyStructWithContentOnWireOpInput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::input::EmptyStructWithContentOnWireOpInput {
             self.build_enforcing_all_constraints()
-507
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(
             self,
         ) -> crate::input::EmptyStructWithContentOnWireOpInput {
             crate::input::EmptyStructWithContentOnWireOpInput {}
             /* ServerBuilderGenerator.kt:542 */
             crate::input::EmptyStructWithContentOnWireOpInput {
             /* ServerBuilderGenerator.kt:542 */}
             /* ServerBuilderGenerator.kt:283 */
-516
+        }
         /* ServerBuilderGenerator.kt:215 */
-518
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-521
+}
 /// See [`CaseInsensitiveErrorOperationInput`](crate::input::CaseInsensitiveErrorOperationInput).
 /// /* ServerBuilderGenerator.kt:171 */See [`CaseInsensitiveErrorOperationInput`](crate::input::CaseInsensitiveErrorOperationInput).
 pub mod case_insensitive_error_operation_input {
-524
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::input::CaseInsensitiveErrorOperationInput {
         fn from(builder: Builder) -> Self {
             builder.build()
-529
+        }
-530
+    }
     /// A builder for [`CaseInsensitiveErrorOperationInput`](crate::input::CaseInsensitiveErrorOperationInput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`CaseInsensitiveErrorOperationInput`](crate::input::CaseInsensitiveErrorOperationInput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {}
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {/* ServerBuilderGenerator.kt:211 */}
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// Consumes the builder and constructs a [`CaseInsensitiveErrorOperationInput`](crate::input::CaseInsensitiveErrorOperationInput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`CaseInsensitiveErrorOperationInput`](crate::input::CaseInsensitiveErrorOperationInput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::input::CaseInsensitiveErrorOperationInput {
             self.build_enforcing_all_constraints()
-542
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(
             self,
         ) -> crate::input::CaseInsensitiveErrorOperationInput {
             crate::input::CaseInsensitiveErrorOperationInput {}
             /* ServerBuilderGenerator.kt:542 */
             crate::input::CaseInsensitiveErrorOperationInput {
             /* ServerBuilderGenerator.kt:542 */}
             /* ServerBuilderGenerator.kt:283 */
-551
+        }
         /* ServerBuilderGenerator.kt:215 */
-553
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-556
+}
 /// See [`NullInNonSparseInput`](crate::input::NullInNonSparseInput).
 /// /* ServerBuilderGenerator.kt:171 */See [`NullInNonSparseInput`](crate::input::NullInNonSparseInput).
 pub mod null_in_non_sparse_input {
-559
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::input::NullInNonSparseInput {
         fn from(builder: Builder) -> Self {
             builder.build()
-564
+        }
-565
+    }
     /// A builder for [`NullInNonSparseInput`](crate::input::NullInNonSparseInput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`NullInNonSparseInput`](crate::input::NullInNonSparseInput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {}
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {/* ServerBuilderGenerator.kt:211 */}
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// Consumes the builder and constructs a [`NullInNonSparseInput`](crate::input::NullInNonSparseInput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`NullInNonSparseInput`](crate::input::NullInNonSparseInput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::input::NullInNonSparseInput {
             self.build_enforcing_all_constraints()
-577
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(self) -> crate::input::NullInNonSparseInput {
             crate::input::NullInNonSparseInput {}
             /* ServerBuilderGenerator.kt:542 */
             crate::input::NullInNonSparseInput {
             /* ServerBuilderGenerator.kt:542 */}
             /* ServerBuilderGenerator.kt:283 */
-584
+        }
         /* ServerBuilderGenerator.kt:215 */
-586
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-589
+}
 /// See [`EscapedStringValuesInput`](crate::input::EscapedStringValuesInput).
 /// /* ServerBuilderGenerator.kt:171 */See [`EscapedStringValuesInput`](crate::input::EscapedStringValuesInput).
 pub mod escaped_string_values_input {
-592
     /* RustType.kt:516 */
     #[derive(::std::cmp::PartialEq, ::std::fmt::Debug)]
     /// Holds one variant for each of the ways the builder can fail.
     /// /* ServerBuilderConstraintViolations.kt:72 */Holds one variant for each of the ways the builder can fail.
     /* RustType.kt:516 */
     #[non_exhaustive]
     /* ServerBuilderConstraintViolations.kt:75 */
     #[allow(clippy::enum_variant_names)]
     pub enum ConstraintViolation {
         /// Constraint violation occurred building member `r#enum` when building `EscapedStringValuesInput`.
         /// /* ServerBuilderConstraintViolations.kt:158 */Constraint violation occurred building member `r#enum` when building `EscapedStringValuesInput`.
         /* RustType.kt:516 */
         #[doc(hidden)]
         /* ServerBuilderConstraintViolations.kt:164 */
         Enum(crate::model::enum_with_escaped_chars::ConstraintViolation),
         /* ServerBuilderConstraintViolations.kt:75 */
-607
+    }
     /* ServerBuilderConstraintViolations.kt:117 */
     impl ::std::fmt::Display for ConstraintViolation {
         /* ServerBuilderConstraintViolations.kt:118 */
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             /* ServerBuilderConstraintViolations.kt:119 */
             match self {
                 ConstraintViolation::Enum(_) => write!(f, "constraint violation occurred building member `r#enum` when building `EscapedStringValuesInput`"),
--
+            }
                 /* ServerBuilderConstraintViolations.kt:127 */ConstraintViolation::Enum(_) => write!(f, "constraint violation occurred building member `r#enum` when building `EscapedStringValuesInput`"),
             /* ServerBuilderConstraintViolations.kt:119 */}
             /* ServerBuilderConstraintViolations.kt:118 */
-617
+        }
         /* ServerBuilderConstraintViolations.kt:117 */
-619
+    }
     /* ServerBuilderConstraintViolations.kt:84 */
     impl ::std::error::Error for ConstraintViolation {}
     /* ServerBuilderConstraintViolations.kt:171 */
     impl ConstraintViolation {
         pub(crate) fn as_validation_exception_field(
             self,
             path: ::std::string::String,
         ) -> crate::model::ValidationExceptionField {
             match self {
                 ConstraintViolation::Enum(inner) => {
                     inner.as_validation_exception_field(path + "/enum")
-631
+                }
-632
+            }
-633
+        }
-634
+    }
     /* ServerBuilderGenerator.kt:234 */
     impl ::std::convert::From<ConstraintViolation>
         for ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection
-638
+    {
         fn from(constraint_violation: ConstraintViolation) -> Self {
             let first_validation_exception_field =
                 constraint_violation.as_validation_exception_field("".to_owned());
             let validation_exception = crate::error::ValidationException {
                 message: format!(
                     "1 validation error detected. {}",
                     &first_validation_exception_field.message
                 ),
                 field_list: Some(vec![first_validation_exception_field]),
             };
             Self::ConstraintViolation(
                                 crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(&validation_exception)
                                     .expect("validation exceptions should never fail to serialize; please file a bug report under https://github.com/smithy-lang/smithy-rs/issues")
-652
+                            )
-653
+        }
-654
+    }
     /* ServerBuilderGenerator.kt:244 */
     impl ::std::convert::From<Builder>
         for crate::constrained::MaybeConstrained<crate::input::EscapedStringValuesInput>
-658
+    {
         fn from(builder: Builder) -> Self {
             Self::Unconstrained(builder)
-661
+        }
-662
+    }
     /* ServerBuilderGenerator.kt:446 */
     impl ::std::convert::TryFrom<Builder> for crate::input::EscapedStringValuesInput {
         type Error = ConstraintViolation;
-666
         fn try_from(builder: Builder) -> ::std::result::Result<Self, Self::Error> {
             builder.build()
-669
+        }
-670
+    }
     /// A builder for [`EscapedStringValuesInput`](crate::input::EscapedStringValuesInput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`EscapedStringValuesInput`](crate::input::EscapedStringValuesInput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {
         /* ServerBuilderGenerator.kt:308 */
         pub(crate) r#enum: ::std::option::Option<
             crate::constrained::MaybeConstrained<crate::model::EnumWithEscapedChars>,
         >,
         /* ServerBuilderGenerator.kt:308 */
         pub(crate) some_string: ::std::option::Option<::std::string::String>,
         /* ServerBuilderGenerator.kt:211 */
-683
+    }
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /* ServerBuilderGenerator.kt:331 */
         #[allow(missing_docs)] // documentation missing in model
                                /* ServerBuilderGenerator.kt:343 */
         pub fn r#enum(
             mut self,
             input: ::std::option::Option<crate::model::EnumWithEscapedChars>,
         ) -> Self {
             self.r#enum = input.map(
                 #[allow(clippy::redundant_closure)]
                 |v| crate::constrained::MaybeConstrained::Constrained(v),
             );
             /* ServerBuilderGenerator.kt:344 */
             self.r#enum =
                 /* ServerBuilderGenerator.kt:367 */input.map(crate::constrained::MaybeConstrained::Constrained)
             /* ServerBuilderGenerator.kt:344 */;
             self
             /* ServerBuilderGenerator.kt:343 */
-699
+        }
         /* ServerBuilderGenerator.kt:426 */
         #[allow(missing_docs)] // documentation missing in model
                                /* ServerBuilderGenerator.kt:428 */
         pub(crate) fn set_enum(
             mut self,
             input: Option<
                 impl ::std::convert::Into<
                     crate::constrained::MaybeConstrained<crate::model::EnumWithEscapedChars>,
                 >,
             >,
         ) -> Self {
             /* ServerBuilderGenerator.kt:429 */
             self.r#enum = input.map(|v| v.into());
             self
             /* ServerBuilderGenerator.kt:428 */
-715
+        }
         /* ServerBuilderGenerator.kt:331 */
         #[allow(missing_docs)] // documentation missing in model
                                /* ServerBuilderGenerator.kt:343 */
         pub fn some_string(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
             self.some_string = input;
             /* ServerBuilderGenerator.kt:344 */
             self.some_string =
                 /* ServerBuilderGenerator.kt:376 */input
             /* ServerBuilderGenerator.kt:344 */;
             self
             /* ServerBuilderGenerator.kt:343 */
-726
+        }
         /* ServerBuilderGenerator.kt:426 */
         #[allow(missing_docs)] // documentation missing in model
                                /* ServerBuilderGenerator.kt:428 */
         pub(crate) fn set_some_string(
             mut self,
             input: Option<impl ::std::convert::Into<::std::string::String>>,
         ) -> Self {
             /* ServerBuilderGenerator.kt:429 */
             self.some_string = input.map(|v| v.into());
             self
             /* ServerBuilderGenerator.kt:428 */
-738
+        }
         /// Consumes the builder and constructs a [`EscapedStringValuesInput`](crate::input::EscapedStringValuesInput).
         ///
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`EscapedStringValuesInput`](crate::input::EscapedStringValuesInput).
         /// /* ServerBuilderGenerator.kt:260 */
         /// The builder fails to construct a [`EscapedStringValuesInput`](crate::input::EscapedStringValuesInput) if a [`ConstraintViolation`] occurs.
         ///
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> Result<crate::input::EscapedStringValuesInput, ConstraintViolation> {
             self.build_enforcing_all_constraints()
-746
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(
             self,
         ) -> Result<crate::input::EscapedStringValuesInput, ConstraintViolation> {
             Ok(crate::input::EscapedStringValuesInput {
             /* ServerBuilderGenerator.kt:287 */
             Ok(
                 /* ServerBuilderGenerator.kt:542 */
                 crate::input::EscapedStringValuesInput {
                     /* ServerBuilderGenerator.kt:546 */
                     r#enum: self
                         .r#enum
                         /* ServerBuilderGenerator.kt:602 */
                         .map(|v| match v {
                             crate::constrained::MaybeConstrained::Constrained(x) => Ok(x),
                             crate::constrained::MaybeConstrained::Unconstrained(x) => x.try_into(),
                         })
                         /* ServerBuilderGenerator.kt:614 */
                         .map(|res| res.map_err(ConstraintViolation::Enum))
                         .transpose()?,
                     /* ServerBuilderGenerator.kt:546 */
                     some_string: self.some_string,
             })
                     /* ServerBuilderGenerator.kt:542 */
                 }, /* ServerBuilderGenerator.kt:287 */
-+
+            )
             /* ServerBuilderGenerator.kt:283 */
-772
+        }
         /* ServerBuilderGenerator.kt:215 */
-774
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-777
+}
 /// See [`PrimitiveIntOpInput`](crate::input::PrimitiveIntOpInput).
 /// /* ServerBuilderGenerator.kt:171 */See [`PrimitiveIntOpInput`](crate::input::PrimitiveIntOpInput).
 pub mod primitive_int_op_input {
-780
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::input::PrimitiveIntOpInput {
         fn from(builder: Builder) -> Self {
             builder.build()
-785
+        }
-786
+    }
     /// A builder for [`PrimitiveIntOpInput`](crate::input::PrimitiveIntOpInput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`PrimitiveIntOpInput`](crate::input::PrimitiveIntOpInput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {
         /* ServerBuilderGenerator.kt:308 */
         pub(crate) value: ::std::option::Option<i32>,
         /* ServerBuilderGenerator.kt:211 */
-795
+    }
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /* ServerBuilderGenerator.kt:331 */
         #[allow(missing_docs)] // documentation missing in model
                                /* ServerBuilderGenerator.kt:343 */
         pub fn value(mut self, input: i32) -> Self {
             self.value = Some(input);
             /* ServerBuilderGenerator.kt:344 */
             self.value =
                 /* ServerBuilderGenerator.kt:345 */Some(
                     /* ServerBuilderGenerator.kt:376 */input
                 /* ServerBuilderGenerator.kt:345 */)
             /* ServerBuilderGenerator.kt:344 */;
             self
             /* ServerBuilderGenerator.kt:343 */
-810
+        }
         /* ServerBuilderGenerator.kt:426 */
         #[allow(missing_docs)] // documentation missing in model
                                /* ServerBuilderGenerator.kt:428 */
         pub(crate) fn set_value(mut self, input: impl ::std::convert::Into<i32>) -> Self {
             /* ServerBuilderGenerator.kt:429 */
             self.value = Some(input.into());
             self
             /* ServerBuilderGenerator.kt:428 */
-819
+        }
         /// Consumes the builder and constructs a [`PrimitiveIntOpInput`](crate::input::PrimitiveIntOpInput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`PrimitiveIntOpInput`](crate::input::PrimitiveIntOpInput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::input::PrimitiveIntOpInput {
             self.build_enforcing_all_constraints()
-824
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(self) -> crate::input::PrimitiveIntOpInput {
             /* ServerBuilderGenerator.kt:542 */
             crate::input::PrimitiveIntOpInput {
                 value: self.value.unwrap_or(0i32),
                 /* ServerBuilderGenerator.kt:546 */
                 value: self
                     .value
                     /* ServerBuilderGeneratorCommon.kt:135 */
                     .unwrap_or(0i32),
                 /* ServerBuilderGenerator.kt:542 */
-835
+            }
             /* ServerBuilderGenerator.kt:283 */
-837
+        }
         /* ServerBuilderGenerator.kt:215 */
-839
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-842
+}
 /// See [`MapWithEnumKeyOpInput`](crate::input::MapWithEnumKeyOpInput).
 /// /* ServerBuilderGenerator.kt:171 */See [`MapWithEnumKeyOpInput`](crate::input::MapWithEnumKeyOpInput).
 pub mod map_with_enum_key_op_input {
-845
     /* RustType.kt:516 */
     #[derive(::std::cmp::PartialEq, ::std::fmt::Debug)]
     /// Holds one variant for each of the ways the builder can fail.
     /// /* ServerBuilderConstraintViolations.kt:72 */Holds one variant for each of the ways the builder can fail.
     /* RustType.kt:516 */
     #[non_exhaustive]
     /* ServerBuilderConstraintViolations.kt:75 */
     #[allow(clippy::enum_variant_names)]
     pub enum ConstraintViolation {
         /// Constraint violation occurred building member `map` when building `MapWithEnumKeyOpInput`.
         /// /* ServerBuilderConstraintViolations.kt:158 */Constraint violation occurred building member `map` when building `MapWithEnumKeyOpInput`.
         /* RustType.kt:516 */
         #[doc(hidden)]
         /* ServerBuilderConstraintViolations.kt:164 */
         Map(crate::model::map_with_enum_key::ConstraintViolation),
         /* ServerBuilderConstraintViolations.kt:75 */
-860
+    }
     /* ServerBuilderConstraintViolations.kt:117 */
     impl ::std::fmt::Display for ConstraintViolation {
         /* ServerBuilderConstraintViolations.kt:118 */
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             /* ServerBuilderConstraintViolations.kt:119 */
             match self {
                 ConstraintViolation::Map(_) => write!(f, "constraint violation occurred building member `map` when building `MapWithEnumKeyOpInput`"),
--
+            }
                 /* ServerBuilderConstraintViolations.kt:127 */ConstraintViolation::Map(_) => write!(f, "constraint violation occurred building member `map` when building `MapWithEnumKeyOpInput`"),
             /* ServerBuilderConstraintViolations.kt:119 */}
             /* ServerBuilderConstraintViolations.kt:118 */
-870
+        }
         /* ServerBuilderConstraintViolations.kt:117 */
-872
+    }
     /* ServerBuilderConstraintViolations.kt:84 */
     impl ::std::error::Error for ConstraintViolation {}
     /* ServerBuilderConstraintViolations.kt:171 */
     impl ConstraintViolation {
         pub(crate) fn as_validation_exception_field(
             self,
             path: ::std::string::String,
         ) -> crate::model::ValidationExceptionField {
             match self {
                 ConstraintViolation::Map(inner) => {
                     inner.as_validation_exception_field(path + "/map")
-884
+                }
-885
+            }
-886
+        }
-887
+    }
     /* ServerBuilderGenerator.kt:234 */
     impl ::std::convert::From<ConstraintViolation>
         for ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection
-891
+    {
         fn from(constraint_violation: ConstraintViolation) -> Self {
             let first_validation_exception_field =
                 constraint_violation.as_validation_exception_field("".to_owned());
             let validation_exception = crate::error::ValidationException {
                 message: format!(
                     "1 validation error detected. {}",
                     &first_validation_exception_field.message
                 ),
                 field_list: Some(vec![first_validation_exception_field]),
             };
             Self::ConstraintViolation(
                                 crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(&validation_exception)
                                     .expect("validation exceptions should never fail to serialize; please file a bug report under https://github.com/smithy-lang/smithy-rs/issues")
-905
+                            )
-906
+        }
-907
+    }
     /* ServerBuilderGenerator.kt:244 */
     impl ::std::convert::From<Builder>
         for crate::constrained::MaybeConstrained<crate::input::MapWithEnumKeyOpInput>
-911
+    {
         fn from(builder: Builder) -> Self {
             Self::Unconstrained(builder)
-914
+        }
-915
+    }
     /* ServerBuilderGenerator.kt:446 */
     impl ::std::convert::TryFrom<Builder> for crate::input::MapWithEnumKeyOpInput {
         type Error = ConstraintViolation;
-919
         fn try_from(builder: Builder) -> ::std::result::Result<Self, Self::Error> {
             builder.build()
-922
+        }
-923
+    }
     /// A builder for [`MapWithEnumKeyOpInput`](crate::input::MapWithEnumKeyOpInput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`MapWithEnumKeyOpInput`](crate::input::MapWithEnumKeyOpInput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {
         /* ServerBuilderGenerator.kt:308 */
         pub(crate) map: ::std::option::Option<
             crate::constrained::MaybeConstrained<
                 crate::constrained::map_with_enum_key_constrained::MapWithEnumKeyConstrained,
             >,
         >,
         /* ServerBuilderGenerator.kt:211 */
-936
+    }
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /* ServerBuilderGenerator.kt:331 */
         #[allow(missing_docs)] // documentation missing in model
                                /* ServerBuilderGenerator.kt:343 */
         pub fn map(
             mut self,
             input: ::std::option::Option<
                 ::std::collections::HashMap<crate::model::StringEnum, ::std::string::String>,
             >,
         ) -> Self {
             self.map = input.map(
                 #[allow(clippy::redundant_closure)]
                 |v| crate::constrained::MaybeConstrained::Constrained((v).into()),
             );
             /* ServerBuilderGenerator.kt:344 */
             self.map =
                 /* ServerBuilderGenerator.kt:369 */input.map(#[allow(clippy::redundant_closure)] |v|
                     /* ServerBuilderGenerator.kt:371 */crate::constrained::MaybeConstrained::Constrained((v).into())
                 /* ServerBuilderGenerator.kt:369 */)
             /* ServerBuilderGenerator.kt:344 */;
             self
             /* ServerBuilderGenerator.kt:343 */
-956
+        }
         /* ServerBuilderGenerator.kt:426 */
         #[allow(missing_docs)] // documentation missing in model
                                /* ServerBuilderGenerator.kt:428 */
         pub(crate) fn set_map(
             mut self,
             input: Option<impl ::std::convert::Into<crate::constrained::MaybeConstrained<crate::constrained::map_with_enum_key_constrained::MapWithEnumKeyConstrained>>>,
         ) -> Self {
             /* ServerBuilderGenerator.kt:429 */
             self.map = input.map(|v| v.into());
             self
             /* ServerBuilderGenerator.kt:428 */
-968
+        }
         /// Consumes the builder and constructs a [`MapWithEnumKeyOpInput`](crate::input::MapWithEnumKeyOpInput).
         ///
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`MapWithEnumKeyOpInput`](crate::input::MapWithEnumKeyOpInput).
         /// /* ServerBuilderGenerator.kt:260 */
         /// The builder fails to construct a [`MapWithEnumKeyOpInput`](crate::input::MapWithEnumKeyOpInput) if a [`ConstraintViolation`] occurs.
         ///
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> Result<crate::input::MapWithEnumKeyOpInput, ConstraintViolation> {
             self.build_enforcing_all_constraints()
-976
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(
             self,
         ) -> Result<crate::input::MapWithEnumKeyOpInput, ConstraintViolation> {
             Ok(crate::input::MapWithEnumKeyOpInput {
             /* ServerBuilderGenerator.kt:287 */
             Ok(
                 /* ServerBuilderGenerator.kt:542 */
                 crate::input::MapWithEnumKeyOpInput {
                     /* ServerBuilderGenerator.kt:546 */
                     map: self
                         .map
                         /* ServerBuilderGenerator.kt:602 */
                         .map(|v| match v {
                             crate::constrained::MaybeConstrained::Constrained(x) => Ok(x),
                             crate::constrained::MaybeConstrained::Unconstrained(x) => x.try_into(),
                         })
                         /* ServerBuilderGenerator.kt:614 */
                         .map(|res| res.map(|v| v.into()).map_err(ConstraintViolation::Map))
                         .transpose()?,
             })
                     /* ServerBuilderGenerator.kt:542 */
                 }, /* ServerBuilderGenerator.kt:287 */
-+
+            )
             /* ServerBuilderGenerator.kt:283 */
-1000
+        }
         /* ServerBuilderGenerator.kt:215 */
-1002
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-1005
+}
 /// See [`StatusResponseInput`](crate::input::StatusResponseInput).
 /// /* ServerBuilderGenerator.kt:171 */See [`StatusResponseInput`](crate::input::StatusResponseInput).
 pub mod status_response_input {
-1008
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::input::StatusResponseInput {
         fn from(builder: Builder) -> Self {
             builder.build()
-1013
+        }
-1014
+    }
     /// A builder for [`StatusResponseInput`](crate::input::StatusResponseInput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`StatusResponseInput`](crate::input::StatusResponseInput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {}
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {/* ServerBuilderGenerator.kt:211 */}
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// Consumes the builder and constructs a [`StatusResponseInput`](crate::input::StatusResponseInput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`StatusResponseInput`](crate::input::StatusResponseInput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::input::StatusResponseInput {
             self.build_enforcing_all_constraints()
-1026
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(self) -> crate::input::StatusResponseInput {
             crate::input::StatusResponseInput {}
             /* ServerBuilderGenerator.kt:542 */
             crate::input::StatusResponseInput {
             /* ServerBuilderGenerator.kt:542 */}
             /* ServerBuilderGenerator.kt:283 */
-1033
+        }
         /* ServerBuilderGenerator.kt:215 */
-1035
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-1038
+}
 /// See [`EnumQueryInput`](crate::input::EnumQueryInput).
 /// /* ServerBuilderGenerator.kt:171 */See [`EnumQueryInput`](crate::input::EnumQueryInput).
 pub mod enum_query_input {
-1041
     /* RustType.kt:516 */
     #[derive(::std::cmp::PartialEq, ::std::fmt::Debug)]
     /// Holds one variant for each of the ways the builder can fail.
     /// /* ServerBuilderConstraintViolations.kt:72 */Holds one variant for each of the ways the builder can fail.
     /* RustType.kt:516 */
     #[non_exhaustive]
     /* ServerBuilderConstraintViolations.kt:75 */
     #[allow(clippy::enum_variant_names)]
     pub enum ConstraintViolation {
         /// `r#enum` was not provided but it is required when building `EnumQueryInput`.
         /// /* ServerBuilderConstraintViolations.kt:138 */`r#enum` was not provided but it is required when building `EnumQueryInput`.
         /* ServerBuilderConstraintViolations.kt:143 */
         MissingEnum,
         /// Constraint violation occurred building member `r#enum` when building `EnumQueryInput`.
         /// /* ServerBuilderConstraintViolations.kt:158 */Constraint violation occurred building member `r#enum` when building `EnumQueryInput`.
         /* RustType.kt:516 */
         #[doc(hidden)]
         /* ServerBuilderConstraintViolations.kt:164 */
         Enum(crate::model::string_enum::ConstraintViolation),
         /* ServerBuilderConstraintViolations.kt:75 */
-1059
+    }
     /* ServerBuilderConstraintViolations.kt:117 */
     impl ::std::fmt::Display for ConstraintViolation {
         /* ServerBuilderConstraintViolations.kt:118 */
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             /* ServerBuilderConstraintViolations.kt:119 */
             match self {
                 ConstraintViolation::MissingEnum => write!(f, "`r#enum` was not provided but it is required when building `EnumQueryInput`"),
                 ConstraintViolation::Enum(_) => write!(f, "constraint violation occurred building member `r#enum` when building `EnumQueryInput`"),
--
+            }
                 /* ServerBuilderConstraintViolations.kt:127 */ConstraintViolation::MissingEnum => write!(f, "`r#enum` was not provided but it is required when building `EnumQueryInput`"),
                 /* ServerBuilderConstraintViolations.kt:127 */ConstraintViolation::Enum(_) => write!(f, "constraint violation occurred building member `r#enum` when building `EnumQueryInput`"),
             /* ServerBuilderConstraintViolations.kt:119 */}
             /* ServerBuilderConstraintViolations.kt:118 */
-1070
+        }
         /* ServerBuilderConstraintViolations.kt:117 */
-1072
+    }
     /* ServerBuilderConstraintViolations.kt:84 */
     impl ::std::error::Error for ConstraintViolation {}
     /* ServerBuilderConstraintViolations.kt:171 */
     impl ConstraintViolation {
         pub(crate) fn as_validation_exception_field(
             self,
             path: ::std::string::String,
         ) -> crate::model::ValidationExceptionField {
             match self {
                 ConstraintViolation::MissingEnum => crate::model::ValidationExceptionField {
                     message: format!(
                         "Value at '{}/enum' failed to satisfy constraint: Member must not be null",
                         path
                     ),
                     path: path + "/enum",
                 },
                 ConstraintViolation::Enum(inner) => {
                     inner.as_validation_exception_field(path + "/enum")
-1091
+                }
-1092
+            }
-1093
+        }
-1094
+    }
     /* ServerBuilderGenerator.kt:234 */
     impl ::std::convert::From<ConstraintViolation>
         for ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection
-1098
+    {
         fn from(constraint_violation: ConstraintViolation) -> Self {
             let first_validation_exception_field =
                 constraint_violation.as_validation_exception_field("".to_owned());
             let validation_exception = crate::error::ValidationException {
                 message: format!(
                     "1 validation error detected. {}",
                     &first_validation_exception_field.message
                 ),
                 field_list: Some(vec![first_validation_exception_field]),
             };
             Self::ConstraintViolation(
                                 crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(&validation_exception)
                                     .expect("validation exceptions should never fail to serialize; please file a bug report under https://github.com/smithy-lang/smithy-rs/issues")
-1112
+                            )
-1113
+        }
-1114
+    }
     /* ServerBuilderGenerator.kt:244 */
     impl ::std::convert::From<Builder>
         for crate::constrained::MaybeConstrained<crate::input::EnumQueryInput>
-1118
+    {
         fn from(builder: Builder) -> Self {
             Self::Unconstrained(builder)
-1121
+        }
-1122
+    }
     /* ServerBuilderGenerator.kt:446 */
     impl ::std::convert::TryFrom<Builder> for crate::input::EnumQueryInput {
         type Error = ConstraintViolation;
-1126
         fn try_from(builder: Builder) -> ::std::result::Result<Self, Self::Error> {
             builder.build()
-1129
+        }
-1130
+    }
     /// A builder for [`EnumQueryInput`](crate::input::EnumQueryInput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`EnumQueryInput`](crate::input::EnumQueryInput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {
         /* ServerBuilderGenerator.kt:308 */
         pub(crate) r#enum:
             ::std::option::Option<crate::constrained::MaybeConstrained<crate::model::StringEnum>>,
         /* ServerBuilderGenerator.kt:211 */
-1140
+    }
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /* ServerBuilderGenerator.kt:331 */
         #[allow(missing_docs)] // documentation missing in model
                                /* ServerBuilderGenerator.kt:343 */
         pub fn r#enum(mut self, input: crate::model::StringEnum) -> Self {
             self.r#enum = Some(crate::constrained::MaybeConstrained::Constrained(input));
             /* ServerBuilderGenerator.kt:344 */
             self.r#enum =
                 /* ServerBuilderGenerator.kt:345 */Some(
                     /* ServerBuilderGenerator.kt:371 */crate::constrained::MaybeConstrained::Constrained(input)
                 /* ServerBuilderGenerator.kt:345 */)
             /* ServerBuilderGenerator.kt:344 */;
             self
             /* ServerBuilderGenerator.kt:343 */
-1155
+        }
         /* ServerBuilderGenerator.kt:426 */
         #[allow(missing_docs)] // documentation missing in model
                                /* ServerBuilderGenerator.kt:428 */
         pub(crate) fn set_enum(
             mut self,
             input: impl ::std::convert::Into<
                 crate::constrained::MaybeConstrained<crate::model::StringEnum>,
             >,
         ) -> Self {
             /* ServerBuilderGenerator.kt:429 */
             self.r#enum = Some(input.into());
             self
             /* ServerBuilderGenerator.kt:428 */
-1169
+        }
         /// Consumes the builder and constructs a [`EnumQueryInput`](crate::input::EnumQueryInput).
         ///
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`EnumQueryInput`](crate::input::EnumQueryInput).
         /// /* ServerBuilderGenerator.kt:260 */
         /// The builder fails to construct a [`EnumQueryInput`](crate::input::EnumQueryInput) if a [`ConstraintViolation`] occurs.
         ///
         /// If the builder fails, it will return the _first_ encountered [`ConstraintViolation`].
         /// /* ServerBuilderGenerator.kt:268 */If the builder fails, it will return the _first_ encountered [`ConstraintViolation`].
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> Result<crate::input::EnumQueryInput, ConstraintViolation> {
             self.build_enforcing_all_constraints()
-1178
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(
             self,
         ) -> Result<crate::input::EnumQueryInput, ConstraintViolation> {
             Ok(crate::input::EnumQueryInput {
             /* ServerBuilderGenerator.kt:287 */
             Ok(
                 /* ServerBuilderGenerator.kt:542 */
                 crate::input::EnumQueryInput {
                     /* ServerBuilderGenerator.kt:546 */
                     r#enum: self
                         .r#enum
                         /* ServerBuilderGenerator.kt:602 */
                         .map(|v| match v {
                             crate::constrained::MaybeConstrained::Constrained(x) => Ok(x),
                             crate::constrained::MaybeConstrained::Unconstrained(x) => x.try_into(),
                         })
                         /* ServerBuilderGenerator.kt:614 */
                         .map(|res| res.map_err(ConstraintViolation::Enum))
                         .transpose()?
                         /* ServerBuilderGenerator.kt:569 */
                         .ok_or(ConstraintViolation::MissingEnum)?,
             })
                     /* ServerBuilderGenerator.kt:542 */
                 }, /* ServerBuilderGenerator.kt:287 */
-+
+            )
             /* ServerBuilderGenerator.kt:283 */
-1204
+        }
         /* ServerBuilderGenerator.kt:215 */
-1206
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-1209
+}
 /// See [`PrimitiveIntHeaderInput`](crate::input::PrimitiveIntHeaderInput).
 /// /* ServerBuilderGenerator.kt:171 */See [`PrimitiveIntHeaderInput`](crate::input::PrimitiveIntHeaderInput).
 pub mod primitive_int_header_input {
-1212
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::input::PrimitiveIntHeaderInput {
         fn from(builder: Builder) -> Self {
             builder.build()
-1217
+        }
-1218
+    }
     /// A builder for [`PrimitiveIntHeaderInput`](crate::input::PrimitiveIntHeaderInput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`PrimitiveIntHeaderInput`](crate::input::PrimitiveIntHeaderInput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {}
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {/* ServerBuilderGenerator.kt:211 */}
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// Consumes the builder and constructs a [`PrimitiveIntHeaderInput`](crate::input::PrimitiveIntHeaderInput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`PrimitiveIntHeaderInput`](crate::input::PrimitiveIntHeaderInput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::input::PrimitiveIntHeaderInput {
             self.build_enforcing_all_constraints()
-1230
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(self) -> crate::input::PrimitiveIntHeaderInput {
             crate::input::PrimitiveIntHeaderInput {}
             /* ServerBuilderGenerator.kt:542 */
             crate::input::PrimitiveIntHeaderInput {
             /* ServerBuilderGenerator.kt:542 */}
             /* ServerBuilderGenerator.kt:283 */
-1237
+        }
         /* ServerBuilderGenerator.kt:215 */
-1239
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-1242
+}
 /// See [`StringPayloadInput`](crate::input::StringPayloadInput).
 /// /* ServerBuilderGenerator.kt:171 */See [`StringPayloadInput`](crate::input::StringPayloadInput).
 pub mod string_payload_input {
-1245
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::input::StringPayloadInput {
         fn from(builder: Builder) -> Self {
             builder.build()
-1250
+        }
-1251
+    }
     /// A builder for [`StringPayloadInput`](crate::input::StringPayloadInput).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`StringPayloadInput`](crate::input::StringPayloadInput).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {
         /* ServerBuilderGenerator.kt:308 */
         pub(crate) payload: ::std::option::Option<::std::string::String>,
         /* ServerBuilderGenerator.kt:211 */
-1260
+    }
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /* ServerBuilderGenerator.kt:331 */
         #[allow(missing_docs)] // documentation missing in model
                                /* ServerBuilderGenerator.kt:343 */
         pub fn payload(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
             self.payload = input;
             /* ServerBuilderGenerator.kt:344 */
             self.payload =
                 /* ServerBuilderGenerator.kt:376 */input
             /* ServerBuilderGenerator.kt:344 */;
             self
             /* ServerBuilderGenerator.kt:343 */
-1273
+        }
         /* ServerBuilderGenerator.kt:426 */
         #[allow(missing_docs)] // documentation missing in model
                                /* ServerBuilderGenerator.kt:428 */
         pub(crate) fn set_payload(
             mut self,
             input: Option<impl ::std::convert::Into<::std::string::String>>,
         ) -> Self {
             /* ServerBuilderGenerator.kt:429 */
             self.payload = input.map(|v| v.into());
             self
             /* ServerBuilderGenerator.kt:428 */
-1285
+        }
         /// Consumes the builder and constructs a [`StringPayloadInput`](crate::input::StringPayloadInput).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`StringPayloadInput`](crate::input::StringPayloadInput).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::input::StringPayloadInput {
             self.build_enforcing_all_constraints()
-1290
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(self) -> crate::input::StringPayloadInput {
             /* ServerBuilderGenerator.kt:542 */
             crate::input::StringPayloadInput {
                 /* ServerBuilderGenerator.kt:546 */
                 payload: self.payload,
                 /* ServerBuilderGenerator.kt:542 */
-1298
+            }
             /* ServerBuilderGenerator.kt:283 */
-1300
+        }
         /* ServerBuilderGenerator.kt:215 */
-1302
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-1305
+}

tmp-codegen-diff/codegen-server-test/rest_json_extras/rust-server-codegen/src/lib.rs

@@ -1,1 +52,53 @@

↥ Expand context

 #![allow(deprecated)]
 #![allow(unknown_lints)]
 #![allow(clippy::module_inception)]
 #![allow(clippy::upper_case_acronyms)]
 #![allow(clippy::large_enum_variant)]
 #![allow(clippy::wrong_self_convention)]
 #![allow(clippy::should_implement_trait)]
 #![allow(clippy::disallowed_names)]
 #![allow(clippy::vec_init_then_push)]
 #![allow(clippy::type_complexity)]
 #![allow(clippy::needless_return)]
 #![allow(clippy::derive_partial_eq_without_eq)]

 #![allow(clippy::result_large_err)]
 #![allow(clippy::unnecessary_map_on_constructor)]
 #![allow(rustdoc::bare_urls)]
 #![allow(rustdoc::redundant_explicit_links)]
 #![allow(rustdoc::invalid_html_tags)]
 #![forbid(unsafe_code)]
 #![cfg_attr(docsrs, feature(doc_auto_cfg))]
 //! A REST JSON service that sends JSON requests and responses.
-21
 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* ServerRootGenerator.kt:65 */
 //! A fast and customizable Rust implementation of the RestJsonExtras Smithy service.
 //!
 //! # Using RestJsonExtras
 //!
 //! The primary entrypoint is [`RestJsonExtras`]: it satisfies the [`Service<http::Request, Response = http::Response>`](::tower::Service)
 //! trait and therefore can be handed to a [`hyper` server](https://github.com/hyperium/hyper) via [`RestJsonExtras::into_make_service`]
 //! or used in AWS Lambda
 #![cfg_attr(
     feature = "aws-lambda",
     doc = " via [`LambdaHandler`](crate::server::routing::LambdaHandler)."

↧ Expand context

 )]
 #![cfg_attr(
     not(feature = "aws-lambda"),
     doc = " by enabling the `aws-lambda` feature flag and utilizing the `LambdaHandler`."
 )]
 //! The [`crate::input`], [`crate::output`], and [`crate::error`]
 //! modules provide the types used in each operation.
 //!
 //! ### Running on Hyper
 //!
 //! ```rust,no_run
 //! # use std::net::SocketAddr;
 //! # async fn dummy() {
 //! use rest_json_extras::{RestJsonExtras, RestJsonExtrasConfig};
 //!
 //! # let app = RestJsonExtras::builder(
 //! #     RestJsonExtrasConfig::builder()
 //! #         .build()
 //! # ).build_unchecked();
 //! let server = app.into_make_service();

@@ -217,218 +296,305 @@

↥ Expand context

 //! }
 //!
 //! async fn primitive_int_header(input: input::PrimitiveIntHeaderInput) -> Result<output::PrimitiveIntHeaderOutput, error::PrimitiveIntHeaderError> {
 //!     todo!()
 //! }
 //!
 //! async fn primitive_int_op(input: input::PrimitiveIntOpInput) -> Result<output::PrimitiveIntOpOutput, error::PrimitiveIntOpError> {
 //!     todo!()
 //! }
 //!
 //! async fn query_precedence(input: input::QueryPrecedenceInput) -> Result<output::QueryPrecedenceOutput, error::QueryPrecedenceError> {
 //!     todo!()
 //! }
 //!
 //! async fn status_response(input: input::StatusResponseInput) -> Result<output::StatusResponseOutput, error::StatusResponseError> {
 //!     todo!()
 //! }
 //!
 //! async fn string_payload(input: input::StringPayloadInput) -> Result<output::StringPayloadOutput, error::StringPayloadError> {
 //!     todo!()

 //! }
 //!
 //! ```
 //!
 //! [`serve`]: https://docs.rs/hyper/0.14.16/hyper/server/struct.Builder.html#method.serve
 //! [`tower::make::MakeService`]: https://docs.rs/tower/latest/tower/make/trait.MakeService.html
 //! [HTTP binding traits]: https://smithy.io/2.0/spec/http-bindings.html
 //! [operations]: https://smithy.io/2.0/spec/service-types.html#operation
 //! [hyper server]: https://docs.rs/hyper/latest/hyper/server/index.html
 //! [Service]: https://docs.rs/tower-service/latest/tower_service/trait.Service.html
 /* ServerRootGenerator.kt:261 */
 pub use crate::service::{
     MissingOperationsError, RestJsonExtras, RestJsonExtrasBuilder, RestJsonExtrasConfig,
     RestJsonExtrasConfigBuilder,
 };
-253
 /// Contains the types that are re-exported from the `aws-smithy-http-server` crate.
 /// /* ServerRustModule.kt:55 */Contains the types that are re-exported from the `aws-smithy-http-server` crate.
 pub mod server {
     // Re-export all types from the `aws-smithy-http-server` crate.
     pub use ::aws_smithy_http_server::*;
-+
     /* CodegenDelegator.kt:200 */
-260
+}
-261
 /* CrateVersionCustomization.kt:23 */
 /// Crate version number.
 pub static PKG_VERSION: &str = env!("CARGO_PKG_VERSION");
-265
 /// Constrained types for constrained shapes.
 /// /* ServerRustModule.kt:55 */Constrained types for constrained shapes.
 /* RustModule.kt:172 */
 mod constrained;
-269
 /// All error types that operations can return. Documentation on these types is copied from the model.
 /// /* ServerRustModule.kt:55 */All error types that operations can return. Documentation on these types is copied from the model.
 pub mod error;
-272
 /// Input structures for operations. Documentation on these types is copied from the model.
 /// /* ServerRustModule.kt:55 */Input structures for operations. Documentation on these types is copied from the model.
 pub mod input;
-275
 /// Data structures used by operation inputs/outputs. Documentation on these types is copied from the model.
 /// /* ServerRustModule.kt:55 */Data structures used by operation inputs/outputs. Documentation on these types is copied from the model.
 pub mod model;
-278
 /// All operations that this crate can perform.
 /// /* ServerRustModule.kt:55 */All operations that this crate can perform.
 pub mod operation;
-281
 /* ServerRustModule.kt:79 */
 /// A collection of types representing each operation defined in the service closure.
 ///
 /// The [plugin system](::aws_smithy_http_server::plugin) makes use of these
 /// [zero-sized types](https://doc.rust-lang.org/nomicon/exotic-sizes.html#zero-sized-types-zsts) (ZSTs) to
 /// parameterize [`Plugin`](::aws_smithy_http_server::plugin::Plugin) implementations. Their traits, such as
 /// [`OperationShape`](::aws_smithy_http_server::operation::OperationShape), can be used to provide
 /// operation specific information to the [`Layer`](::tower::Layer) being applied.
 pub mod operation_shape;
-291
 /// Output structures for operations. Documentation on these types is copied from the model.
 /// /* ServerRustModule.kt:55 */Output structures for operations. Documentation on these types is copied from the model.
 pub mod output;
-294
 /* RustModule.kt:172 */
 mod service;
-297
 /// Data primitives referenced by other data types.
 /// /* ServerRustModule.kt:55 */Data primitives referenced by other data types.
 pub mod types;
-300
 /// Unconstrained types for constrained shapes.
 /// /* ServerRustModule.kt:55 */Unconstrained types for constrained shapes.
 /* RustModule.kt:172 */
 mod unconstrained;
-304
 pub(crate) mod protocol_serde;

tmp-codegen-diff/codegen-server-test/rest_json_extras/rust-server-codegen/src/model.rs

@@ -1,1 +386,518 @@

 // 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 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct EmptyStruct {}
 pub /* StructureGenerator.kt:201 */ struct EmptyStruct {/* StructureGenerator.kt:201 */}
 /* ServerCodegenVisitor.kt:345 */
 impl EmptyStruct {
     /// Creates a new builder-style object to manufacture [`EmptyStruct`](crate::model::EmptyStruct).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`EmptyStruct`](crate::model::EmptyStruct).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::model::empty_struct::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::model::empty_struct::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-17
+    }
     /* ServerCodegenVisitor.kt:345 */
-19
+}
-20
 /* UnionGenerator.kt:67 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub enum SingleElementUnion {
 pub /* UnionGenerator.kt:85 */ enum SingleElementUnion {
     /* UnionGenerator.kt:90 */
     #[allow(missing_docs)] // documentation missing in model
     /* UnionGenerator.kt:190 */
     A(::std::string::String),
     /* UnionGenerator.kt:85 */
-33
+}
 /* UnionGenerator.kt:111 */
 impl SingleElementUnion {
     /* RustType.kt:516 */
     #[allow(irrefutable_let_patterns)]
     /* UnionGenerator.kt:217 */
     /// Tries to convert the enum instance into [`A`](crate::model::SingleElementUnion::A), extracting the inner [`String`](::std::string::String).
     /* UnionGenerator.kt:222 */
     /// Returns `Err(&Self)` if it can't be converted.
     /* UnionGenerator.kt:223 */
     pub fn as_a(&self) -> ::std::result::Result<&::std::string::String, &Self> {
         /* UnionGenerator.kt:227 */
         if let SingleElementUnion::A(val) = &self {
             ::std::result::Result::Ok(val)
         } else {
             ::std::result::Result::Err(self)
-49
+        }
         /* UnionGenerator.kt:223 */
-51
+    }
     /* UnionGenerator.kt:121 */
     /// Returns true if this is a [`A`](crate::model::SingleElementUnion::A).
     /* UnionGenerator.kt:122 */
     pub fn is_a(&self) -> bool {
         /* UnionGenerator.kt:123 */
         self.as_a().is_ok()
         /* UnionGenerator.kt:122 */
-59
+    }
     /* UnionGenerator.kt:111 */
-61
+}
-62
 /// Describes one specific validation failure for an input member.
 /// /* StructureGenerator.kt:197 */Describes one specific validation failure for an input member.
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct ValidationExceptionField {
     /// A JSONPointer expression to the structure member whose value failed to satisfy the modeled constraints.
 pub /* StructureGenerator.kt:201 */ struct ValidationExceptionField {
     /// /* StructureGenerator.kt:231 */A JSONPointer expression to the structure member whose value failed to satisfy the modeled constraints.
     pub path: ::std::string::String,
     /// A detailed description of the validation failure.
     /// /* StructureGenerator.kt:231 */A detailed description of the validation failure.
     pub message: ::std::string::String,
     /* StructureGenerator.kt:201 */
-74
+}
 /* StructureGenerator.kt:135 */
 impl ValidationExceptionField {
     /// A JSONPointer expression to the structure member whose value failed to satisfy the modeled constraints.
     /// /* StructureGenerator.kt:231 */A JSONPointer expression to the structure member whose value failed to satisfy the modeled constraints.
     /* StructureGenerator.kt:166 */
     pub fn path(&self) -> &str {
         /* StructureGenerator.kt:171 */
         use std::ops::Deref;
         self.path.deref()
         /* StructureGenerator.kt:166 */
-84
+    }
     /// A detailed description of the validation failure.
     /// /* StructureGenerator.kt:231 */A detailed description of the validation failure.
     /* StructureGenerator.kt:166 */
     pub fn message(&self) -> &str {
         /* StructureGenerator.kt:171 */
         use std::ops::Deref;
         self.message.deref()
         /* StructureGenerator.kt:166 */
-92
+    }
     /* StructureGenerator.kt:135 */
-94
+}
 /* ServerCodegenVisitor.kt:345 */
 impl ValidationExceptionField {
     /// Creates a new builder-style object to manufacture [`ValidationExceptionField`](crate::model::ValidationExceptionField).
     /// /* ServerBuilderGenerator.kt:294 */Creates a new builder-style object to manufacture [`ValidationExceptionField`](crate::model::ValidationExceptionField).
     /* ServerBuilderGenerator.kt:295 */
     pub fn builder() -> crate::model::validation_exception_field::Builder {
         /* ServerBuilderGenerator.kt:296 */
         crate::model::validation_exception_field::Builder::default()
         /* ServerBuilderGenerator.kt:295 */
-103
+    }
     /* ServerCodegenVisitor.kt:345 */
-105
+}
-106
 /* EnumGenerator.kt:154 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone,
     ::std::cmp::Eq,
     ::std::cmp::Ord,
     ::std::cmp::PartialEq,
     ::std::cmp::PartialOrd,
     ::std::fmt::Debug,
     ::std::hash::Hash,
 )]
 pub enum EnumWithEscapedChars {
     /// this needs#tobe escaped
 pub /* EnumGenerator.kt:267 */ enum EnumWithEscapedChars {
     /// /* EnumGenerator.kt:156 */this needs#tobe escaped
     /* EnumGenerator.kt:143 */
     HasQuotes,
     /* EnumGenerator.kt:154 */
     #[allow(missing_docs)] // documentation missing in model
     /* EnumGenerator.kt:143 */
     Normal,
     /* EnumGenerator.kt:267 */
-128
+}
 /// See [`EnumWithEscapedChars`](crate::model::EnumWithEscapedChars).
 /// /* CodegenDelegator.kt:51 */See [`EnumWithEscapedChars`](crate::model::EnumWithEscapedChars).
 pub mod enum_with_escaped_chars {
     #[derive(Debug, PartialEq)]
     pub struct ConstraintViolation(pub(crate) ::std::string::String);
-133
     impl ::std::fmt::Display for ConstraintViolation {
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             write!(
                 f,
                 r#"Value provided for 'aws.protocoltests.restjson#EnumWithEscapedChars' failed to satisfy constraint: Member must satisfy enum value set: [has"quotes, normal]"#
-139
+            )
-140
+        }
-141
+    }
-142
     impl ::std::error::Error for ConstraintViolation {}
     impl ConstraintViolation {
         pub(crate) fn as_validation_exception_field(
             self,
             path: ::std::string::String,
         ) -> crate::model::ValidationExceptionField {
             crate::model::ValidationExceptionField {
                 message: format!(
                     r#"Value at '{}' failed to satisfy constraint: Member must satisfy enum value set: [has"quotes, normal]"#,
                     &path
                 ),
                 path,
-155
+            }
-156
+        }
-157
+    }
-+
     /* ServerEnumGenerator.kt:46 */
-160
+}
 /* ServerEnumGenerator.kt:85 */
 impl ::std::convert::TryFrom<&str> for EnumWithEscapedChars {
     type Error = crate::model::enum_with_escaped_chars::ConstraintViolation;
     fn try_from(
         s: &str,
     ) -> ::std::result::Result<Self, <Self as ::std::convert::TryFrom<&str>>::Error> {
         match s {
             "has\"quotes" => Ok(EnumWithEscapedChars::HasQuotes),
             "normal" => Ok(EnumWithEscapedChars::Normal),
             _ => Err(crate::model::enum_with_escaped_chars::ConstraintViolation(
                 s.to_owned(),
             )),
-173
+        }
-174
+    }
-175
+}
 impl ::std::convert::TryFrom<::std::string::String> for EnumWithEscapedChars {
     type Error = crate::model::enum_with_escaped_chars::ConstraintViolation;
     fn try_from(
         s: ::std::string::String,
     ) -> ::std::result::Result<Self, <Self as ::std::convert::TryFrom<::std::string::String>>::Error>
-181
+    {
         s.as_str().try_into()
-183
+    }
-184
+}
 /* ServerEnumGenerator.kt:145 */
 impl std::str::FromStr for EnumWithEscapedChars {
     type Err = crate::model::enum_with_escaped_chars::ConstraintViolation;
     fn from_str(s: &str) -> std::result::Result<Self, <Self as std::str::FromStr>::Err> {
         Self::try_from(s)
-190
+    }
-191
+}
 /* EnumGenerator.kt:274 */
 impl EnumWithEscapedChars {
     /// Returns the `&str` value of the enum member.
     pub fn as_str(&self) -> &str {
         match self {
             EnumWithEscapedChars::HasQuotes => "has\"quotes",
             EnumWithEscapedChars::Normal => "normal",
-199
+        }
-200
+    }
     /// Returns all the `&str` representations of the enum members.
     pub const fn values() -> &'static [&'static str] {
         &["has\"quotes", "normal"]
-204
+    }
-205
+}
 /* EnumGenerator.kt:223 */
 impl ::std::convert::AsRef<str> for EnumWithEscapedChars {
     fn as_ref(&self) -> &str {
         self.as_str()
-210
+    }
-211
+}
 /* ConstrainedTraitForEnumGenerator.kt:36 */
 impl crate::constrained::Constrained for EnumWithEscapedChars {
     type Unconstrained = ::std::string::String;
-215
+}
-216
 impl ::std::convert::From<::std::string::String>
     for crate::constrained::MaybeConstrained<crate::model::EnumWithEscapedChars>
-219
+{
     fn from(value: ::std::string::String) -> Self {
         Self::Unconstrained(value)
-222
+    }
-223
+}
-224
 /* EnumGenerator.kt:154 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[derive(
     ::std::clone::Clone,
     ::std::cmp::Eq,
     ::std::cmp::Ord,
     ::std::cmp::PartialEq,
     ::std::cmp::PartialOrd,
     ::std::fmt::Debug,
     ::std::hash::Hash,
 )]
 pub enum StringEnum {
 pub /* EnumGenerator.kt:267 */ enum StringEnum {
     /* EnumGenerator.kt:154 */
     #[allow(missing_docs)] // documentation missing in model
     /* EnumGenerator.kt:143 */
     V,
     /* EnumGenerator.kt:267 */
-243
+}
 /// See [`StringEnum`](crate::model::StringEnum).
 /// /* CodegenDelegator.kt:51 */See [`StringEnum`](crate::model::StringEnum).
 pub mod string_enum {
     #[derive(Debug, PartialEq)]
     pub struct ConstraintViolation(pub(crate) ::std::string::String);
-248
     impl ::std::fmt::Display for ConstraintViolation {
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             write!(
                 f,
                 r#"Value provided for 'aws.protocoltests.restjson#StringEnum' failed to satisfy constraint: Member must satisfy enum value set: [enumvalue]"#
-254
+            )
-255
+        }
-256
+    }
-257
     impl ::std::error::Error for ConstraintViolation {}
     impl ConstraintViolation {
         pub(crate) fn as_validation_exception_field(
             self,
             path: ::std::string::String,
         ) -> crate::model::ValidationExceptionField {
             crate::model::ValidationExceptionField {
                 message: format!(
                     r#"Value at '{}' failed to satisfy constraint: Member must satisfy enum value set: [enumvalue]"#,
                     &path
                 ),
                 path,
-270
+            }
-271
+        }
-272
+    }
-+
     /* ServerEnumGenerator.kt:46 */
-275
+}
 /* ServerEnumGenerator.kt:85 */
 impl ::std::convert::TryFrom<&str> for StringEnum {
     type Error = crate::model::string_enum::ConstraintViolation;
     fn try_from(
         s: &str,
     ) -> ::std::result::Result<Self, <Self as ::std::convert::TryFrom<&str>>::Error> {
         match s {
             "enumvalue" => Ok(StringEnum::V),
             _ => Err(crate::model::string_enum::ConstraintViolation(s.to_owned())),
-285
+        }
-286
+    }
-287
+}
 impl ::std::convert::TryFrom<::std::string::String> for StringEnum {
     type Error = crate::model::string_enum::ConstraintViolation;
     fn try_from(
         s: ::std::string::String,
     ) -> ::std::result::Result<Self, <Self as ::std::convert::TryFrom<::std::string::String>>::Error>
-293
+    {
         s.as_str().try_into()
-295
+    }
-296
+}
 /* ServerEnumGenerator.kt:145 */
 impl std::str::FromStr for StringEnum {
     type Err = crate::model::string_enum::ConstraintViolation;
     fn from_str(s: &str) -> std::result::Result<Self, <Self as std::str::FromStr>::Err> {
         Self::try_from(s)
-302
+    }
-303
+}
 /* EnumGenerator.kt:274 */
 impl StringEnum {
     /// Returns the `&str` value of the enum member.
     pub fn as_str(&self) -> &str {
         match self {
             StringEnum::V => "enumvalue",
-310
+        }
-311
+    }
     /// Returns all the `&str` representations of the enum members.
     pub const fn values() -> &'static [&'static str] {
         &["enumvalue"]
-315
+    }
-316
+}
 /* EnumGenerator.kt:223 */
 impl ::std::convert::AsRef<str> for StringEnum {
     fn as_ref(&self) -> &str {
         self.as_str()
-321
+    }
-322
+}
 /* ConstrainedTraitForEnumGenerator.kt:36 */
 impl crate::constrained::Constrained for StringEnum {
     type Unconstrained = ::std::string::String;
-326
+}
-327
 impl ::std::convert::From<::std::string::String>
     for crate::constrained::MaybeConstrained<crate::model::StringEnum>
-330
+{
     fn from(value: ::std::string::String) -> Self {
         Self::Unconstrained(value)
-333
+    }
-334
+}
 /// See [`EmptyStruct`](crate::model::EmptyStruct).
 /// /* ServerBuilderGenerator.kt:171 */See [`EmptyStruct`](crate::model::EmptyStruct).
 pub mod empty_struct {
-337
     /* ServerBuilderGenerator.kt:461 */
     impl ::std::convert::From<Builder> for crate::model::EmptyStruct {
         fn from(builder: Builder) -> Self {
             builder.build()
-342
+        }
-343
+    }
     /// A builder for [`EmptyStruct`](crate::model::EmptyStruct).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`EmptyStruct`](crate::model::EmptyStruct).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {}
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {/* ServerBuilderGenerator.kt:211 */}
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// Consumes the builder and constructs a [`EmptyStruct`](crate::model::EmptyStruct).
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`EmptyStruct`](crate::model::EmptyStruct).
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> crate::model::EmptyStruct {
             self.build_enforcing_all_constraints()
-355
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(self) -> crate::model::EmptyStruct {
             crate::model::EmptyStruct {}
             /* ServerBuilderGenerator.kt:542 */
             crate::model::EmptyStruct {
             /* ServerBuilderGenerator.kt:542 */}
             /* ServerBuilderGenerator.kt:283 */
-362
+        }
         /* ServerBuilderGenerator.kt:215 */
-364
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-367
+}
 /// See [`ValidationExceptionField`](crate::model::ValidationExceptionField).
 /// /* ServerBuilderGenerator.kt:171 */See [`ValidationExceptionField`](crate::model::ValidationExceptionField).
 pub mod validation_exception_field {
-370
     /* RustType.kt:516 */
     #[derive(::std::cmp::PartialEq, ::std::fmt::Debug)]
     /// Holds one variant for each of the ways the builder can fail.
     /// /* ServerBuilderConstraintViolations.kt:72 */Holds one variant for each of the ways the builder can fail.
     /* RustType.kt:516 */
     #[non_exhaustive]
     /* ServerBuilderConstraintViolations.kt:75 */
     #[allow(clippy::enum_variant_names)]
     pub enum ConstraintViolation {
         /// `path` was not provided but it is required when building `ValidationExceptionField`.
         /// /* ServerBuilderConstraintViolations.kt:138 */`path` was not provided but it is required when building `ValidationExceptionField`.
         /* ServerBuilderConstraintViolations.kt:143 */
         MissingPath,
         /// `message` was not provided but it is required when building `ValidationExceptionField`.
         /// /* ServerBuilderConstraintViolations.kt:138 */`message` was not provided but it is required when building `ValidationExceptionField`.
         /* ServerBuilderConstraintViolations.kt:143 */
         MissingMessage,
         /* ServerBuilderConstraintViolations.kt:75 */
-386
+    }
     /* ServerBuilderConstraintViolations.kt:117 */
     impl ::std::fmt::Display for ConstraintViolation {
         /* ServerBuilderConstraintViolations.kt:118 */
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             /* ServerBuilderConstraintViolations.kt:119 */
             match self {
                 ConstraintViolation::MissingPath => write!(f, "`path` was not provided but it is required when building `ValidationExceptionField`"),
                 ConstraintViolation::MissingMessage => write!(f, "`message` was not provided but it is required when building `ValidationExceptionField`"),
--
+            }
                 /* ServerBuilderConstraintViolations.kt:127 */ConstraintViolation::MissingPath => write!(f, "`path` was not provided but it is required when building `ValidationExceptionField`"),
                 /* ServerBuilderConstraintViolations.kt:127 */ConstraintViolation::MissingMessage => write!(f, "`message` was not provided but it is required when building `ValidationExceptionField`"),
             /* ServerBuilderConstraintViolations.kt:119 */}
             /* ServerBuilderConstraintViolations.kt:118 */
-397
+        }
         /* ServerBuilderConstraintViolations.kt:117 */
-399
+    }
     /* ServerBuilderConstraintViolations.kt:84 */
     impl ::std::error::Error for ConstraintViolation {}
     /* ServerBuilderGenerator.kt:446 */
     impl ::std::convert::TryFrom<Builder> for crate::model::ValidationExceptionField {
         type Error = ConstraintViolation;
-405
         fn try_from(builder: Builder) -> ::std::result::Result<Self, Self::Error> {
             builder.build()
-408
+        }
-409
+    }
     /// A builder for [`ValidationExceptionField`](crate::model::ValidationExceptionField).
     /// /* ServerBuilderGenerator.kt:201 */A builder for [`ValidationExceptionField`](crate::model::ValidationExceptionField).
     /* RustType.kt:516 */
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     /* ServerBuilderGenerator.kt:211 */
     pub struct Builder {
         /* ServerBuilderGenerator.kt:308 */
         pub(crate) path: ::std::option::Option<::std::string::String>,
         /* ServerBuilderGenerator.kt:308 */
         pub(crate) message: ::std::option::Option<::std::string::String>,
         /* ServerBuilderGenerator.kt:211 */
-420
+    }
     /* ServerBuilderGenerator.kt:215 */
     impl Builder {
         /// A JSONPointer expression to the structure member whose value failed to satisfy the modeled constraints.
         /// /* ServerBuilderGenerator.kt:331 */A JSONPointer expression to the structure member whose value failed to satisfy the modeled constraints.
         /* ServerBuilderGenerator.kt:343 */
         pub fn path(mut self, input: ::std::string::String) -> Self {
             self.path = Some(input);
             /* ServerBuilderGenerator.kt:344 */
             self.path =
                 /* ServerBuilderGenerator.kt:345 */Some(
                     /* ServerBuilderGenerator.kt:376 */input
                 /* ServerBuilderGenerator.kt:345 */)
             /* ServerBuilderGenerator.kt:344 */;
             self
             /* ServerBuilderGenerator.kt:343 */
-434
+        }
         /// A detailed description of the validation failure.
         /// /* ServerBuilderGenerator.kt:331 */A detailed description of the validation failure.
         /* ServerBuilderGenerator.kt:343 */
         pub fn message(mut self, input: ::std::string::String) -> Self {
             self.message = Some(input);
             /* ServerBuilderGenerator.kt:344 */
             self.message =
                 /* ServerBuilderGenerator.kt:345 */Some(
                     /* ServerBuilderGenerator.kt:376 */input
                 /* ServerBuilderGenerator.kt:345 */)
             /* ServerBuilderGenerator.kt:344 */;
             self
             /* ServerBuilderGenerator.kt:343 */
-446
+        }
         /// Consumes the builder and constructs a [`ValidationExceptionField`](crate::model::ValidationExceptionField).
         ///
         /// /* ServerBuilderGenerator.kt:258 */Consumes the builder and constructs a [`ValidationExceptionField`](crate::model::ValidationExceptionField).
         /// /* ServerBuilderGenerator.kt:260 */
         /// The builder fails to construct a [`ValidationExceptionField`](crate::model::ValidationExceptionField) if a [`ConstraintViolation`] occurs.
         ///
         /// If the builder fails, it will return the _first_ encountered [`ConstraintViolation`].
         /// /* ServerBuilderGenerator.kt:268 */If the builder fails, it will return the _first_ encountered [`ConstraintViolation`].
         /* ServerBuilderGenerator.kt:271 */
         pub fn build(self) -> Result<crate::model::ValidationExceptionField, ConstraintViolation> {
             self.build_enforcing_all_constraints()
-455
+        }
         /* ServerBuilderGenerator.kt:283 */
         fn build_enforcing_all_constraints(
             self,
         ) -> Result<crate::model::ValidationExceptionField, ConstraintViolation> {
             Ok(crate::model::ValidationExceptionField {
                 path: self.path.ok_or(ConstraintViolation::MissingPath)?,
                 message: self.message.ok_or(ConstraintViolation::MissingMessage)?,
             })
             /* ServerBuilderGenerator.kt:287 */
             Ok(
                 /* ServerBuilderGenerator.kt:542 */
                 crate::model::ValidationExceptionField {
                     /* ServerBuilderGenerator.kt:546 */
                     path: self
                         .path
                         /* ServerBuilderGenerator.kt:569 */
                         .ok_or(ConstraintViolation::MissingPath)?,
                     /* ServerBuilderGenerator.kt:546 */
                     message: self
                         .message
                         /* ServerBuilderGenerator.kt:569 */
                         .ok_or(ConstraintViolation::MissingMessage)?,
                     /* ServerBuilderGenerator.kt:542 */
                 }, /* ServerBuilderGenerator.kt:287 */
-+
+            )
             /* ServerBuilderGenerator.kt:283 */
-478
+        }
         /* ServerBuilderGenerator.kt:215 */
-480
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-483
+}
 pub mod map_with_enum_key {
-485
     /* MapConstraintViolationGenerator.kt:82 */
     #[allow(clippy::enum_variant_names)]
     #[derive(Debug, PartialEq)]
     pub enum ConstraintViolation {
         #[doc(hidden)]
         Key(crate::model::string_enum::ConstraintViolation),
-492
+    }
-493
     impl ::std::fmt::Display for ConstraintViolation {
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             match self {
                 Self::Key(key_constraint_violation) => write!(f, "{}", key_constraint_violation),
-498
+            }
-499
+        }
-500
+    }
-501
     impl ::std::error::Error for ConstraintViolation {}
     /* MapConstraintViolationGenerator.kt:111 */
     impl ConstraintViolation {
         pub(crate) fn as_validation_exception_field(
             self,
             path: ::std::string::String,
         ) -> crate::model::ValidationExceptionField {
             match self {
                 Self::Key(key_constraint_violation) => {
                     key_constraint_violation.as_validation_exception_field(path)
-512
+                }
-513
+            }
-514
+        }
-515
+    }
-+
     /* RustCrateInlineModuleComposingWriter.kt:299 */
-518
+}

tmp-codegen-diff/codegen-server-test/rest_json_extras/rust-server-codegen/src/operation.rs

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

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_QUERYPRECEDENCE: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`QueryPrecedenceInput`](crate::input::QueryPrecedenceInput) using modelled bindings.
     pub struct QueryPrecedenceInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryPrecedenceInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-9
+    }
-10
+}
-11
 impl std::future::Future for QueryPrecedenceInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::QueryPrecedenceInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-17
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-24
+    }
-25
+}
-26
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::QueryPrecedenceInput
 where

@@ -38,39 +138,144 @@

↥ Expand context

-39
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = QueryPrecedenceInputFuture;
-42
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_QUERYPRECEDENCE,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-50
+            }
             crate::protocol_serde::shape_query_precedence::de_query_precedence_http_request(request)
                 .await
                 .map_err(Into::into)
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-61
+                )
             },
         );
         QueryPrecedenceInputFuture {
             inner: Box::pin(fut),
-66
+        }
-67
+    }
-68
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::QueryPrecedenceOutput
-74
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_query_precedence::ser_query_precedence_http_response(
             self,
         ) {
             Ok(response) => response,
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-83
+            }
-84
+        }
-85
+    }
-86
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::QueryPrecedenceError
-92
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_query_precedence::ser_query_precedence_http_error(&self)
-95
+        {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                 );
                 response
-101
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-105
+            }
-106
+        }
-107
+    }
-108
+}
-109
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod query_precedence_test {
-116
     /// Servers put all query params in map
     /// Test ID: RestJsonServersPutAllQueryParamsInMap
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn rest_json_servers_put_all_query_params_in_map_request() {
         #[allow(unused_mut)]
         let mut http_request = http::Request::builder()
             .uri("/Precedence")

↧ Expand context

             .method("POST")
             .body(::aws_smithy_http_server::body::Body::from(
                 ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                     "".as_bytes(),
                     ::aws_smithy_protocol_test::MediaType::from("unknown"),
                 )),
             ))
             .unwrap();
         *http_request.uri_mut() = "/Precedence?bar=named&qux=fromMap".parse().unwrap();
         #[allow(unused_mut)]
         let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
         let config = crate::service::RestJsonExtrasConfig::builder().build();
         let service =
             crate::service::RestJsonExtras::builder::<::hyper::body::Body, _, _, _>(config)
                 .query_precedence(move |input: crate::input::QueryPrecedenceInput| {
                     let sender = sender.clone();
                     async move {
                         let result = {
                             let expected = crate::input::QueryPrecedenceInput {
                                 foo: ::std::option::Option::Some("named".to_owned()),

@@ -161,167 +222,231 @@

↥ Expand context

         );
-168
+    }
-169
     /// Upper case error modeled lower case.
     /// Test ID: ServiceLevelErrorServer
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn service_level_error_server_response() {
         let output = crate::error::ExtraError {};
         let output = crate::error::QueryPrecedenceError::ExtraError(output);
         use ::aws_smithy_http_server::response::IntoResponse;
         let http_response = output.into_response();
         ::pretty_assertions::assert_eq!(
             http::StatusCode::from_u16(500).expect("invalid expected HTTP status code"),
             http_response.status()
         );
         let expected_headers = [("X-Amzn-Errortype", "ExtraError")];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
             http_response.headers(),
             expected_headers,

         ));
         let body = ::hyper::body::to_bytes(http_response.into_body())
             .await
             .expect("unable to extract body to bytes");
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_body(
             &body,
             "{}",
             ::aws_smithy_protocol_test::MediaType::from("unknown"),
         ));
-196
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-199
+}
-200
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_EMPTYSTRUCTWITHCONTENTONWIREOP: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`EmptyStructWithContentOnWireOpInput`](crate::input::EmptyStructWithContentOnWireOpInput) using modelled bindings.
     pub struct EmptyStructWithContentOnWireOpInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EmptyStructWithContentOnWireOpInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-208
+    }
-209
+}
-210
 impl std::future::Future for EmptyStructWithContentOnWireOpInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::EmptyStructWithContentOnWireOpInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-216
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-223
+    }
-224
+}
-225
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::EmptyStructWithContentOnWireOpInput
 where

@@ -229,238 +355,372 @@

↥ Expand context

-238
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = EmptyStructWithContentOnWireOpInputFuture;
-241
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_EMPTYSTRUCTWITHCONTENTONWIREOP,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-249
+            }
             crate::protocol_serde::shape_empty_struct_with_content_on_wire_op::de_empty_struct_with_content_on_wire_op_http_request(request)
                             .await
                             .map_err(Into::into)
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-260
+                )
             },
         );
         EmptyStructWithContentOnWireOpInputFuture {
             inner: Box::pin(fut),
-265
+        }
-266
+    }
-267
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::EmptyStructWithContentOnWireOpOutput
-273
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_empty_struct_with_content_on_wire_op::ser_empty_struct_with_content_on_wire_op_http_response(self) {
                         Ok(response) => response,
                         Err(e) => {
                             ::tracing::error!(error = %e, "failed to serialize response");
                             ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-280
+                        }
-281
+                    }
-282
+    }
-283
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::EmptyStructWithContentOnWireOpError
-289
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_empty_struct_with_content_on_wire_op::ser_empty_struct_with_content_on_wire_op_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response
             },
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-299
+            }
-300
+        }
-301
+    }
-302
+}
-303
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod empty_struct_with_content_on_wire_op_test {
-310
     /// Upper case error modeled lower case.
     /// Test ID: ServiceLevelErrorServer
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn service_level_error_server_response() {
         let output = crate::error::ExtraError {};
         let output = crate::error::EmptyStructWithContentOnWireOpError::ExtraError(output);
         use ::aws_smithy_http_server::response::IntoResponse;
         let http_response = output.into_response();
         ::pretty_assertions::assert_eq!(
             http::StatusCode::from_u16(500).expect("invalid expected HTTP status code"),
             http_response.status()
         );
         let expected_headers = [("X-Amzn-Errortype", "ExtraError")];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
             http_response.headers(),
             expected_headers,
         ));
         let body = ::hyper::body::to_bytes(http_response.into_body())
             .await
             .expect("unable to extract body to bytes");
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_body(
             &body,
             "{}",
             ::aws_smithy_protocol_test::MediaType::from("unknown"),
         ));
-337
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-340
+}
-341
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_CASEINSENSITIVEERROROPERATION: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`CaseInsensitiveErrorOperationInput`](crate::input::CaseInsensitiveErrorOperationInput) using modelled bindings.
     pub struct CaseInsensitiveErrorOperationInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::CaseInsensitiveErrorOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-349
+    }
-350
+}
-351
 impl std::future::Future for CaseInsensitiveErrorOperationInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::CaseInsensitiveErrorOperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-357
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-364
+    }
-365
+}
-366
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::CaseInsensitiveErrorOperationInput
 where

@@ -362,379 +488,513 @@

↥ Expand context

-379
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = CaseInsensitiveErrorOperationInputFuture;
-382
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_CASEINSENSITIVEERROROPERATION,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-390
+            }
             crate::protocol_serde::shape_case_insensitive_error_operation::de_case_insensitive_error_operation_http_request(request)
                             .await
                             .map_err(Into::into)
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-401
+                )
             },
         );
         CaseInsensitiveErrorOperationInputFuture {
             inner: Box::pin(fut),
-406
+        }
-407
+    }
-408
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::CaseInsensitiveErrorOperationOutput
-414
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_case_insensitive_error_operation::ser_case_insensitive_error_operation_http_response(self) {
                         Ok(response) => response,
                         Err(e) => {
                             ::tracing::error!(error = %e, "failed to serialize response");
                             ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-421
+                        }
-422
+                    }
-423
+    }
-424
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::CaseInsensitiveErrorOperationError
-430
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_case_insensitive_error_operation::ser_case_insensitive_error_operation_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response
             },
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-440
+            }
-441
+        }
-442
+    }
-443
+}
-444
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod case_insensitive_error_operation_test {
-451
     /// Upper case error modeled lower case.
     /// Test ID: ServiceLevelErrorServer
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn service_level_error_server_response() {
         let output = crate::error::ExtraError {};
         let output = crate::error::CaseInsensitiveErrorOperationError::ExtraError(output);
         use ::aws_smithy_http_server::response::IntoResponse;
         let http_response = output.into_response();
         ::pretty_assertions::assert_eq!(
             http::StatusCode::from_u16(500).expect("invalid expected HTTP status code"),
             http_response.status()
         );
         let expected_headers = [("X-Amzn-Errortype", "ExtraError")];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
             http_response.headers(),
             expected_headers,
         ));
         let body = ::hyper::body::to_bytes(http_response.into_body())
             .await
             .expect("unable to extract body to bytes");
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_body(
             &body,
             "{}",
             ::aws_smithy_protocol_test::MediaType::from("unknown"),
         ));
-478
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-481
+}
-482
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_NULLINNONSPARSE: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`NullInNonSparseInput`](crate::input::NullInNonSparseInput) using modelled bindings.
     pub struct NullInNonSparseInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::NullInNonSparseInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-490
+    }
-491
+}
-492
 impl std::future::Future for NullInNonSparseInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::NullInNonSparseInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-498
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-505
+    }
-506
+}
-507
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::NullInNonSparseInput
 where

@@ -497,522 +629,662 @@

↥ Expand context

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

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-544
+                )
             },
         );
         NullInNonSparseInputFuture {
             inner: Box::pin(fut),
-549
+        }
-550
+    }
-551
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::NullInNonSparseOutput
-557
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_null_in_non_sparse::ser_null_in_non_sparse_http_response(
             self,
         ) {
             Ok(response) => response,
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-566
+            }
-567
+        }
-568
+    }
-569
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::NullInNonSparseError
-575
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_null_in_non_sparse::ser_null_in_non_sparse_http_error(
             &self,
         ) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                 );
                 response
-585
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-589
+            }
-590
+        }
-591
+    }
-592
+}
-593
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod null_in_non_sparse_test {
-600
     /// Upper case error modeled lower case.
     /// Test ID: ServiceLevelErrorServer
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn service_level_error_server_response() {
         let output = crate::error::ExtraError {};
         let output = crate::error::NullInNonSparseError::ExtraError(output);
         use ::aws_smithy_http_server::response::IntoResponse;
         let http_response = output.into_response();
         ::pretty_assertions::assert_eq!(
             http::StatusCode::from_u16(500).expect("invalid expected HTTP status code"),
             http_response.status()
         );
         let expected_headers = [("X-Amzn-Errortype", "ExtraError")];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
             http_response.headers(),
             expected_headers,
         ));
         let body = ::hyper::body::to_bytes(http_response.into_body())
             .await
             .expect("unable to extract body to bytes");
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_body(
             &body,
             "{}",
             ::aws_smithy_protocol_test::MediaType::from("unknown"),
         ));
-627
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-630
+}
-631
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_ESCAPEDSTRINGVALUES: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`EscapedStringValuesInput`](crate::input::EscapedStringValuesInput) using modelled bindings.
     pub struct EscapedStringValuesInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EscapedStringValuesInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-639
+    }
-640
+}
-641
 impl std::future::Future for EscapedStringValuesInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::EscapedStringValuesInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-647
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-654
+    }
-655
+}
-656
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::EscapedStringValuesInput
 where

@@ -636,669 +731,769 @@

↥ Expand context

-669
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = EscapedStringValuesInputFuture;
-672
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_ESCAPEDSTRINGVALUES,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-680
+            }
             crate::protocol_serde::shape_escaped_string_values::de_escaped_string_values_http_request(request)
                             .await
                             .map_err(Into::into)
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-691
+                )
             },
         );
         EscapedStringValuesInputFuture {
             inner: Box::pin(fut),
-696
+        }
-697
+    }
-698
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::EscapedStringValuesOutput
-704
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_escaped_string_values::ser_escaped_string_values_http_response(self) {
                         Ok(response) => response,
                         Err(e) => {
                             ::tracing::error!(error = %e, "failed to serialize response");
                             ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-711
+                        }
-712
+                    }
-713
+    }
-714
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::EscapedStringValuesError
-720
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_escaped_string_values::ser_escaped_string_values_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response
             },
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-730
+            }
-731
+        }
-732
+    }
-733
+}
-734
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod escaped_string_values_test {
-741
     /// Test ID: EscapedStringValuesRequest
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn escaped_string_values_request_request() {
         #[allow(unused_mut)]
         let mut http_request = http::Request::builder()
             .uri("/escaped-string-values")
             .method("POST")

↧ Expand context

             .header("Content-Type", "application/json")
             .body(::aws_smithy_http_server::body::Body::from(
                 ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                     "{\"enum\":\"has\\\"quotes\",\"also\\\"has\\\"quotes\":\"test\"}".as_bytes(),
                     ::aws_smithy_protocol_test::MediaType::from("unknown"),
                 )),
             ))
             .unwrap();
         #[allow(unused_mut)]
         let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
         let config = crate::service::RestJsonExtrasConfig::builder().build();
         let service =
             crate::service::RestJsonExtras::builder::<::hyper::body::Body, _, _, _>(config)
                 .escaped_string_values(move |input: crate::input::EscapedStringValuesInput| {
                     let sender = sender.clone();
                     async move {
                         let result = {
                             let expected = crate::input::EscapedStringValuesInput {
                                 r#enum: ::std::option::Option::Some(
                                     "has\"quotes"

@@ -782,820 +843,884 @@

↥ Expand context

         ));
-821
+    }
-822
     /// Upper case error modeled lower case.
     /// Test ID: ServiceLevelErrorServer
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn service_level_error_server_response() {
         let output = crate::error::ExtraError {};
         let output = crate::error::EscapedStringValuesError::ExtraError(output);
         use ::aws_smithy_http_server::response::IntoResponse;
         let http_response = output.into_response();
         ::pretty_assertions::assert_eq!(
             http::StatusCode::from_u16(500).expect("invalid expected HTTP status code"),
             http_response.status()
         );
         let expected_headers = [("X-Amzn-Errortype", "ExtraError")];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
             http_response.headers(),
             expected_headers,

         ));
         let body = ::hyper::body::to_bytes(http_response.into_body())
             .await
             .expect("unable to extract body to bytes");
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_body(
             &body,
             "{}",
             ::aws_smithy_protocol_test::MediaType::from("unknown"),
         ));
-849
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-852
+}
-853
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_PRIMITIVEINTOP: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`PrimitiveIntOpInput`](crate::input::PrimitiveIntOpInput) using modelled bindings.
     pub struct PrimitiveIntOpInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::PrimitiveIntOpInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-861
+    }
-862
+}
-863
 impl std::future::Future for PrimitiveIntOpInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::PrimitiveIntOpInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-869
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-876
+    }
-877
+}
-878
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::PrimitiveIntOpInput
 where

@@ -850,891 +981,1030 @@

↥ Expand context

-891
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = PrimitiveIntOpInputFuture;
-894
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_PRIMITIVEINTOP,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-902
+            }
             crate::protocol_serde::shape_primitive_int_op::de_primitive_int_op_http_request(request)
                 .await
                 .map_err(Into::into)
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-913
+                )
             },
         );
         PrimitiveIntOpInputFuture {
             inner: Box::pin(fut),
-918
+        }
-919
+    }
-920
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::PrimitiveIntOpOutput
-926
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_primitive_int_op::ser_primitive_int_op_http_response(
             self,
         ) {
             Ok(response) => response,
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-935
+            }
-936
+        }
-937
+    }
-938
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::PrimitiveIntOpError
-944
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_primitive_int_op::ser_primitive_int_op_http_error(&self)
-947
+        {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                 );
                 response
-953
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-957
+            }
-958
+        }
-959
+    }
-960
+}
-961
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod primitive_int_op_test {
-968
     /// Upper case error modeled lower case.
     /// Test ID: ServiceLevelErrorServer
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn service_level_error_server_response() {
         let output = crate::error::ExtraError {};
         let output = crate::error::PrimitiveIntOpError::ExtraError(output);
         use ::aws_smithy_http_server::response::IntoResponse;
         let http_response = output.into_response();
         ::pretty_assertions::assert_eq!(
             http::StatusCode::from_u16(500).expect("invalid expected HTTP status code"),
             http_response.status()
         );
         let expected_headers = [("X-Amzn-Errortype", "ExtraError")];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
             http_response.headers(),
             expected_headers,
         ));
         let body = ::hyper::body::to_bytes(http_response.into_body())
             .await
             .expect("unable to extract body to bytes");
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_body(
             &body,
             "{}",
             ::aws_smithy_protocol_test::MediaType::from("unknown"),
         ));
-995
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-998
+}
-999
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_MAPWITHENUMKEYOP: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`MapWithEnumKeyOpInput`](crate::input::MapWithEnumKeyOpInput) using modelled bindings.
     pub struct MapWithEnumKeyOpInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::MapWithEnumKeyOpInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-1007
+    }
-1008
+}
-1009
 impl std::future::Future for MapWithEnumKeyOpInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::MapWithEnumKeyOpInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-1015
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-1022
+    }
-1023
+}
-1024
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::MapWithEnumKeyOpInput
 where

@@ -990,1039 +1089,1143 @@

↥ Expand context

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

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-1061
+                )
             },
         );
         MapWithEnumKeyOpInputFuture {
             inner: Box::pin(fut),
-1066
+        }
-1067
+    }
-1068
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::MapWithEnumKeyOpOutput
-1074
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_map_with_enum_key_op::ser_map_with_enum_key_op_http_response(self) {
                         Ok(response) => response,
                         Err(e) => {
                             ::tracing::error!(error = %e, "failed to serialize response");
                             ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-1081
+                        }
-1082
+                    }
-1083
+    }
-1084
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::MapWithEnumKeyOpError
-1090
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_map_with_enum_key_op::ser_map_with_enum_key_op_http_error(
             &self,
         ) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                 );
                 response
-1100
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-1104
+            }
-1105
+        }
-1106
+    }
-1107
+}
-1108
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod map_with_enum_key_op_test {
-1115
     /// Test ID: MapWithEnumKeyRequest
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn map_with_enum_key_request_request() {
         #[allow(unused_mut)]
         let mut http_request = http::Request::builder()
             .uri("/map-with-enum-key")
             .method("POST")

↧ Expand context

             .header("Content-Type", "application/json")
             .body(::aws_smithy_http_server::body::Body::from(
                 ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                     "{\"map\":{\"enumvalue\":\"something\"}}".as_bytes(),
                     ::aws_smithy_protocol_test::MediaType::from("unknown"),
                 )),
             ))
             .unwrap();
         #[allow(unused_mut)]
         let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
         let config = crate::service::RestJsonExtrasConfig::builder().build();
         let service =
             crate::service::RestJsonExtras::builder::<::hyper::body::Body, _, _, _>(config)
                 .map_with_enum_key_op(move |input: crate::input::MapWithEnumKeyOpInput| {
                     let sender = sender.clone();
                     async move {
                         let result = {
                             let expected = crate::input::MapWithEnumKeyOpInput {
                                 map: ::std::option::Option::Some({
                                     let mut ret = ::std::collections::HashMap::new();

@@ -1147,1201 +1208,1265 @@

↥ Expand context

         ));
-1202
+    }
-1203
     /// Upper case error modeled lower case.
     /// Test ID: ServiceLevelErrorServer
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn service_level_error_server_response() {
         let output = crate::error::ExtraError {};
         let output = crate::error::MapWithEnumKeyOpError::ExtraError(output);
         use ::aws_smithy_http_server::response::IntoResponse;
         let http_response = output.into_response();
         ::pretty_assertions::assert_eq!(
             http::StatusCode::from_u16(500).expect("invalid expected HTTP status code"),
             http_response.status()
         );
         let expected_headers = [("X-Amzn-Errortype", "ExtraError")];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
             http_response.headers(),
             expected_headers,

         ));
         let body = ::hyper::body::to_bytes(http_response.into_body())
             .await
             .expect("unable to extract body to bytes");
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_body(
             &body,
             "{}",
             ::aws_smithy_protocol_test::MediaType::from("unknown"),
         ));
-1230
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-1233
+}
-1234
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_STATUSRESPONSE: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`StatusResponseInput`](crate::input::StatusResponseInput) using modelled bindings.
     pub struct StatusResponseInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::StatusResponseInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-1242
+    }
-1243
+}
-1244
 impl std::future::Future for StatusResponseInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::StatusResponseInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-1250
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-1257
+    }
-1258
+}
-1259
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::StatusResponseInput
 where

@@ -1215,1272 +1344,1409 @@

↥ Expand context

-1272
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = StatusResponseInputFuture;
-1275
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_STATUSRESPONSE,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-1283
+            }
             crate::protocol_serde::shape_status_response::de_status_response_http_request(request)
                 .await
                 .map_err(Into::into)
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-1294
+                )
             },
         );
         StatusResponseInputFuture {
             inner: Box::pin(fut),
-1299
+        }
-1300
+    }
-1301
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::StatusResponseOutput
-1307
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_status_response::ser_status_response_http_response(self)
-1310
+        {
             Ok(response) => response,
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-1315
+            }
-1316
+        }
-1317
+    }
-1318
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::StatusResponseError
-1324
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_status_response::ser_status_response_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                 );
                 response
-1332
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-1336
+            }
-1337
+        }
-1338
+    }
-1339
+}
-1340
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod status_response_test {
-1347
     /// Upper case error modeled lower case.
     /// Test ID: ServiceLevelErrorServer
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn service_level_error_server_response() {
         let output = crate::error::ExtraError {};
         let output = crate::error::StatusResponseError::ExtraError(output);
         use ::aws_smithy_http_server::response::IntoResponse;
         let http_response = output.into_response();
         ::pretty_assertions::assert_eq!(
             http::StatusCode::from_u16(500).expect("invalid expected HTTP status code"),
             http_response.status()
         );
         let expected_headers = [("X-Amzn-Errortype", "ExtraError")];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
             http_response.headers(),
             expected_headers,
         ));
         let body = ::hyper::body::to_bytes(http_response.into_body())
             .await
             .expect("unable to extract body to bytes");
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_body(
             &body,
             "{}",
             ::aws_smithy_protocol_test::MediaType::from("unknown"),
         ));
-1374
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-1377
+}
-1378
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_ENUMQUERY: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`EnumQueryInput`](crate::input::EnumQueryInput) using modelled bindings.
     pub struct EnumQueryInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EnumQueryInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-1386
+    }
-1387
+}
-1388
 impl std::future::Future for EnumQueryInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::EnumQueryInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-1394
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-1401
+    }
-1402
+}
-1403
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::EnumQueryInput
 where

@@ -1351,1416 +1448,1518 @@

↥ Expand context

-1416
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = EnumQueryInputFuture;
-1419
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_ENUMQUERY,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-1427
+            }
             crate::protocol_serde::shape_enum_query::de_enum_query_http_request(request)
                 .await
                 .map_err(Into::into)
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-1438
+                )
             },
         );
         EnumQueryInputFuture {
             inner: Box::pin(fut),
-1443
+        }
-1444
+    }
-1445
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::EnumQueryOutput
-1451
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_enum_query::ser_enum_query_http_response(self) {
             Ok(response) => response,
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-1458
+            }
-1459
+        }
-1460
+    }
-1461
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::EnumQueryError
-1467
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_enum_query::ser_enum_query_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                 );
                 response
-1475
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-1479
+            }
-1480
+        }
-1481
+    }
-1482
+}
-1483
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod enum_query_test {
-1490
     /// Test ID: EnumQueryRequest
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn enum_query_request_request() {
         #[allow(unused_mut)]
         let mut http_request = http::Request::builder()
             .uri("/foo/enumvalue")
             .method("GET")

↧ Expand context

             .body(::aws_smithy_http_server::body::Body::empty())
             .unwrap();
         #[allow(unused_mut)]
         let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
         let config = crate::service::RestJsonExtrasConfig::builder().build();
         let service =
             crate::service::RestJsonExtras::builder::<::hyper::body::Body, _, _, _>(config)
                 .enum_query(move |input: crate::input::EnumQueryInput| {
                     let sender = sender.clone();
                     async move {
                         let result = {
                             let expected = crate::input::EnumQueryInput {
                                 r#enum: "enumvalue"
                                     .parse::<crate::model::StringEnum>()
                                     .expect("static value validated to member"),
                             };
                             ::pretty_assertions::assert_eq!(input, expected);
                             let output = crate::output::EnumQueryOutput {};
                             Ok(output)
                         };

@@ -1460,1530 +1521,1594 @@

↥ Expand context

         );
-1531
+    }
-1532
     /// Upper case error modeled lower case.
     /// Test ID: ServiceLevelErrorServer
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn service_level_error_server_response() {
         let output = crate::error::ExtraError {};
         let output = crate::error::EnumQueryError::ExtraError(output);
         use ::aws_smithy_http_server::response::IntoResponse;
         let http_response = output.into_response();
         ::pretty_assertions::assert_eq!(
             http::StatusCode::from_u16(500).expect("invalid expected HTTP status code"),
             http_response.status()
         );
         let expected_headers = [("X-Amzn-Errortype", "ExtraError")];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
             http_response.headers(),
             expected_headers,

         ));
         let body = ::hyper::body::to_bytes(http_response.into_body())
             .await
             .expect("unable to extract body to bytes");
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_body(
             &body,
             "{}",
             ::aws_smithy_protocol_test::MediaType::from("unknown"),
         ));
-1559
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-1562
+}
-1563
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 const CONTENT_TYPE_PRIMITIVEINTHEADER: ::mime::Mime = ::mime::APPLICATION_JSON;
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`PrimitiveIntHeaderInput`](crate::input::PrimitiveIntHeaderInput) using modelled bindings.
     pub struct PrimitiveIntHeaderInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::PrimitiveIntHeaderInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-1571
+    }
-1572
+}
-1573
 impl std::future::Future for PrimitiveIntHeaderInputFuture {

↧ Expand context

     type Output = Result<
         crate::input::PrimitiveIntHeaderInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-1579
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-1586
+    }
-1587
+}
-1588
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::PrimitiveIntHeaderInput
 where

@@ -1530,1603 +1690,1771 @@

↥ Expand context

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

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-1625
+                )
             },
         );
         PrimitiveIntHeaderInputFuture {
             inner: Box::pin(fut),
-1630
+        }
-1631
+    }
-1632
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::PrimitiveIntHeaderOutput
-1638
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_primitive_int_header::ser_primitive_int_header_http_response(self) {
                         Ok(response) => response,
                         Err(e) => {
                             ::tracing::error!(error = %e, "failed to serialize response");
                             ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-1645
+                        }
-1646
+                    }
-1647
+    }
-1648
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::PrimitiveIntHeaderError
-1654
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_primitive_int_header::ser_primitive_int_header_http_error(
             &self,
         ) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                 );
                 response
-1664
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-1668
+            }
-1669
+        }
-1670
+    }
-1671
+}
-1672
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod primitive_int_header_test {
-1679
     /// Test ID: DeserPrimitiveHeader
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn deser_primitive_header_response() {
         let output = crate::output::PrimitiveIntHeaderOutput { field: 123 };
         use ::aws_smithy_http_server::response::IntoResponse;
         let http_response = output.into_response();
         ::pretty_assertions::assert_eq!(
             http::StatusCode::from_u16(200).expect("invalid expected HTTP status code"),
             http_response.status()
         );
         let expected_headers = [("x-field", "123")];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
             http_response.headers(),
             expected_headers,
         ));
-1696
+    }
     /// Test ID: DeserPrimitiveHeaderMissing
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn deser_primitive_header_missing_response() {
         let output = crate::output::PrimitiveIntHeaderOutput { field: 0 };
         use ::aws_smithy_http_server::response::IntoResponse;
         let http_response = output.into_response();
         ::pretty_assertions::assert_eq!(
             http::StatusCode::from_u16(200).expect("invalid expected HTTP status code"),
             http_response.status()
         );
-1708
+    }
-1709
     /// Upper case error modeled lower case.
     /// Test ID: ServiceLevelErrorServer
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn service_level_error_server_response() {
         let output = crate::error::ExtraError {};
         let output = crate::error::PrimitiveIntHeaderError::ExtraError(output);
         use ::aws_smithy_http_server::response::IntoResponse;
         let http_response = output.into_response();
         ::pretty_assertions::assert_eq!(
             http::StatusCode::from_u16(500).expect("invalid expected HTTP status code"),
             http_response.status()
         );
         let expected_headers = [("X-Amzn-Errortype", "ExtraError")];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
             http_response.headers(),
             expected_headers,
         ));
         let body = ::hyper::body::to_bytes(http_response.into_body())
             .await
             .expect("unable to extract body to bytes");
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_body(
             &body,
             "{}",
             ::aws_smithy_protocol_test::MediaType::from("unknown"),
         ));
-1736
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-1739
+}
-1740
 /* ServerHttpBoundProtocolGenerator.kt:266 */
 static CONTENT_TYPE_STRINGPAYLOAD: std::sync::LazyLock<::mime::Mime> =
     std::sync::LazyLock::new(|| {
         "text/plain"
             .parse::<::mime::Mime>()
             .expect("BUG: MIME parsing failed, content_type is not valid")
     });
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`StringPayloadInput`](crate::input::StringPayloadInput) using modelled bindings.
     pub struct StringPayloadInputFuture {

↧ Expand context

         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::StringPayloadInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-1753
+    }
-1754
+}
-1755
 impl std::future::Future for StringPayloadInputFuture {
     type Output = Result<
         crate::input::StringPayloadInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-1761
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-1768
+    }
-1769
+}
-1770
 impl<B>

@@ -1702,1783 +1799,1885 @@

↥ Expand context

-1783
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = StringPayloadInputFuture;
-1786
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &CONTENT_TYPE_STRINGPAYLOAD,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-1794
+            }
             crate::protocol_serde::shape_string_payload::de_string_payload_http_request(request)
                 .await
                 .map_err(Into::into)
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");

                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
-1805
+                )
             },
         );
         StringPayloadInputFuture {
             inner: Box::pin(fut),
-1810
+        }
-1811
+    }
-1812
+}
 /* ServerHttpBoundProtocolGenerator.kt:329 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::StringPayloadOutput
-1818
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_string_payload::ser_string_payload_http_response(self) {
             Ok(response) => response,
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-1825
+            }
-1826
+        }
-1827
+    }
-1828
+}
 /* ServerHttpBoundProtocolGenerator.kt:350 */
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::StringPayloadError
-1834
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_string_payload::ser_string_payload_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                 );
                 response
-1842
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-1846
+            }
-1847
+        }
-1848
+    }
-1849
+}
-1850
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod string_payload_test {
-1857
     /// Test ID: StringPayload
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn string_payload_request() {
         #[allow(unused_mut)]
         let mut http_request = http::Request::builder()
             .uri("/StringPayload")
             .method("POST")

↧ Expand context

             .header("Content-Type", "text/plain")
             .body(::aws_smithy_http_server::body::Body::from(
                 ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                     "rawstring".as_bytes(),
                     ::aws_smithy_protocol_test::MediaType::from("unknown"),
                 )),
             ))
             .unwrap();
         #[allow(unused_mut)]
         let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
         let config = crate::service::RestJsonExtrasConfig::builder().build();
         let service =
             crate::service::RestJsonExtras::builder::<::hyper::body::Body, _, _, _>(config)
                 .string_payload(move |input: crate::input::StringPayloadInput| {
                     let sender = sender.clone();
                     async move {
                         let result = {
                             let expected = crate::input::StringPayloadInput {
                                 payload: ::std::option::Option::Some("rawstring".to_owned()),
                             };

@@ -1817,1903 +1847,1935 @@

↥ Expand context

         );
-1904
+    }
-1905
     /// Upper case error modeled lower case.
     /// Test ID: ServiceLevelErrorServer
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn service_level_error_server_response() {
         let output = crate::error::ExtraError {};
         let output = crate::error::StringPayloadError::ExtraError(output);
         use ::aws_smithy_http_server::response::IntoResponse;
         let http_response = output.into_response();
         ::pretty_assertions::assert_eq!(
             http::StatusCode::from_u16(500).expect("invalid expected HTTP status code"),
             http_response.status()
         );
         let expected_headers = [("X-Amzn-Errortype", "ExtraError")];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
             http_response.headers(),
             expected_headers,

         ));
         let body = ::hyper::body::to_bytes(http_response.into_body())
             .await
             .expect("unable to extract body to bytes");
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_body(
             &body,
             "{}",
             ::aws_smithy_protocol_test::MediaType::from("unknown"),
         ));
-1932
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-1935
+}

tmp-codegen-diff/codegen-server-test/rest_json_extras/rust-server-codegen/src/operation_shape.rs

@@ -1,1 +0,455 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct QueryPrecedence;
-6
 impl ::aws_smithy_http_server::operation::OperationShape for QueryPrecedence {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson#QueryPrecedence",
             "aws.protocoltests.restjson",
             "QueryPrecedence",
         );
-14
     type Input = crate::input::QueryPrecedenceInput;
     type Output = crate::output::QueryPrecedenceOutput;
     type Error = crate::error::QueryPrecedenceError;
-18
+}
-19
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for QueryPrecedence {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-32
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-35
+    }
-36
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-39
+    }
-40
+}
 /* ServerOperationGenerator.kt:88 */
-42
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct EmptyStructWithContentOnWireOp;
-47
 impl ::aws_smithy_http_server::operation::OperationShape for EmptyStructWithContentOnWireOp {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson#EmptyStructWithContentOnWireOp",
             "aws.protocoltests.restjson",
             "EmptyStructWithContentOnWireOp",
         );
-55
     type Input = crate::input::EmptyStructWithContentOnWireOpInput;
     type Output = crate::output::EmptyStructWithContentOnWireOpOutput;
     type Error = crate::error::EmptyStructWithContentOnWireOpError;
-59
+}
-60
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity
     for EmptyStructWithContentOnWireOp
-63
+{
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-75
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-78
+    }
-79
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-82
+    }
-83
+}
 /* ServerOperationGenerator.kt:88 */
-85
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct CaseInsensitiveErrorOperation;
-90
 impl ::aws_smithy_http_server::operation::OperationShape for CaseInsensitiveErrorOperation {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson#CaseInsensitiveErrorOperation",
             "aws.protocoltests.restjson",
             "CaseInsensitiveErrorOperation",
         );
-98
     type Input = crate::input::CaseInsensitiveErrorOperationInput;
     type Output = crate::output::CaseInsensitiveErrorOperationOutput;
     type Error = crate::error::CaseInsensitiveErrorOperationError;
-102
+}
-103
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity
     for CaseInsensitiveErrorOperation
-106
+{
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-118
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-121
+    }
-122
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-125
+    }
-126
+}
 /* ServerOperationGenerator.kt:88 */
-128
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct NullInNonSparse;
-133
 impl ::aws_smithy_http_server::operation::OperationShape for NullInNonSparse {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson#NullInNonSparse",
             "aws.protocoltests.restjson",
             "NullInNonSparse",
         );
-141
     type Input = crate::input::NullInNonSparseInput;
     type Output = crate::output::NullInNonSparseOutput;
     type Error = crate::error::NullInNonSparseError;
-145
+}
-146
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for NullInNonSparse {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-159
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-162
+    }
-163
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-166
+    }
-167
+}
 /* ServerOperationGenerator.kt:88 */
-169
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct EscapedStringValues;
-174
 impl ::aws_smithy_http_server::operation::OperationShape for EscapedStringValues {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson#EscapedStringValues",
             "aws.protocoltests.restjson",
             "EscapedStringValues",
         );
-182
     type Input = crate::input::EscapedStringValuesInput;
     type Output = crate::output::EscapedStringValuesOutput;
     type Error = crate::error::EscapedStringValuesError;
-186
+}
-187
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for EscapedStringValues {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-200
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-203
+    }
-204
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-207
+    }
-208
+}
 /* ServerOperationGenerator.kt:88 */
-210
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct PrimitiveIntOp;
-215
 impl ::aws_smithy_http_server::operation::OperationShape for PrimitiveIntOp {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson#PrimitiveIntOp",
             "aws.protocoltests.restjson",
             "PrimitiveIntOp",
         );
-223
     type Input = crate::input::PrimitiveIntOpInput;
     type Output = crate::output::PrimitiveIntOpOutput;
     type Error = crate::error::PrimitiveIntOpError;
-227
+}
-228
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for PrimitiveIntOp {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-241
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-244
+    }
-245
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-248
+    }
-249
+}
 /* ServerOperationGenerator.kt:88 */
-251
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct MapWithEnumKeyOp;
-256
 impl ::aws_smithy_http_server::operation::OperationShape for MapWithEnumKeyOp {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson#MapWithEnumKeyOp",
             "aws.protocoltests.restjson",
             "MapWithEnumKeyOp",
         );
-264
     type Input = crate::input::MapWithEnumKeyOpInput;
     type Output = crate::output::MapWithEnumKeyOpOutput;
     type Error = crate::error::MapWithEnumKeyOpError;
-268
+}
-269
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for MapWithEnumKeyOp {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-282
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-285
+    }
-286
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-289
+    }
-290
+}
 /* ServerOperationGenerator.kt:88 */
-292
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct StatusResponse;
-297
 impl ::aws_smithy_http_server::operation::OperationShape for StatusResponse {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson#StatusResponse",
             "aws.protocoltests.restjson",
             "StatusResponse",
         );
-305
     type Input = crate::input::StatusResponseInput;
     type Output = crate::output::StatusResponseOutput;
     type Error = crate::error::StatusResponseError;
-309
+}
-310
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for StatusResponse {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-323
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-326
+    }
-327
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-330
+    }
-331
+}
 /* ServerOperationGenerator.kt:88 */
-333
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct EnumQuery;
-338
 impl ::aws_smithy_http_server::operation::OperationShape for EnumQuery {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson#EnumQuery",
             "aws.protocoltests.restjson",
             "EnumQuery",
         );
-346
     type Input = crate::input::EnumQueryInput;
     type Output = crate::output::EnumQueryOutput;
     type Error = crate::error::EnumQueryError;
-350
+}
-351
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for EnumQuery {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-364
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-367
+    }
-368
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-371
+    }
-372
+}
 /* ServerOperationGenerator.kt:88 */
-374
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct PrimitiveIntHeader;
-379
 impl ::aws_smithy_http_server::operation::OperationShape for PrimitiveIntHeader {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson#PrimitiveIntHeader",
             "aws.protocoltests.restjson",
             "PrimitiveIntHeader",
         );
-387
     type Input = crate::input::PrimitiveIntHeaderInput;
     type Output = crate::output::PrimitiveIntHeaderOutput;
     type Error = crate::error::PrimitiveIntHeaderError;
-391
+}
-392
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for PrimitiveIntHeader {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-405
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-408
+    }
-409
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-412
+    }
-413
+}
 /* ServerOperationGenerator.kt:88 */
-415
 /* ServerOperationGenerator.kt:48 */
 #[allow(missing_docs)] // documentation missing in model
                        /* ServerOperationGenerator.kt:55 */
 pub struct StringPayload;
-420
 impl ::aws_smithy_http_server::operation::OperationShape for StringPayload {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
             "aws.protocoltests.restjson#StringPayload",
             "aws.protocoltests.restjson",
             "StringPayload",
         );
-428
     type Input = crate::input::StringPayloadInput;
     type Output = crate::output::StringPayloadOutput;
     type Error = crate::error::StringPayloadError;
-432
+}
-433
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for StringPayload {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     >;
-446
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
-449
+    }
-450
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-453
+    }
-454
+}
 /* ServerOperationGenerator.kt:88 */

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