1 1 | // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
|
2 2 | ::pin_project_lite::pin_project! {
|
3 3 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
4 - | /// [`QueryIncompatibleOperationInput`](crate::input::QueryIncompatibleOperationInput) using modelled bindings.
|
5 - | pub struct QueryIncompatibleOperationInputFuture {
|
6 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryIncompatibleOperationInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
4 + | /// [`NoInputAndNoOutputInput`](crate::input::NoInputAndNoOutputInput) using modelled bindings.
|
5 + | pub struct NoInputAndNoOutputInputFuture {
|
6 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::NoInputAndNoOutputInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
7 7 | }
|
8 8 | }
|
9 9 |
|
10 - | impl std::future::Future for QueryIncompatibleOperationInputFuture {
|
10 + | impl std::future::Future for NoInputAndNoOutputInputFuture {
|
11 11 | type Output = Result<
|
12 - | crate::input::QueryIncompatibleOperationInput,
|
12 + | crate::input::NoInputAndNoOutputInput,
|
13 13 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
14 14 | >;
|
15 15 |
|
16 16 | fn poll(
|
17 17 | self: std::pin::Pin<&mut Self>,
|
18 18 | cx: &mut std::task::Context<'_>,
|
19 19 | ) -> std::task::Poll<Self::Output> {
|
20 20 | let this = self.project();
|
21 21 | this.inner.as_mut().poll(cx)
|
22 22 | }
|
23 23 | }
|
24 24 |
|
25 25 | impl<B>
|
26 26 | ::aws_smithy_legacy_http_server::request::FromRequest<
|
27 27 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
28 28 | B,
|
29 - | > for crate::input::QueryIncompatibleOperationInput
|
29 + | > for crate::input::NoInputAndNoOutputInput
|
30 30 | where
|
31 31 | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
32 32 | B: 'static,
|
33 33 |
|
34 34 | B::Data: Send,
|
35 35 | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
36 36 | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
37 37 | {
|
38 38 | type Rejection =
|
39 39 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
40 - | type Future = QueryIncompatibleOperationInputFuture;
|
40 + | type Future = NoInputAndNoOutputInputFuture;
|
41 41 |
|
42 42 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
43 43 | let fut = async move {
|
44 44 | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
45 45 | request.headers(),
|
46 46 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
|
47 47 | ) {
|
48 48 | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
49 49 | }
|
50 - | crate::protocol_serde::shape_query_incompatible_operation::de_query_incompatible_operation_http_request(request)
|
50 + | crate::protocol_serde::shape_no_input_and_no_output::de_no_input_and_no_output_http_request(request)
|
51 51 | .await
|
52 52 | };
|
53 53 | use ::futures_util::future::TryFutureExt;
|
54 54 | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
55 55 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
56 56 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
57 57 | });
|
58 - | QueryIncompatibleOperationInputFuture {
|
58 + | NoInputAndNoOutputInputFuture {
|
59 59 | inner: Box::pin(fut),
|
60 60 | }
|
61 61 | }
|
62 62 | }
|
63 63 | impl
|
64 64 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
65 65 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
66 - | > for crate::output::QueryIncompatibleOperationOutput
|
66 + | > for crate::output::NoInputAndNoOutputOutput
|
67 67 | {
|
68 68 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
69 - | match crate::protocol_serde::shape_query_incompatible_operation::ser_query_incompatible_operation_http_response(self) {
|
69 + | match crate::protocol_serde::shape_no_input_and_no_output::ser_no_input_and_no_output_http_response(self) {
|
70 70 | Ok(response) => response,
|
71 71 | Err(e) => {
|
72 72 | ::tracing::error!(error = %e, "failed to serialize response");
|
73 73 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
74 74 | }
|
75 75 | }
|
76 76 | }
|
77 77 | }
|
78 78 | impl
|
79 79 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
80 80 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
81 - | > for crate::error::QueryIncompatibleOperationError
|
81 + | > for crate::error::NoInputAndNoOutputError
|
82 82 | {
|
83 83 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
84 - | match crate::protocol_serde::shape_query_incompatible_operation::ser_query_incompatible_operation_http_error(&self) {
|
84 + | match crate::protocol_serde::shape_no_input_and_no_output::ser_no_input_and_no_output_http_error(&self) {
|
85 85 | Ok(mut response) => {
|
86 86 | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
87 87 | response
|
88 88 | },
|
89 89 | Err(e) => {
|
90 90 | ::tracing::error!(error = %e, "failed to serialize response");
|
91 91 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
92 92 | }
|
93 93 | }
|
94 94 | }
|
95 95 | }
|
96 96 |
|
97 97 | ::pin_project_lite::pin_project! {
|
98 98 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
99 - | /// [`OperationWithRequiredMembersWithDefaultsInput`](crate::input::OperationWithRequiredMembersWithDefaultsInput) using modelled bindings.
|
100 - | pub struct OperationWithRequiredMembersWithDefaultsInputFuture {
|
101 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::OperationWithRequiredMembersWithDefaultsInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
99 + | /// [`NoInputAndOutputInput`](crate::input::NoInputAndOutputInput) using modelled bindings.
|
100 + | pub struct NoInputAndOutputInputFuture {
|
101 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::NoInputAndOutputInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
102 102 | }
|
103 103 | }
|
104 104 |
|
105 - | impl std::future::Future for OperationWithRequiredMembersWithDefaultsInputFuture {
|
105 + | impl std::future::Future for NoInputAndOutputInputFuture {
|
106 106 | type Output = Result<
|
107 - | crate::input::OperationWithRequiredMembersWithDefaultsInput,
|
107 + | crate::input::NoInputAndOutputInput,
|
108 108 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
109 109 | >;
|
110 110 |
|
111 111 | fn poll(
|
112 112 | self: std::pin::Pin<&mut Self>,
|
113 113 | cx: &mut std::task::Context<'_>,
|
114 114 | ) -> std::task::Poll<Self::Output> {
|
115 115 | let this = self.project();
|
116 116 | this.inner.as_mut().poll(cx)
|
117 117 | }
|
118 118 | }
|
119 119 |
|
120 120 | impl<B>
|
121 121 | ::aws_smithy_legacy_http_server::request::FromRequest<
|
122 122 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
123 123 | B,
|
124 - | > for crate::input::OperationWithRequiredMembersWithDefaultsInput
|
124 + | > for crate::input::NoInputAndOutputInput
|
125 125 | where
|
126 126 | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
127 127 | B: 'static,
|
128 128 |
|
129 129 | B::Data: Send,
|
130 130 | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
131 131 | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
132 132 | {
|
133 133 | type Rejection =
|
134 134 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
135 - | type Future = OperationWithRequiredMembersWithDefaultsInputFuture;
|
135 + | type Future = NoInputAndOutputInputFuture;
|
136 136 |
|
137 137 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
138 138 | let fut = async move {
|
139 139 | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
140 140 | request.headers(),
|
141 141 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
|
142 142 | ) {
|
143 143 | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
144 144 | }
|
145 - | crate::protocol_serde::shape_operation_with_required_members_with_defaults::de_operation_with_required_members_with_defaults_http_request(request)
|
145 + | crate::protocol_serde::shape_no_input_and_output::de_no_input_and_output_http_request(
|
146 + | request,
|
147 + | )
|
146 148 | .await
|
147 149 | };
|
148 150 | use ::futures_util::future::TryFutureExt;
|
149 151 | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
150 152 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
151 153 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
152 154 | });
|
153 - | OperationWithRequiredMembersWithDefaultsInputFuture {
|
155 + | NoInputAndOutputInputFuture {
|
154 156 | inner: Box::pin(fut),
|
155 157 | }
|
156 158 | }
|
157 159 | }
|
158 160 | impl
|
159 161 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
160 162 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
161 - | > for crate::output::OperationWithRequiredMembersWithDefaultsOutput
|
163 + | > for crate::output::NoInputAndOutputOutput
|
162 164 | {
|
163 165 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
164 - | match crate::protocol_serde::shape_operation_with_required_members_with_defaults::ser_operation_with_required_members_with_defaults_http_response(self) {
|
166 + | match crate::protocol_serde::shape_no_input_and_output::ser_no_input_and_output_http_response(self) {
|
165 167 | Ok(response) => response,
|
166 168 | Err(e) => {
|
167 169 | ::tracing::error!(error = %e, "failed to serialize response");
|
168 170 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
169 171 | }
|
170 172 | }
|
171 173 | }
|
172 174 | }
|
173 175 | impl
|
174 176 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
175 177 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
176 - | > for crate::error::OperationWithRequiredMembersWithDefaultsError
|
178 + | > for crate::error::NoInputAndOutputError
|
177 179 | {
|
178 180 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
179 - | match crate::protocol_serde::shape_operation_with_required_members_with_defaults::ser_operation_with_required_members_with_defaults_http_error(&self) {
|
181 + | match crate::protocol_serde::shape_no_input_and_output::ser_no_input_and_output_http_error(
|
182 + | &self,
|
183 + | ) {
|
180 184 | Ok(mut response) => {
|
181 - | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
185 + | response.extensions_mut().insert(
|
186 + | ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
|
187 + | self.name(),
|
188 + | ),
|
189 + | );
|
182 190 | response
|
183 - | },
|
191 + | }
|
184 192 | Err(e) => {
|
185 193 | ::tracing::error!(error = %e, "failed to serialize response");
|
186 194 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
187 195 | }
|
188 196 | }
|
189 197 | }
|
190 198 | }
|
191 199 |
|
192 200 | ::pin_project_lite::pin_project! {
|
193 201 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
194 - | /// [`OperationWithNestedStructureInput`](crate::input::OperationWithNestedStructureInput) using modelled bindings.
|
195 - | pub struct OperationWithNestedStructureInputFuture {
|
196 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::OperationWithNestedStructureInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
202 + | /// [`EmptyInputAndEmptyOutputInput`](crate::input::EmptyInputAndEmptyOutputInput) using modelled bindings.
|
203 + | pub struct EmptyInputAndEmptyOutputInputFuture {
|
204 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EmptyInputAndEmptyOutputInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
197 205 | }
|
198 206 | }
|
199 207 |
|
200 - | impl std::future::Future for OperationWithNestedStructureInputFuture {
|
208 + | impl std::future::Future for EmptyInputAndEmptyOutputInputFuture {
|
201 209 | type Output = Result<
|
202 - | crate::input::OperationWithNestedStructureInput,
|
210 + | crate::input::EmptyInputAndEmptyOutputInput,
|
203 211 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
204 212 | >;
|
205 213 |
|
206 214 | fn poll(
|
207 215 | self: std::pin::Pin<&mut Self>,
|
208 216 | cx: &mut std::task::Context<'_>,
|
209 217 | ) -> std::task::Poll<Self::Output> {
|
210 218 | let this = self.project();
|
211 219 | this.inner.as_mut().poll(cx)
|
212 220 | }
|
213 221 | }
|
214 222 |
|
215 223 | impl<B>
|
216 224 | ::aws_smithy_legacy_http_server::request::FromRequest<
|
217 225 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
218 226 | B,
|
219 - | > for crate::input::OperationWithNestedStructureInput
|
227 + | > for crate::input::EmptyInputAndEmptyOutputInput
|
220 228 | where
|
221 229 | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
222 230 | B: 'static,
|
223 231 |
|
224 232 | B::Data: Send,
|
225 233 | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
226 234 | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
227 235 | {
|
228 236 | type Rejection =
|
229 237 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
230 - | type Future = OperationWithNestedStructureInputFuture;
|
238 + | type Future = EmptyInputAndEmptyOutputInputFuture;
|
231 239 |
|
232 240 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
233 241 | let fut = async move {
|
234 242 | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
235 243 | request.headers(),
|
236 244 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
|
237 245 | ) {
|
238 246 | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
239 247 | }
|
240 - | crate::protocol_serde::shape_operation_with_nested_structure::de_operation_with_nested_structure_http_request(request)
|
248 + | crate::protocol_serde::shape_empty_input_and_empty_output::de_empty_input_and_empty_output_http_request(request)
|
241 249 | .await
|
242 250 | };
|
243 251 | use ::futures_util::future::TryFutureExt;
|
244 252 | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
245 253 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
246 254 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
247 255 | });
|
248 - | OperationWithNestedStructureInputFuture {
|
256 + | EmptyInputAndEmptyOutputInputFuture {
|
249 257 | inner: Box::pin(fut),
|
250 258 | }
|
251 259 | }
|
252 260 | }
|
253 261 | impl
|
254 262 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
255 263 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
256 - | > for crate::output::OperationWithNestedStructureOutput
|
264 + | > for crate::output::EmptyInputAndEmptyOutputOutput
|
257 265 | {
|
258 266 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
259 - | match crate::protocol_serde::shape_operation_with_nested_structure::ser_operation_with_nested_structure_http_response(self) {
|
267 + | match crate::protocol_serde::shape_empty_input_and_empty_output::ser_empty_input_and_empty_output_http_response(self) {
|
260 268 | Ok(response) => response,
|
261 269 | Err(e) => {
|
262 270 | ::tracing::error!(error = %e, "failed to serialize response");
|
263 271 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
264 272 | }
|
265 273 | }
|
266 274 | }
|
267 275 | }
|
268 276 | impl
|
269 277 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
270 278 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
271 - | > for crate::error::OperationWithNestedStructureError
|
279 + | > for crate::error::EmptyInputAndEmptyOutputError
|
272 280 | {
|
273 281 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
274 - | match crate::protocol_serde::shape_operation_with_nested_structure::ser_operation_with_nested_structure_http_error(&self) {
|
282 + | match crate::protocol_serde::shape_empty_input_and_empty_output::ser_empty_input_and_empty_output_http_error(&self) {
|
275 283 | Ok(mut response) => {
|
276 284 | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
277 285 | response
|
278 286 | },
|
279 287 | Err(e) => {
|
280 288 | ::tracing::error!(error = %e, "failed to serialize response");
|
281 289 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
282 290 | }
|
283 291 | }
|
284 292 | }
|
285 293 | }
|
286 294 |
|
287 295 | ::pin_project_lite::pin_project! {
|
288 296 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
289 - | /// [`OperationWithRequiredMembersInput`](crate::input::OperationWithRequiredMembersInput) using modelled bindings.
|
290 - | pub struct OperationWithRequiredMembersInputFuture {
|
291 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::OperationWithRequiredMembersInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
297 + | /// [`SimpleScalarPropertiesInput`](crate::input::SimpleScalarPropertiesInput) using modelled bindings.
|
298 + | pub struct SimpleScalarPropertiesInputFuture {
|
299 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::SimpleScalarPropertiesInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
292 300 | }
|
293 301 | }
|
294 302 |
|
295 - | impl std::future::Future for OperationWithRequiredMembersInputFuture {
|
303 + | impl std::future::Future for SimpleScalarPropertiesInputFuture {
|
296 304 | type Output = Result<
|
297 - | crate::input::OperationWithRequiredMembersInput,
|
305 + | crate::input::SimpleScalarPropertiesInput,
|
298 306 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
299 307 | >;
|
300 308 |
|
301 309 | fn poll(
|
302 310 | self: std::pin::Pin<&mut Self>,
|
303 311 | cx: &mut std::task::Context<'_>,
|
304 312 | ) -> std::task::Poll<Self::Output> {
|
305 313 | let this = self.project();
|
306 314 | this.inner.as_mut().poll(cx)
|
307 315 | }
|
308 316 | }
|
309 317 |
|
310 318 | impl<B>
|
311 319 | ::aws_smithy_legacy_http_server::request::FromRequest<
|
312 320 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
313 321 | B,
|
314 - | > for crate::input::OperationWithRequiredMembersInput
|
322 + | > for crate::input::SimpleScalarPropertiesInput
|
315 323 | where
|
316 324 | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
317 325 | B: 'static,
|
318 326 |
|
319 327 | B::Data: Send,
|
320 328 | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
321 329 | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
322 330 | {
|
323 331 | type Rejection =
|
324 332 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
325 - | type Future = OperationWithRequiredMembersInputFuture;
|
333 + | type Future = SimpleScalarPropertiesInputFuture;
|
326 334 |
|
327 335 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
328 336 | let fut = async move {
|
329 337 | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
330 338 | request.headers(),
|
331 339 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
|
332 340 | ) {
|
333 341 | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
334 342 | }
|
335 - | crate::protocol_serde::shape_operation_with_required_members::de_operation_with_required_members_http_request(request)
|
343 + | crate::protocol_serde::shape_simple_scalar_properties::de_simple_scalar_properties_http_request(request)
|
336 344 | .await
|
337 345 | };
|
338 346 | use ::futures_util::future::TryFutureExt;
|
339 347 | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
340 348 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
341 349 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
342 350 | });
|
343 - | OperationWithRequiredMembersInputFuture {
|
351 + | SimpleScalarPropertiesInputFuture {
|
344 352 | inner: Box::pin(fut),
|
345 353 | }
|
346 354 | }
|
347 355 | }
|
348 356 | impl
|
349 357 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
350 358 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
351 - | > for crate::output::OperationWithRequiredMembersOutput
|
359 + | > for crate::output::SimpleScalarPropertiesOutput
|
352 360 | {
|
353 361 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
354 - | match crate::protocol_serde::shape_operation_with_required_members::ser_operation_with_required_members_http_response(self) {
|
362 + | match crate::protocol_serde::shape_simple_scalar_properties::ser_simple_scalar_properties_http_response(self) {
|
355 363 | Ok(response) => response,
|
356 364 | Err(e) => {
|
357 365 | ::tracing::error!(error = %e, "failed to serialize response");
|
358 366 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
359 367 | }
|
360 368 | }
|
361 369 | }
|
362 370 | }
|
363 371 | impl
|
364 372 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
365 373 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
366 - | > for crate::error::OperationWithRequiredMembersError
|
374 + | > for crate::error::SimpleScalarPropertiesError
|
367 375 | {
|
368 376 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
369 - | match crate::protocol_serde::shape_operation_with_required_members::ser_operation_with_required_members_http_error(&self) {
|
377 + | match crate::protocol_serde::shape_simple_scalar_properties::ser_simple_scalar_properties_http_error(&self) {
|
370 378 | Ok(mut response) => {
|
371 379 | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
372 380 | response
|
373 381 | },
|
374 382 | Err(e) => {
|
375 383 | ::tracing::error!(error = %e, "failed to serialize response");
|
376 384 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
377 385 | }
|
378 386 | }
|
379 387 | }
|
380 388 | }
|
381 389 |
|
382 390 | ::pin_project_lite::pin_project! {
|
383 391 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
384 - | /// [`OperationWithDefaultsInput`](crate::input::OperationWithDefaultsInput) using modelled bindings.
|
385 - | pub struct OperationWithDefaultsInputFuture {
|
386 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::OperationWithDefaultsInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
392 + | /// [`GreetingWithErrorsInput`](crate::input::GreetingWithErrorsInput) using modelled bindings.
|
393 + | pub struct GreetingWithErrorsInputFuture {
|
394 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::GreetingWithErrorsInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
387 395 | }
|
388 396 | }
|
389 397 |
|
390 - | impl std::future::Future for OperationWithDefaultsInputFuture {
|
398 + | impl std::future::Future for GreetingWithErrorsInputFuture {
|
391 399 | type Output = Result<
|
392 - | crate::input::OperationWithDefaultsInput,
|
400 + | crate::input::GreetingWithErrorsInput,
|
393 401 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
394 402 | >;
|
395 403 |
|
396 404 | fn poll(
|
397 405 | self: std::pin::Pin<&mut Self>,
|
398 406 | cx: &mut std::task::Context<'_>,
|
399 407 | ) -> std::task::Poll<Self::Output> {
|
400 408 | let this = self.project();
|
401 409 | this.inner.as_mut().poll(cx)
|
402 410 | }
|
403 411 | }
|
404 412 |
|
405 413 | impl<B>
|
406 414 | ::aws_smithy_legacy_http_server::request::FromRequest<
|
407 415 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
408 416 | B,
|
409 - | > for crate::input::OperationWithDefaultsInput
|
417 + | > for crate::input::GreetingWithErrorsInput
|
410 418 | where
|
411 419 | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
412 420 | B: 'static,
|
413 421 |
|
414 422 | B::Data: Send,
|
415 423 | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
416 424 | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
417 425 | {
|
418 426 | type Rejection =
|
419 427 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
420 - | type Future = OperationWithDefaultsInputFuture;
|
428 + | type Future = GreetingWithErrorsInputFuture;
|
421 429 |
|
422 430 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
423 431 | let fut = async move {
|
424 432 | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
425 433 | request.headers(),
|
426 434 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
|
427 435 | ) {
|
428 436 | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
429 437 | }
|
430 - | crate::protocol_serde::shape_operation_with_defaults::de_operation_with_defaults_http_request(request)
|
438 + | crate::protocol_serde::shape_greeting_with_errors::de_greeting_with_errors_http_request(
|
439 + | request,
|
440 + | )
|
431 441 | .await
|
432 442 | };
|
433 443 | use ::futures_util::future::TryFutureExt;
|
434 444 | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
435 445 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
436 446 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
437 447 | });
|
438 - | OperationWithDefaultsInputFuture {
|
448 + | GreetingWithErrorsInputFuture {
|
439 449 | inner: Box::pin(fut),
|
440 450 | }
|
441 451 | }
|
442 452 | }
|
443 453 | impl
|
444 454 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
445 455 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
446 - | > for crate::output::OperationWithDefaultsOutput
|
456 + | > for crate::output::GreetingWithErrorsOutput
|
447 457 | {
|
448 458 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
449 - | match crate::protocol_serde::shape_operation_with_defaults::ser_operation_with_defaults_http_response(self) {
|
459 + | match crate::protocol_serde::shape_greeting_with_errors::ser_greeting_with_errors_http_response(self) {
|
450 460 | Ok(response) => response,
|
451 461 | Err(e) => {
|
452 462 | ::tracing::error!(error = %e, "failed to serialize response");
|
453 463 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
454 464 | }
|
455 465 | }
|
456 466 | }
|
457 467 | }
|
458 468 | impl
|
459 469 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
460 470 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
461 - | > for crate::error::OperationWithDefaultsError
|
471 + | > for crate::error::GreetingWithErrorsError
|
462 472 | {
|
463 473 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
464 - | match crate::protocol_serde::shape_operation_with_defaults::ser_operation_with_defaults_http_error(&self) {
|
474 + | match crate::protocol_serde::shape_greeting_with_errors::ser_greeting_with_errors_http_error(
|
475 + | &self,
|
476 + | ) {
|
465 477 | Ok(mut response) => {
|
466 - | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
478 + | response.extensions_mut().insert(
|
479 + | ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
|
480 + | self.name(),
|
481 + | ),
|
482 + | );
|
467 483 | response
|
468 - | },
|
484 + | }
|
469 485 | Err(e) => {
|
470 486 | ::tracing::error!(error = %e, "failed to serialize response");
|
471 487 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
472 488 | }
|
473 489 | }
|
474 490 | }
|
475 491 | }
|
476 492 |
|
477 493 | ::pin_project_lite::pin_project! {
|
478 494 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
479 - | /// [`ContentTypeParametersInput`](crate::input::ContentTypeParametersInput) using modelled bindings.
|
480 - | pub struct ContentTypeParametersInputFuture {
|
481 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ContentTypeParametersInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
495 + | /// [`JsonUnionsInput`](crate::input::JsonUnionsInput) using modelled bindings.
|
496 + | pub struct JsonUnionsInputFuture {
|
497 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::JsonUnionsInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
482 498 | }
|
483 499 | }
|
484 500 |
|
485 - | impl std::future::Future for ContentTypeParametersInputFuture {
|
501 + | impl std::future::Future for JsonUnionsInputFuture {
|
486 502 | type Output = Result<
|
487 - | crate::input::ContentTypeParametersInput,
|
503 + | crate::input::JsonUnionsInput,
|
488 504 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
489 505 | >;
|
490 506 |
|
491 507 | fn poll(
|
492 508 | self: std::pin::Pin<&mut Self>,
|
493 509 | cx: &mut std::task::Context<'_>,
|
494 510 | ) -> std::task::Poll<Self::Output> {
|
495 511 | let this = self.project();
|
496 512 | this.inner.as_mut().poll(cx)
|
497 513 | }
|
498 514 | }
|
499 515 |
|
500 516 | impl<B>
|
501 517 | ::aws_smithy_legacy_http_server::request::FromRequest<
|
502 518 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
503 519 | B,
|
504 - | > for crate::input::ContentTypeParametersInput
|
520 + | > for crate::input::JsonUnionsInput
|
505 521 | where
|
506 522 | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
507 523 | B: 'static,
|
508 524 |
|
509 525 | B::Data: Send,
|
510 526 | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
511 527 | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
512 528 | {
|
513 529 | type Rejection =
|
514 530 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
515 - | type Future = ContentTypeParametersInputFuture;
|
531 + | type Future = JsonUnionsInputFuture;
|
516 532 |
|
517 533 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
518 534 | let fut = async move {
|
519 535 | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
520 536 | request.headers(),
|
521 537 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
|
522 538 | ) {
|
523 539 | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
524 540 | }
|
525 - | crate::protocol_serde::shape_content_type_parameters::de_content_type_parameters_http_request(request)
|
526 - | .await
|
541 + | crate::protocol_serde::shape_json_unions::de_json_unions_http_request(request).await
|
527 542 | };
|
528 543 | use ::futures_util::future::TryFutureExt;
|
529 544 | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
530 545 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
531 546 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
532 547 | });
|
533 - | ContentTypeParametersInputFuture {
|
548 + | JsonUnionsInputFuture {
|
534 549 | inner: Box::pin(fut),
|
535 550 | }
|
536 551 | }
|
537 552 | }
|
538 553 | impl
|
539 554 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
540 555 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
541 - | > for crate::output::ContentTypeParametersOutput
|
556 + | > for crate::output::JsonUnionsOutput
|
542 557 | {
|
543 558 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
544 - | match crate::protocol_serde::shape_content_type_parameters::ser_content_type_parameters_http_response(self) {
|
559 + | match crate::protocol_serde::shape_json_unions::ser_json_unions_http_response(self) {
|
545 560 | Ok(response) => response,
|
546 561 | Err(e) => {
|
547 562 | ::tracing::error!(error = %e, "failed to serialize response");
|
548 563 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
549 564 | }
|
550 565 | }
|
551 566 | }
|
552 567 | }
|
553 568 | impl
|
554 569 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
555 570 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
556 - | > for crate::error::ContentTypeParametersError
|
571 + | > for crate::error::JsonUnionsError
|
557 572 | {
|
558 573 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
559 - | match crate::protocol_serde::shape_content_type_parameters::ser_content_type_parameters_http_error(&self) {
|
574 + | match crate::protocol_serde::shape_json_unions::ser_json_unions_http_error(&self) {
|
560 575 | Ok(mut response) => {
|
561 - | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
576 + | response.extensions_mut().insert(
|
577 + | ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
|
578 + | self.name(),
|
579 + | ),
|
580 + | );
|
562 581 | response
|
563 - | },
|
582 + | }
|
564 583 | Err(e) => {
|
565 584 | ::tracing::error!(error = %e, "failed to serialize response");
|
566 585 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
567 586 | }
|
568 587 | }
|
569 588 | }
|
570 589 | }
|
571 590 |
|
572 591 | ::pin_project_lite::pin_project! {
|
573 592 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
574 - | /// [`PutWithContentEncodingInput`](crate::input::PutWithContentEncodingInput) using modelled bindings.
|
575 - | pub struct PutWithContentEncodingInputFuture {
|
576 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::PutWithContentEncodingInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
593 + | /// [`EndpointOperationInput`](crate::input::EndpointOperationInput) using modelled bindings.
|
594 + | pub struct EndpointOperationInputFuture {
|
595 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EndpointOperationInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
577 596 | }
|
578 597 | }
|
579 598 |
|
580 - | impl std::future::Future for PutWithContentEncodingInputFuture {
|
599 + | impl std::future::Future for EndpointOperationInputFuture {
|
581 600 | type Output = Result<
|
582 - | crate::input::PutWithContentEncodingInput,
|
601 + | crate::input::EndpointOperationInput,
|
583 602 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
584 603 | >;
|
585 604 |
|
586 605 | fn poll(
|
587 606 | self: std::pin::Pin<&mut Self>,
|
588 607 | cx: &mut std::task::Context<'_>,
|
589 608 | ) -> std::task::Poll<Self::Output> {
|
590 609 | let this = self.project();
|
591 610 | this.inner.as_mut().poll(cx)
|
592 611 | }
|
593 612 | }
|
594 613 |
|
595 614 | impl<B>
|
596 615 | ::aws_smithy_legacy_http_server::request::FromRequest<
|
597 616 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
598 617 | B,
|
599 - | > for crate::input::PutWithContentEncodingInput
|
618 + | > for crate::input::EndpointOperationInput
|
600 619 | where
|
601 620 | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
602 621 | B: 'static,
|
603 622 |
|
604 623 | B::Data: Send,
|
605 624 | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
606 625 | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
607 626 | {
|
608 627 | type Rejection =
|
609 628 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
610 - | type Future = PutWithContentEncodingInputFuture;
|
629 + | type Future = EndpointOperationInputFuture;
|
611 630 |
|
612 631 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
613 632 | let fut = async move {
|
614 633 | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
615 634 | request.headers(),
|
616 635 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
|
617 636 | ) {
|
618 637 | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
619 638 | }
|
620 - | crate::protocol_serde::shape_put_with_content_encoding::de_put_with_content_encoding_http_request(request)
|
639 + | crate::protocol_serde::shape_endpoint_operation::de_endpoint_operation_http_request(
|
640 + | request,
|
641 + | )
|
621 642 | .await
|
622 643 | };
|
623 644 | use ::futures_util::future::TryFutureExt;
|
624 645 | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
625 646 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
626 647 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
627 648 | });
|
628 - | PutWithContentEncodingInputFuture {
|
649 + | EndpointOperationInputFuture {
|
629 650 | inner: Box::pin(fut),
|
630 651 | }
|
631 652 | }
|
632 653 | }
|
633 654 | impl
|
634 655 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
635 656 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
636 - | > for crate::output::PutWithContentEncodingOutput
|
657 + | > for crate::output::EndpointOperationOutput
|
637 658 | {
|
638 659 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
639 - | match crate::protocol_serde::shape_put_with_content_encoding::ser_put_with_content_encoding_http_response(self) {
|
660 + | match crate::protocol_serde::shape_endpoint_operation::ser_endpoint_operation_http_response(
|
661 + | self,
|
662 + | ) {
|
640 663 | Ok(response) => response,
|
641 664 | Err(e) => {
|
642 665 | ::tracing::error!(error = %e, "failed to serialize response");
|
643 666 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
644 667 | }
|
645 668 | }
|
646 669 | }
|
647 670 | }
|
648 671 | impl
|
649 672 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
650 673 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
651 - | > for crate::error::PutWithContentEncodingError
|
674 + | > for crate::error::EndpointOperationError
|
652 675 | {
|
653 676 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
654 - | match crate::protocol_serde::shape_put_with_content_encoding::ser_put_with_content_encoding_http_error(&self) {
|
677 + | match crate::protocol_serde::shape_endpoint_operation::ser_endpoint_operation_http_error(
|
678 + | &self,
|
679 + | ) {
|
655 680 | Ok(mut response) => {
|
656 - | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
681 + | response.extensions_mut().insert(
|
682 + | ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
|
683 + | self.name(),
|
684 + | ),
|
685 + | );
|
657 686 | response
|
658 - | },
|
687 + | }
|
659 688 | Err(e) => {
|
660 689 | ::tracing::error!(error = %e, "failed to serialize response");
|
661 690 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
662 691 | }
|
663 692 | }
|
664 693 | }
|
665 694 | }
|
666 695 |
|
667 696 | ::pin_project_lite::pin_project! {
|
668 697 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
669 - | /// [`HostWithPathOperationInput`](crate::input::HostWithPathOperationInput) using modelled bindings.
|
670 - | pub struct HostWithPathOperationInputFuture {
|
671 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::HostWithPathOperationInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
698 + | /// [`EndpointWithHostLabelOperationInput`](crate::input::EndpointWithHostLabelOperationInput) using modelled bindings.
|
699 + | pub struct EndpointWithHostLabelOperationInputFuture {
|
700 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EndpointWithHostLabelOperationInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
672 701 | }
|
673 702 | }
|
674 703 |
|
675 - | impl std::future::Future for HostWithPathOperationInputFuture {
|
704 + | impl std::future::Future for EndpointWithHostLabelOperationInputFuture {
|
676 705 | type Output = Result<
|
677 - | crate::input::HostWithPathOperationInput,
|
706 + | crate::input::EndpointWithHostLabelOperationInput,
|
678 707 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
679 708 | >;
|
680 709 |
|
681 710 | fn poll(
|
682 711 | self: std::pin::Pin<&mut Self>,
|
683 712 | cx: &mut std::task::Context<'_>,
|
684 713 | ) -> std::task::Poll<Self::Output> {
|
685 714 | let this = self.project();
|
686 715 | this.inner.as_mut().poll(cx)
|
687 716 | }
|
688 717 | }
|
689 718 |
|
690 719 | impl<B>
|
691 720 | ::aws_smithy_legacy_http_server::request::FromRequest<
|
692 721 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
693 722 | B,
|
694 - | > for crate::input::HostWithPathOperationInput
|
723 + | > for crate::input::EndpointWithHostLabelOperationInput
|
695 724 | where
|
696 725 | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
697 726 | B: 'static,
|
698 727 |
|
699 728 | B::Data: Send,
|
700 729 | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
701 730 | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
702 731 | {
|
703 732 | type Rejection =
|
704 733 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
705 - | type Future = HostWithPathOperationInputFuture;
|
734 + | type Future = EndpointWithHostLabelOperationInputFuture;
|
706 735 |
|
707 736 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
708 737 | let fut = async move {
|
709 738 | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
710 739 | request.headers(),
|
711 740 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
|
712 741 | ) {
|
713 742 | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
714 743 | }
|
715 - | crate::protocol_serde::shape_host_with_path_operation::de_host_with_path_operation_http_request(request)
|
744 + | crate::protocol_serde::shape_endpoint_with_host_label_operation::de_endpoint_with_host_label_operation_http_request(request)
|
716 745 | .await
|
717 746 | };
|
718 747 | use ::futures_util::future::TryFutureExt;
|
719 748 | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
720 749 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
721 750 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
722 751 | });
|
723 - | HostWithPathOperationInputFuture {
|
752 + | EndpointWithHostLabelOperationInputFuture {
|
724 753 | inner: Box::pin(fut),
|
725 754 | }
|
726 755 | }
|
727 756 | }
|
728 757 | impl
|
729 758 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
730 759 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
731 - | > for crate::output::HostWithPathOperationOutput
|
760 + | > for crate::output::EndpointWithHostLabelOperationOutput
|
732 761 | {
|
733 762 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
734 - | match crate::protocol_serde::shape_host_with_path_operation::ser_host_with_path_operation_http_response(self) {
|
763 + | match crate::protocol_serde::shape_endpoint_with_host_label_operation::ser_endpoint_with_host_label_operation_http_response(self) {
|
735 764 | Ok(response) => response,
|
736 765 | Err(e) => {
|
737 766 | ::tracing::error!(error = %e, "failed to serialize response");
|
738 767 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
739 768 | }
|
740 769 | }
|
741 770 | }
|
742 771 | }
|
743 772 | impl
|
744 773 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
745 774 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
746 - | > for crate::error::HostWithPathOperationError
|
775 + | > for crate::error::EndpointWithHostLabelOperationError
|
747 776 | {
|
748 777 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
749 - | match crate::protocol_serde::shape_host_with_path_operation::ser_host_with_path_operation_http_error(&self) {
|
778 + | match crate::protocol_serde::shape_endpoint_with_host_label_operation::ser_endpoint_with_host_label_operation_http_error(&self) {
|
750 779 | Ok(mut response) => {
|
751 780 | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
752 781 | response
|
753 782 | },
|
754 783 | Err(e) => {
|
755 784 | ::tracing::error!(error = %e, "failed to serialize response");
|
756 785 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
757 786 | }
|
758 787 | }
|
759 788 | }
|
760 789 | }
|
761 790 |
|
762 791 | ::pin_project_lite::pin_project! {
|
763 792 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
764 - | /// [`EndpointWithHostLabelOperationInput`](crate::input::EndpointWithHostLabelOperationInput) using modelled bindings.
|
765 - | pub struct EndpointWithHostLabelOperationInputFuture {
|
766 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EndpointWithHostLabelOperationInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
793 + | /// [`HostWithPathOperationInput`](crate::input::HostWithPathOperationInput) using modelled bindings.
|
794 + | pub struct HostWithPathOperationInputFuture {
|
795 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::HostWithPathOperationInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
767 796 | }
|
768 797 | }
|
769 798 |
|
770 - | impl std::future::Future for EndpointWithHostLabelOperationInputFuture {
|
799 + | impl std::future::Future for HostWithPathOperationInputFuture {
|
771 800 | type Output = Result<
|
772 - | crate::input::EndpointWithHostLabelOperationInput,
|
801 + | crate::input::HostWithPathOperationInput,
|
773 802 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
774 803 | >;
|
775 804 |
|
776 805 | fn poll(
|
777 806 | self: std::pin::Pin<&mut Self>,
|
778 807 | cx: &mut std::task::Context<'_>,
|
779 808 | ) -> std::task::Poll<Self::Output> {
|
780 809 | let this = self.project();
|
781 810 | this.inner.as_mut().poll(cx)
|
782 811 | }
|
783 812 | }
|
784 813 |
|
785 814 | impl<B>
|
786 815 | ::aws_smithy_legacy_http_server::request::FromRequest<
|
787 816 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
788 817 | B,
|
789 - | > for crate::input::EndpointWithHostLabelOperationInput
|
818 + | > for crate::input::HostWithPathOperationInput
|
790 819 | where
|
791 820 | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
792 821 | B: 'static,
|
793 822 |
|
794 823 | B::Data: Send,
|
795 824 | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
796 825 | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
797 826 | {
|
798 827 | type Rejection =
|
799 828 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
800 - | type Future = EndpointWithHostLabelOperationInputFuture;
|
829 + | type Future = HostWithPathOperationInputFuture;
|
801 830 |
|
802 831 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
803 832 | let fut = async move {
|
804 833 | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
805 834 | request.headers(),
|
806 835 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
|
807 836 | ) {
|
808 837 | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
809 838 | }
|
810 - | crate::protocol_serde::shape_endpoint_with_host_label_operation::de_endpoint_with_host_label_operation_http_request(request)
|
839 + | crate::protocol_serde::shape_host_with_path_operation::de_host_with_path_operation_http_request(request)
|
811 840 | .await
|
812 841 | };
|
813 842 | use ::futures_util::future::TryFutureExt;
|
814 843 | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
815 844 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
816 845 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
817 846 | });
|
818 - | EndpointWithHostLabelOperationInputFuture {
|
847 + | HostWithPathOperationInputFuture {
|
819 848 | inner: Box::pin(fut),
|
820 849 | }
|
821 850 | }
|
822 851 | }
|
823 852 | impl
|
824 853 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
825 854 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
826 - | > for crate::output::EndpointWithHostLabelOperationOutput
|
855 + | > for crate::output::HostWithPathOperationOutput
|
827 856 | {
|
828 857 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
829 - | match crate::protocol_serde::shape_endpoint_with_host_label_operation::ser_endpoint_with_host_label_operation_http_response(self) {
|
858 + | match crate::protocol_serde::shape_host_with_path_operation::ser_host_with_path_operation_http_response(self) {
|
830 859 | Ok(response) => response,
|
831 860 | Err(e) => {
|
832 861 | ::tracing::error!(error = %e, "failed to serialize response");
|
833 862 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
834 863 | }
|
835 864 | }
|
836 865 | }
|
837 866 | }
|
838 867 | impl
|
839 868 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
840 869 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
841 - | > for crate::error::EndpointWithHostLabelOperationError
|
870 + | > for crate::error::HostWithPathOperationError
|
842 871 | {
|
843 872 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
844 - | match crate::protocol_serde::shape_endpoint_with_host_label_operation::ser_endpoint_with_host_label_operation_http_error(&self) {
|
873 + | match crate::protocol_serde::shape_host_with_path_operation::ser_host_with_path_operation_http_error(&self) {
|
845 874 | Ok(mut response) => {
|
846 875 | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
847 876 | response
|
848 877 | },
|
849 878 | Err(e) => {
|
850 879 | ::tracing::error!(error = %e, "failed to serialize response");
|
851 880 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
852 881 | }
|
853 882 | }
|
854 883 | }
|
855 884 | }
|
856 885 |
|
857 886 | ::pin_project_lite::pin_project! {
|
858 887 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
859 - | /// [`EndpointOperationInput`](crate::input::EndpointOperationInput) using modelled bindings.
|
860 - | pub struct EndpointOperationInputFuture {
|
861 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EndpointOperationInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
888 + | /// [`PutWithContentEncodingInput`](crate::input::PutWithContentEncodingInput) using modelled bindings.
|
889 + | pub struct PutWithContentEncodingInputFuture {
|
890 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::PutWithContentEncodingInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
862 891 | }
|
863 892 | }
|
864 893 |
|
865 - | impl std::future::Future for EndpointOperationInputFuture {
|
894 + | impl std::future::Future for PutWithContentEncodingInputFuture {
|
866 895 | type Output = Result<
|
867 - | crate::input::EndpointOperationInput,
|
896 + | crate::input::PutWithContentEncodingInput,
|
868 897 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
869 898 | >;
|
870 899 |
|
871 900 | fn poll(
|
872 901 | self: std::pin::Pin<&mut Self>,
|
873 902 | cx: &mut std::task::Context<'_>,
|
874 903 | ) -> std::task::Poll<Self::Output> {
|
875 904 | let this = self.project();
|
876 905 | this.inner.as_mut().poll(cx)
|
877 906 | }
|
878 907 | }
|
879 908 |
|
880 909 | impl<B>
|
881 910 | ::aws_smithy_legacy_http_server::request::FromRequest<
|
882 911 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
883 912 | B,
|
884 - | > for crate::input::EndpointOperationInput
|
913 + | > for crate::input::PutWithContentEncodingInput
|
885 914 | where
|
886 915 | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
887 916 | B: 'static,
|
888 917 |
|
889 918 | B::Data: Send,
|
890 919 | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
891 920 | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
892 921 | {
|
893 922 | type Rejection =
|
894 923 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
895 - | type Future = EndpointOperationInputFuture;
|
924 + | type Future = PutWithContentEncodingInputFuture;
|
896 925 |
|
897 926 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
898 927 | let fut = async move {
|
899 928 | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
900 929 | request.headers(),
|
901 930 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
|
902 931 | ) {
|
903 932 | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
904 933 | }
|
905 - | crate::protocol_serde::shape_endpoint_operation::de_endpoint_operation_http_request(
|
906 - | request,
|
907 - | )
|
934 + | crate::protocol_serde::shape_put_with_content_encoding::de_put_with_content_encoding_http_request(request)
|
908 935 | .await
|
909 936 | };
|
910 937 | use ::futures_util::future::TryFutureExt;
|
911 938 | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
912 939 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
913 940 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
914 941 | });
|
915 - | EndpointOperationInputFuture {
|
942 + | PutWithContentEncodingInputFuture {
|
916 943 | inner: Box::pin(fut),
|
917 944 | }
|
918 945 | }
|
919 946 | }
|
920 947 | impl
|
921 948 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
922 949 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
923 - | > for crate::output::EndpointOperationOutput
|
950 + | > for crate::output::PutWithContentEncodingOutput
|
924 951 | {
|
925 952 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
926 - | match crate::protocol_serde::shape_endpoint_operation::ser_endpoint_operation_http_response(
|
927 - | self,
|
928 - | ) {
|
953 + | match crate::protocol_serde::shape_put_with_content_encoding::ser_put_with_content_encoding_http_response(self) {
|
929 954 | Ok(response) => response,
|
930 955 | Err(e) => {
|
931 956 | ::tracing::error!(error = %e, "failed to serialize response");
|
932 957 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
933 958 | }
|
934 959 | }
|
935 960 | }
|
936 961 | }
|
937 962 | impl
|
938 963 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
939 964 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
940 - | > for crate::error::EndpointOperationError
|
965 + | > for crate::error::PutWithContentEncodingError
|
941 966 | {
|
942 967 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
943 - | match crate::protocol_serde::shape_endpoint_operation::ser_endpoint_operation_http_error(
|
944 - | &self,
|
945 - | ) {
|
968 + | match crate::protocol_serde::shape_put_with_content_encoding::ser_put_with_content_encoding_http_error(&self) {
|
946 969 | Ok(mut response) => {
|
947 - | response.extensions_mut().insert(
|
948 - | ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
|
949 - | self.name(),
|
950 - | ),
|
951 - | );
|
970 + | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
952 971 | response
|
953 - | }
|
972 + | },
|
954 973 | Err(e) => {
|
955 974 | ::tracing::error!(error = %e, "failed to serialize response");
|
956 975 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
957 976 | }
|
958 977 | }
|
959 978 | }
|
960 979 | }
|
961 980 |
|
962 981 | ::pin_project_lite::pin_project! {
|
963 982 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
964 - | /// [`JsonUnionsInput`](crate::input::JsonUnionsInput) using modelled bindings.
|
965 - | pub struct JsonUnionsInputFuture {
|
966 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::JsonUnionsInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
983 + | /// [`ContentTypeParametersInput`](crate::input::ContentTypeParametersInput) using modelled bindings.
|
984 + | pub struct ContentTypeParametersInputFuture {
|
985 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ContentTypeParametersInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
967 986 | }
|
968 987 | }
|
969 988 |
|
970 - | impl std::future::Future for JsonUnionsInputFuture {
|
989 + | impl std::future::Future for ContentTypeParametersInputFuture {
|
971 990 | type Output = Result<
|
972 - | crate::input::JsonUnionsInput,
|
991 + | crate::input::ContentTypeParametersInput,
|
973 992 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
974 993 | >;
|
975 994 |
|
976 995 | fn poll(
|
977 996 | self: std::pin::Pin<&mut Self>,
|
978 997 | cx: &mut std::task::Context<'_>,
|
979 998 | ) -> std::task::Poll<Self::Output> {
|
980 999 | let this = self.project();
|
981 1000 | this.inner.as_mut().poll(cx)
|
982 1001 | }
|
983 1002 | }
|
984 1003 |
|
985 1004 | impl<B>
|
986 1005 | ::aws_smithy_legacy_http_server::request::FromRequest<
|
987 1006 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
988 1007 | B,
|
989 - | > for crate::input::JsonUnionsInput
|
1008 + | > for crate::input::ContentTypeParametersInput
|
990 1009 | where
|
991 1010 | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
992 1011 | B: 'static,
|
993 1012 |
|
994 1013 | B::Data: Send,
|
995 1014 | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
996 1015 | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
997 1016 | {
|
998 1017 | type Rejection =
|
999 1018 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
1000 - | type Future = JsonUnionsInputFuture;
|
1019 + | type Future = ContentTypeParametersInputFuture;
|
1001 1020 |
|
1002 1021 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
1003 1022 | let fut = async move {
|
1004 1023 | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
1005 1024 | request.headers(),
|
1006 1025 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
|
1007 1026 | ) {
|
1008 1027 | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
1009 1028 | }
|
1010 - | crate::protocol_serde::shape_json_unions::de_json_unions_http_request(request).await
|
1029 + | crate::protocol_serde::shape_content_type_parameters::de_content_type_parameters_http_request(request)
|
1030 + | .await
|
1011 1031 | };
|
1012 1032 | use ::futures_util::future::TryFutureExt;
|
1013 1033 | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1014 1034 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1015 1035 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1016 1036 | });
|
1017 - | JsonUnionsInputFuture {
|
1037 + | ContentTypeParametersInputFuture {
|
1018 1038 | inner: Box::pin(fut),
|
1019 1039 | }
|
1020 1040 | }
|
1021 1041 | }
|
1022 1042 | impl
|
1023 1043 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1024 1044 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
1025 - | > for crate::output::JsonUnionsOutput
|
1045 + | > for crate::output::ContentTypeParametersOutput
|
1026 1046 | {
|
1027 1047 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1028 - | match crate::protocol_serde::shape_json_unions::ser_json_unions_http_response(self) {
|
1048 + | match crate::protocol_serde::shape_content_type_parameters::ser_content_type_parameters_http_response(self) {
|
1029 1049 | Ok(response) => response,
|
1030 1050 | Err(e) => {
|
1031 1051 | ::tracing::error!(error = %e, "failed to serialize response");
|
1032 1052 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1033 1053 | }
|
1034 1054 | }
|
1035 1055 | }
|
1036 1056 | }
|
1037 1057 | impl
|
1038 1058 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1039 1059 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
1040 - | > for crate::error::JsonUnionsError
|
1060 + | > for crate::error::ContentTypeParametersError
|
1041 1061 | {
|
1042 1062 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1043 - | match crate::protocol_serde::shape_json_unions::ser_json_unions_http_error(&self) {
|
1063 + | match crate::protocol_serde::shape_content_type_parameters::ser_content_type_parameters_http_error(&self) {
|
1044 1064 | Ok(mut response) => {
|
1045 - | response.extensions_mut().insert(
|
1046 - | ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
|
1047 - | self.name(),
|
1048 - | ),
|
1049 - | );
|
1065 + | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1050 1066 | response
|
1051 - | }
|
1067 + | },
|
1052 1068 | Err(e) => {
|
1053 1069 | ::tracing::error!(error = %e, "failed to serialize response");
|
1054 1070 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1055 1071 | }
|
1056 1072 | }
|
1057 1073 | }
|
1058 1074 | }
|
1059 1075 |
|
1060 1076 | ::pin_project_lite::pin_project! {
|
1061 1077 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
1062 - | /// [`GreetingWithErrorsInput`](crate::input::GreetingWithErrorsInput) using modelled bindings.
|
1063 - | pub struct GreetingWithErrorsInputFuture {
|
1064 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::GreetingWithErrorsInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1078 + | /// [`OperationWithDefaultsInput`](crate::input::OperationWithDefaultsInput) using modelled bindings.
|
1079 + | pub struct OperationWithDefaultsInputFuture {
|
1080 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::OperationWithDefaultsInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1065 1081 | }
|
1066 1082 | }
|
1067 1083 |
|
1068 - | impl std::future::Future for GreetingWithErrorsInputFuture {
|
1084 + | impl std::future::Future for OperationWithDefaultsInputFuture {
|
1069 1085 | type Output = Result<
|
1070 - | crate::input::GreetingWithErrorsInput,
|
1086 + | crate::input::OperationWithDefaultsInput,
|
1071 1087 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
1072 1088 | >;
|
1073 1089 |
|
1074 1090 | fn poll(
|
1075 1091 | self: std::pin::Pin<&mut Self>,
|
1076 1092 | cx: &mut std::task::Context<'_>,
|
1077 1093 | ) -> std::task::Poll<Self::Output> {
|
1078 1094 | let this = self.project();
|
1079 1095 | this.inner.as_mut().poll(cx)
|
1080 1096 | }
|
1081 1097 | }
|
1082 1098 |
|
1083 1099 | impl<B>
|
1084 1100 | ::aws_smithy_legacy_http_server::request::FromRequest<
|
1085 1101 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
1086 1102 | B,
|
1087 - | > for crate::input::GreetingWithErrorsInput
|
1103 + | > for crate::input::OperationWithDefaultsInput
|
1088 1104 | where
|
1089 1105 | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
1090 1106 | B: 'static,
|
1091 1107 |
|
1092 1108 | B::Data: Send,
|
1093 1109 | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
1094 1110 | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
1095 1111 | {
|
1096 1112 | type Rejection =
|
1097 1113 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
1098 - | type Future = GreetingWithErrorsInputFuture;
|
1114 + | type Future = OperationWithDefaultsInputFuture;
|
1099 1115 |
|
1100 1116 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
1101 1117 | let fut = async move {
|
1102 1118 | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
1103 1119 | request.headers(),
|
1104 1120 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
|
1105 1121 | ) {
|
1106 1122 | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
1107 1123 | }
|
1108 - | crate::protocol_serde::shape_greeting_with_errors::de_greeting_with_errors_http_request(
|
1109 - | request,
|
1110 - | )
|
1124 + | crate::protocol_serde::shape_operation_with_defaults::de_operation_with_defaults_http_request(request)
|
1111 1125 | .await
|
1112 1126 | };
|
1113 1127 | use ::futures_util::future::TryFutureExt;
|
1114 1128 | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1115 1129 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1116 1130 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1117 1131 | });
|
1118 - | GreetingWithErrorsInputFuture {
|
1132 + | OperationWithDefaultsInputFuture {
|
1119 1133 | inner: Box::pin(fut),
|
1120 1134 | }
|
1121 1135 | }
|
1122 1136 | }
|
1123 1137 | impl
|
1124 1138 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1125 1139 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
1126 - | > for crate::output::GreetingWithErrorsOutput
|
1140 + | > for crate::output::OperationWithDefaultsOutput
|
1127 1141 | {
|
1128 1142 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1129 - | match crate::protocol_serde::shape_greeting_with_errors::ser_greeting_with_errors_http_response(self) {
|
1143 + | match crate::protocol_serde::shape_operation_with_defaults::ser_operation_with_defaults_http_response(self) {
|
1130 1144 | Ok(response) => response,
|
1131 1145 | Err(e) => {
|
1132 1146 | ::tracing::error!(error = %e, "failed to serialize response");
|
1133 1147 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1134 1148 | }
|
1135 1149 | }
|
1136 1150 | }
|
1137 1151 | }
|
1138 1152 | impl
|
1139 1153 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1140 1154 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
1141 - | > for crate::error::GreetingWithErrorsError
|
1155 + | > for crate::error::OperationWithDefaultsError
|
1142 1156 | {
|
1143 1157 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1144 - | match crate::protocol_serde::shape_greeting_with_errors::ser_greeting_with_errors_http_error(
|
1145 - | &self,
|
1146 - | ) {
|
1158 + | match crate::protocol_serde::shape_operation_with_defaults::ser_operation_with_defaults_http_error(&self) {
|
1147 1159 | Ok(mut response) => {
|
1148 - | response.extensions_mut().insert(
|
1149 - | ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
|
1150 - | self.name(),
|
1151 - | ),
|
1152 - | );
|
1160 + | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1153 1161 | response
|
1154 - | }
|
1162 + | },
|
1155 1163 | Err(e) => {
|
1156 1164 | ::tracing::error!(error = %e, "failed to serialize response");
|
1157 1165 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1158 1166 | }
|
1159 1167 | }
|
1160 1168 | }
|
1161 1169 | }
|
1162 1170 |
|
1163 1171 | ::pin_project_lite::pin_project! {
|
1164 1172 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
1165 - | /// [`SimpleScalarPropertiesInput`](crate::input::SimpleScalarPropertiesInput) using modelled bindings.
|
1166 - | pub struct SimpleScalarPropertiesInputFuture {
|
1167 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::SimpleScalarPropertiesInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1173 + | /// [`OperationWithRequiredMembersInput`](crate::input::OperationWithRequiredMembersInput) using modelled bindings.
|
1174 + | pub struct OperationWithRequiredMembersInputFuture {
|
1175 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::OperationWithRequiredMembersInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1168 1176 | }
|
1169 1177 | }
|
1170 1178 |
|
1171 - | impl std::future::Future for SimpleScalarPropertiesInputFuture {
|
1179 + | impl std::future::Future for OperationWithRequiredMembersInputFuture {
|
1172 1180 | type Output = Result<
|
1173 - | crate::input::SimpleScalarPropertiesInput,
|
1181 + | crate::input::OperationWithRequiredMembersInput,
|
1174 1182 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
1175 1183 | >;
|
1176 1184 |
|
1177 1185 | fn poll(
|
1178 1186 | self: std::pin::Pin<&mut Self>,
|
1179 1187 | cx: &mut std::task::Context<'_>,
|
1180 1188 | ) -> std::task::Poll<Self::Output> {
|
1181 1189 | let this = self.project();
|
1182 1190 | this.inner.as_mut().poll(cx)
|
1183 1191 | }
|
1184 1192 | }
|
1185 1193 |
|
1186 1194 | impl<B>
|
1187 1195 | ::aws_smithy_legacy_http_server::request::FromRequest<
|
1188 1196 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
1189 1197 | B,
|
1190 - | > for crate::input::SimpleScalarPropertiesInput
|
1198 + | > for crate::input::OperationWithRequiredMembersInput
|
1191 1199 | where
|
1192 1200 | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
1193 1201 | B: 'static,
|
1194 1202 |
|
1195 1203 | B::Data: Send,
|
1196 1204 | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
1197 1205 | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
1198 1206 | {
|
1199 1207 | type Rejection =
|
1200 1208 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
1201 - | type Future = SimpleScalarPropertiesInputFuture;
|
1209 + | type Future = OperationWithRequiredMembersInputFuture;
|
1202 1210 |
|
1203 1211 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
1204 1212 | let fut = async move {
|
1205 1213 | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
1206 1214 | request.headers(),
|
1207 1215 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
|
1208 1216 | ) {
|
1209 1217 | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
1210 1218 | }
|
1211 - | crate::protocol_serde::shape_simple_scalar_properties::de_simple_scalar_properties_http_request(request)
|
1219 + | crate::protocol_serde::shape_operation_with_required_members::de_operation_with_required_members_http_request(request)
|
1212 1220 | .await
|
1213 1221 | };
|
1214 1222 | use ::futures_util::future::TryFutureExt;
|
1215 1223 | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1216 1224 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1217 1225 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1218 1226 | });
|
1219 - | SimpleScalarPropertiesInputFuture {
|
1227 + | OperationWithRequiredMembersInputFuture {
|
1220 1228 | inner: Box::pin(fut),
|
1221 1229 | }
|
1222 1230 | }
|
1223 1231 | }
|
1224 1232 | impl
|
1225 1233 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1226 1234 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
1227 - | > for crate::output::SimpleScalarPropertiesOutput
|
1235 + | > for crate::output::OperationWithRequiredMembersOutput
|
1228 1236 | {
|
1229 1237 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1230 - | match crate::protocol_serde::shape_simple_scalar_properties::ser_simple_scalar_properties_http_response(self) {
|
1238 + | match crate::protocol_serde::shape_operation_with_required_members::ser_operation_with_required_members_http_response(self) {
|
1231 1239 | Ok(response) => response,
|
1232 1240 | Err(e) => {
|
1233 1241 | ::tracing::error!(error = %e, "failed to serialize response");
|
1234 1242 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1235 1243 | }
|
1236 1244 | }
|
1237 1245 | }
|
1238 1246 | }
|
1239 1247 | impl
|
1240 1248 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1241 1249 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
1242 - | > for crate::error::SimpleScalarPropertiesError
|
1250 + | > for crate::error::OperationWithRequiredMembersError
|
1243 1251 | {
|
1244 1252 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1245 - | match crate::protocol_serde::shape_simple_scalar_properties::ser_simple_scalar_properties_http_error(&self) {
|
1253 + | match crate::protocol_serde::shape_operation_with_required_members::ser_operation_with_required_members_http_error(&self) {
|
1246 1254 | Ok(mut response) => {
|
1247 1255 | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1248 1256 | response
|
1249 1257 | },
|
1250 1258 | Err(e) => {
|
1251 1259 | ::tracing::error!(error = %e, "failed to serialize response");
|
1252 1260 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1253 1261 | }
|
1254 1262 | }
|
1255 1263 | }
|
1256 1264 | }
|
1257 1265 |
|
1258 1266 | ::pin_project_lite::pin_project! {
|
1259 1267 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
1260 - | /// [`EmptyInputAndEmptyOutputInput`](crate::input::EmptyInputAndEmptyOutputInput) using modelled bindings.
|
1261 - | pub struct EmptyInputAndEmptyOutputInputFuture {
|
1262 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EmptyInputAndEmptyOutputInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1268 + | /// [`OperationWithNestedStructureInput`](crate::input::OperationWithNestedStructureInput) using modelled bindings.
|
1269 + | pub struct OperationWithNestedStructureInputFuture {
|
1270 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::OperationWithNestedStructureInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1263 1271 | }
|
1264 1272 | }
|
1265 1273 |
|
1266 - | impl std::future::Future for EmptyInputAndEmptyOutputInputFuture {
|
1274 + | impl std::future::Future for OperationWithNestedStructureInputFuture {
|
1267 1275 | type Output = Result<
|
1268 - | crate::input::EmptyInputAndEmptyOutputInput,
|
1276 + | crate::input::OperationWithNestedStructureInput,
|
1269 1277 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
1270 1278 | >;
|
1271 1279 |
|
1272 1280 | fn poll(
|
1273 1281 | self: std::pin::Pin<&mut Self>,
|
1274 1282 | cx: &mut std::task::Context<'_>,
|
1275 1283 | ) -> std::task::Poll<Self::Output> {
|
1276 1284 | let this = self.project();
|
1277 1285 | this.inner.as_mut().poll(cx)
|
1278 1286 | }
|
1279 1287 | }
|
1280 1288 |
|
1281 1289 | impl<B>
|
1282 1290 | ::aws_smithy_legacy_http_server::request::FromRequest<
|
1283 1291 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
1284 1292 | B,
|
1285 - | > for crate::input::EmptyInputAndEmptyOutputInput
|
1293 + | > for crate::input::OperationWithNestedStructureInput
|
1286 1294 | where
|
1287 1295 | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
1288 1296 | B: 'static,
|
1289 1297 |
|
1290 1298 | B::Data: Send,
|
1291 1299 | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
1292 1300 | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
1293 1301 | {
|
1294 1302 | type Rejection =
|
1295 1303 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
1296 - | type Future = EmptyInputAndEmptyOutputInputFuture;
|
1304 + | type Future = OperationWithNestedStructureInputFuture;
|
1297 1305 |
|
1298 1306 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
1299 1307 | let fut = async move {
|
1300 1308 | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
1301 1309 | request.headers(),
|
1302 1310 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
|
1303 1311 | ) {
|
1304 1312 | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
1305 1313 | }
|
1306 - | crate::protocol_serde::shape_empty_input_and_empty_output::de_empty_input_and_empty_output_http_request(request)
|
1314 + | crate::protocol_serde::shape_operation_with_nested_structure::de_operation_with_nested_structure_http_request(request)
|
1307 1315 | .await
|
1308 1316 | };
|
1309 1317 | use ::futures_util::future::TryFutureExt;
|
1310 1318 | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1311 1319 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1312 1320 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1313 1321 | });
|
1314 - | EmptyInputAndEmptyOutputInputFuture {
|
1322 + | OperationWithNestedStructureInputFuture {
|
1315 1323 | inner: Box::pin(fut),
|
1316 1324 | }
|
1317 1325 | }
|
1318 1326 | }
|
1319 1327 | impl
|
1320 1328 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1321 1329 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
1322 - | > for crate::output::EmptyInputAndEmptyOutputOutput
|
1330 + | > for crate::output::OperationWithNestedStructureOutput
|
1323 1331 | {
|
1324 1332 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1325 - | match crate::protocol_serde::shape_empty_input_and_empty_output::ser_empty_input_and_empty_output_http_response(self) {
|
1333 + | match crate::protocol_serde::shape_operation_with_nested_structure::ser_operation_with_nested_structure_http_response(self) {
|
1326 1334 | Ok(response) => response,
|
1327 1335 | Err(e) => {
|
1328 1336 | ::tracing::error!(error = %e, "failed to serialize response");
|
1329 1337 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1330 1338 | }
|
1331 1339 | }
|
1332 1340 | }
|
1333 1341 | }
|
1334 1342 | impl
|
1335 1343 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1336 1344 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
1337 - | > for crate::error::EmptyInputAndEmptyOutputError
|
1345 + | > for crate::error::OperationWithNestedStructureError
|
1338 1346 | {
|
1339 1347 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1340 - | match crate::protocol_serde::shape_empty_input_and_empty_output::ser_empty_input_and_empty_output_http_error(&self) {
|
1348 + | match crate::protocol_serde::shape_operation_with_nested_structure::ser_operation_with_nested_structure_http_error(&self) {
|
1341 1349 | Ok(mut response) => {
|
1342 1350 | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1343 1351 | response
|
1344 1352 | },
|
1345 1353 | Err(e) => {
|
1346 1354 | ::tracing::error!(error = %e, "failed to serialize response");
|
1347 1355 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1348 1356 | }
|
1349 1357 | }
|
1350 1358 | }
|
1351 1359 | }
|
1352 1360 |
|
1353 1361 | ::pin_project_lite::pin_project! {
|
1354 1362 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
1355 - | /// [`NoInputAndOutputInput`](crate::input::NoInputAndOutputInput) using modelled bindings.
|
1356 - | pub struct NoInputAndOutputInputFuture {
|
1357 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::NoInputAndOutputInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1363 + | /// [`OperationWithRequiredMembersWithDefaultsInput`](crate::input::OperationWithRequiredMembersWithDefaultsInput) using modelled bindings.
|
1364 + | pub struct OperationWithRequiredMembersWithDefaultsInputFuture {
|
1365 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::OperationWithRequiredMembersWithDefaultsInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1358 1366 | }
|
1359 1367 | }
|
1360 1368 |
|
1361 - | impl std::future::Future for NoInputAndOutputInputFuture {
|
1369 + | impl std::future::Future for OperationWithRequiredMembersWithDefaultsInputFuture {
|
1362 1370 | type Output = Result<
|
1363 - | crate::input::NoInputAndOutputInput,
|
1371 + | crate::input::OperationWithRequiredMembersWithDefaultsInput,
|
1364 1372 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
1365 1373 | >;
|
1366 1374 |
|
1367 1375 | fn poll(
|
1368 1376 | self: std::pin::Pin<&mut Self>,
|
1369 1377 | cx: &mut std::task::Context<'_>,
|
1370 1378 | ) -> std::task::Poll<Self::Output> {
|
1371 1379 | let this = self.project();
|
1372 1380 | this.inner.as_mut().poll(cx)
|
1373 1381 | }
|
1374 1382 | }
|
1375 1383 |
|
1376 1384 | impl<B>
|
1377 1385 | ::aws_smithy_legacy_http_server::request::FromRequest<
|
1378 1386 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
1379 1387 | B,
|
1380 - | > for crate::input::NoInputAndOutputInput
|
1388 + | > for crate::input::OperationWithRequiredMembersWithDefaultsInput
|
1381 1389 | where
|
1382 1390 | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
1383 1391 | B: 'static,
|
1384 1392 |
|
1385 1393 | B::Data: Send,
|
1386 1394 | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
1387 1395 | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
1388 1396 | {
|
1389 1397 | type Rejection =
|
1390 1398 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
1391 - | type Future = NoInputAndOutputInputFuture;
|
1399 + | type Future = OperationWithRequiredMembersWithDefaultsInputFuture;
|
1392 1400 |
|
1393 1401 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
1394 1402 | let fut = async move {
|
1395 1403 | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
1396 1404 | request.headers(),
|
1397 1405 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
|
1398 1406 | ) {
|
1399 1407 | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
1400 1408 | }
|
1401 - | crate::protocol_serde::shape_no_input_and_output::de_no_input_and_output_http_request(
|
1402 - | request,
|
1403 - | )
|
1409 + | crate::protocol_serde::shape_operation_with_required_members_with_defaults::de_operation_with_required_members_with_defaults_http_request(request)
|
1404 1410 | .await
|
1405 1411 | };
|
1406 1412 | use ::futures_util::future::TryFutureExt;
|
1407 1413 | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1408 1414 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1409 1415 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1410 1416 | });
|
1411 - | NoInputAndOutputInputFuture {
|
1417 + | OperationWithRequiredMembersWithDefaultsInputFuture {
|
1412 1418 | inner: Box::pin(fut),
|
1413 1419 | }
|
1414 1420 | }
|
1415 1421 | }
|
1416 1422 | impl
|
1417 1423 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1418 1424 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
1419 - | > for crate::output::NoInputAndOutputOutput
|
1425 + | > for crate::output::OperationWithRequiredMembersWithDefaultsOutput
|
1420 1426 | {
|
1421 1427 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1422 - | match crate::protocol_serde::shape_no_input_and_output::ser_no_input_and_output_http_response(self) {
|
1428 + | match crate::protocol_serde::shape_operation_with_required_members_with_defaults::ser_operation_with_required_members_with_defaults_http_response(self) {
|
1423 1429 | Ok(response) => response,
|
1424 1430 | Err(e) => {
|
1425 1431 | ::tracing::error!(error = %e, "failed to serialize response");
|
1426 1432 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1427 1433 | }
|
1428 1434 | }
|
1429 1435 | }
|
1430 1436 | }
|
1431 1437 | impl
|
1432 1438 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1433 1439 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
1434 - | > for crate::error::NoInputAndOutputError
|
1440 + | > for crate::error::OperationWithRequiredMembersWithDefaultsError
|
1435 1441 | {
|
1436 1442 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1437 - | match crate::protocol_serde::shape_no_input_and_output::ser_no_input_and_output_http_error(
|
1438 - | &self,
|
1439 - | ) {
|
1443 + | match crate::protocol_serde::shape_operation_with_required_members_with_defaults::ser_operation_with_required_members_with_defaults_http_error(&self) {
|
1440 1444 | Ok(mut response) => {
|
1441 - | response.extensions_mut().insert(
|
1442 - | ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
|
1443 - | self.name(),
|
1444 - | ),
|
1445 - | );
|
1445 + | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1446 1446 | response
|
1447 - | }
|
1447 + | },
|
1448 1448 | Err(e) => {
|
1449 1449 | ::tracing::error!(error = %e, "failed to serialize response");
|
1450 1450 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1451 1451 | }
|
1452 1452 | }
|
1453 1453 | }
|
1454 1454 | }
|
1455 1455 |
|
1456 1456 | ::pin_project_lite::pin_project! {
|
1457 1457 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
1458 - | /// [`NoInputAndNoOutputInput`](crate::input::NoInputAndNoOutputInput) using modelled bindings.
|
1459 - | pub struct NoInputAndNoOutputInputFuture {
|
1460 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::NoInputAndNoOutputInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1458 + | /// [`QueryIncompatibleOperationInput`](crate::input::QueryIncompatibleOperationInput) using modelled bindings.
|
1459 + | pub struct QueryIncompatibleOperationInputFuture {
|
1460 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryIncompatibleOperationInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1461 1461 | }
|
1462 1462 | }
|
1463 1463 |
|
1464 - | impl std::future::Future for NoInputAndNoOutputInputFuture {
|
1464 + | impl std::future::Future for QueryIncompatibleOperationInputFuture {
|
1465 1465 | type Output = Result<
|
1466 - | crate::input::NoInputAndNoOutputInput,
|
1466 + | crate::input::QueryIncompatibleOperationInput,
|
1467 1467 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
1468 1468 | >;
|
1469 1469 |
|
1470 1470 | fn poll(
|
1471 1471 | self: std::pin::Pin<&mut Self>,
|
1472 1472 | cx: &mut std::task::Context<'_>,
|
1473 1473 | ) -> std::task::Poll<Self::Output> {
|
1474 1474 | let this = self.project();
|
1475 1475 | this.inner.as_mut().poll(cx)
|
1476 1476 | }
|
1477 1477 | }
|
1478 1478 |
|
1479 1479 | impl<B>
|
1480 1480 | ::aws_smithy_legacy_http_server::request::FromRequest<
|
1481 1481 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
1482 1482 | B,
|
1483 - | > for crate::input::NoInputAndNoOutputInput
|
1483 + | > for crate::input::QueryIncompatibleOperationInput
|
1484 1484 | where
|
1485 1485 | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
1486 1486 | B: 'static,
|
1487 1487 |
|
1488 1488 | B::Data: Send,
|
1489 1489 | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
1490 1490 | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
1491 1491 | {
|
1492 1492 | type Rejection =
|
1493 1493 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
1494 - | type Future = NoInputAndNoOutputInputFuture;
|
1494 + | type Future = QueryIncompatibleOperationInputFuture;
|
1495 1495 |
|
1496 1496 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
1497 1497 | let fut = async move {
|
1498 1498 | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
1499 1499 | request.headers(),
|
1500 1500 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_0,
|
1501 1501 | ) {
|
1502 1502 | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
1503 1503 | }
|
1504 - | crate::protocol_serde::shape_no_input_and_no_output::de_no_input_and_no_output_http_request(request)
|
1504 + | crate::protocol_serde::shape_query_incompatible_operation::de_query_incompatible_operation_http_request(request)
|
1505 1505 | .await
|
1506 1506 | };
|
1507 1507 | use ::futures_util::future::TryFutureExt;
|
1508 1508 | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1509 1509 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1510 1510 | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1511 1511 | });
|
1512 - | NoInputAndNoOutputInputFuture {
|
1512 + | QueryIncompatibleOperationInputFuture {
|
1513 1513 | inner: Box::pin(fut),
|
1514 1514 | }
|
1515 1515 | }
|
1516 1516 | }
|
1517 1517 | impl
|
1518 1518 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1519 1519 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
1520 - | > for crate::output::NoInputAndNoOutputOutput
|
1520 + | > for crate::output::QueryIncompatibleOperationOutput
|
1521 1521 | {
|
1522 1522 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1523 - | match crate::protocol_serde::shape_no_input_and_no_output::ser_no_input_and_no_output_http_response(self) {
|
1523 + | match crate::protocol_serde::shape_query_incompatible_operation::ser_query_incompatible_operation_http_response(self) {
|
1524 1524 | Ok(response) => response,
|
1525 1525 | Err(e) => {
|
1526 1526 | ::tracing::error!(error = %e, "failed to serialize response");
|
1527 1527 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1528 1528 | }
|
1529 1529 | }
|
1530 1530 | }
|
1531 1531 | }
|
1532 1532 | impl
|
1533 1533 | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1534 1534 | ::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0,
|
1535 - | > for crate::error::NoInputAndNoOutputError
|
1535 + | > for crate::error::QueryIncompatibleOperationError
|
1536 1536 | {
|
1537 1537 | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1538 - | match crate::protocol_serde::shape_no_input_and_no_output::ser_no_input_and_no_output_http_error(&self) {
|
1538 + | match crate::protocol_serde::shape_query_incompatible_operation::ser_query_incompatible_operation_http_error(&self) {
|
1539 1539 | Ok(mut response) => {
|
1540 1540 | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1541 1541 | response
|
1542 1542 | },
|
1543 1543 | Err(e) => {
|
1544 1544 | ::tracing::error!(error = %e, "failed to serialize response");
|
1545 1545 | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_10::AwsJson1_0>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1546 1546 | }
|
1547 1547 | }
|
1548 1548 | }
|