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 - | /// [`EventStreamsOperationInput`](crate::input::EventStreamsOperationInput) using modelled bindings.
|
5 - | pub struct EventStreamsOperationInputFuture {
|
6 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EventStreamsOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
4 + | /// [`ConstrainedShapesOperationInput`](crate::input::ConstrainedShapesOperationInput) using modelled bindings.
|
5 + | pub struct ConstrainedShapesOperationInputFuture {
|
6 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ConstrainedShapesOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
7 7 | }
|
8 8 | }
|
9 9 |
|
10 - | impl std::future::Future for EventStreamsOperationInputFuture {
|
10 + | impl std::future::Future for ConstrainedShapesOperationInputFuture {
|
11 11 | type Output = Result<
|
12 - | crate::input::EventStreamsOperationInput,
|
12 + | crate::input::ConstrainedShapesOperationInput,
|
13 13 | ::aws_smithy_http_server::protocol::rest_json_1::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_http_server::request::FromRequest<
|
27 27 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
28 28 | B,
|
29 - | > for crate::input::EventStreamsOperationInput
|
29 + | > for crate::input::ConstrainedShapesOperationInput
|
30 30 | where
|
31 31 | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
32 32 | B: 'static,
|
33 33 |
|
34 - | B: ::http_body_1x::Body<Data = ::bytes::Bytes>
|
35 - | + ::std::marker::Send
|
36 - | + ::std::marker::Sync
|
37 - | + 'static,
|
38 - | B::Error: Into<::aws_smithy_types::body::Error> + 'static,
|
39 - |
|
40 34 | B::Data: Send,
|
41 35 | ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
|
42 36 | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
43 37 | {
|
44 38 | type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
|
45 - | type Future = EventStreamsOperationInputFuture;
|
39 + | type Future = ConstrainedShapesOperationInputFuture;
|
46 40 |
|
47 41 | fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
|
48 42 | let fut = async move {
|
49 43 | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
50 44 | request.headers(),
|
51 - | &crate::mimes::CONTENT_TYPE_APPLICATION_VND_AMAZON_EVENTSTREAM,
|
45 + | &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
|
52 46 | ) {
|
53 47 | return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
|
54 48 | }
|
55 - | crate::protocol_serde::shape_event_streams_operation::de_event_streams_operation_http_request(request)
|
49 + | crate::protocol_serde::shape_constrained_shapes_operation::de_constrained_shapes_operation_http_request(request)
|
56 50 | .await
|
57 51 | };
|
58 52 | use ::futures_util::future::TryFutureExt;
|
59 53 | let fut = fut.map_err(
|
60 54 | |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
|
61 55 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
62 56 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
|
63 57 | e,
|
64 58 | )
|
65 59 | },
|
66 60 | );
|
67 - | EventStreamsOperationInputFuture {
|
61 + | ConstrainedShapesOperationInputFuture {
|
68 62 | inner: Box::pin(fut),
|
69 63 | }
|
70 64 | }
|
71 65 | }
|
72 66 | impl
|
73 67 | ::aws_smithy_http_server::response::IntoResponse<
|
74 68 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
75 - | > for crate::output::EventStreamsOperationOutput
|
69 + | > for crate::output::ConstrainedShapesOperationOutput
|
76 70 | {
|
77 71 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
78 - | match crate::protocol_serde::shape_event_streams_operation::ser_event_streams_operation_http_response(self) {
|
72 + | match crate::protocol_serde::shape_constrained_shapes_operation::ser_constrained_shapes_operation_http_response(self) {
|
79 73 | Ok(response) => response,
|
80 74 | Err(e) => {
|
81 75 | ::tracing::error!(error = %e, "failed to serialize response");
|
82 76 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
83 77 | }
|
84 78 | }
|
85 79 | }
|
86 80 | }
|
87 81 | impl
|
88 82 | ::aws_smithy_http_server::response::IntoResponse<
|
89 83 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
90 - | > for crate::error::EventStreamsOperationError
|
84 + | > for crate::error::ConstrainedShapesOperationError
|
91 85 | {
|
92 86 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
93 - | match crate::protocol_serde::shape_event_streams_operation::ser_event_streams_operation_http_error(&self) {
|
87 + | match crate::protocol_serde::shape_constrained_shapes_operation::ser_constrained_shapes_operation_http_error(&self) {
|
94 88 | Ok(mut response) => {
|
95 89 | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
96 90 | response
|
97 91 | },
|
98 92 | Err(e) => {
|
99 93 | ::tracing::error!(error = %e, "failed to serialize response");
|
100 94 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
101 95 | }
|
102 96 | }
|
103 97 | }
|
104 98 | }
|
105 99 |
|
106 100 | ::pin_project_lite::pin_project! {
|
107 101 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
108 - | /// [`StreamingBlobOperationInput`](crate::input::StreamingBlobOperationInput) using modelled bindings.
|
109 - | pub struct StreamingBlobOperationInputFuture {
|
110 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::StreamingBlobOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
102 + | /// [`ConstrainedShapesOnlyInOutputOperationInput`](crate::input::ConstrainedShapesOnlyInOutputOperationInput) using modelled bindings.
|
103 + | pub struct ConstrainedShapesOnlyInOutputOperationInputFuture {
|
104 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ConstrainedShapesOnlyInOutputOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
111 105 | }
|
112 106 | }
|
113 107 |
|
114 - | impl std::future::Future for StreamingBlobOperationInputFuture {
|
108 + | impl std::future::Future for ConstrainedShapesOnlyInOutputOperationInputFuture {
|
115 109 | type Output = Result<
|
116 - | crate::input::StreamingBlobOperationInput,
|
110 + | crate::input::ConstrainedShapesOnlyInOutputOperationInput,
|
117 111 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
|
118 112 | >;
|
119 113 |
|
120 114 | fn poll(
|
121 115 | self: std::pin::Pin<&mut Self>,
|
122 116 | cx: &mut std::task::Context<'_>,
|
123 117 | ) -> std::task::Poll<Self::Output> {
|
124 118 | let this = self.project();
|
125 119 | this.inner.as_mut().poll(cx)
|
126 120 | }
|
127 121 | }
|
128 122 |
|
129 123 | impl<B>
|
130 124 | ::aws_smithy_http_server::request::FromRequest<
|
131 125 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
132 126 | B,
|
133 - | > for crate::input::StreamingBlobOperationInput
|
127 + | > for crate::input::ConstrainedShapesOnlyInOutputOperationInput
|
134 128 | where
|
135 129 | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
136 130 | B: 'static,
|
137 131 |
|
138 - | B: ::http_body_1x::Body<Data = ::bytes::Bytes>
|
139 - | + ::std::marker::Send
|
140 - | + ::std::marker::Sync
|
141 - | + 'static,
|
142 - | B::Error: Into<::aws_smithy_types::body::Error> + 'static,
|
143 - |
|
144 132 | B::Data: Send,
|
145 133 | ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
|
146 134 | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
147 135 | {
|
148 136 | type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
|
149 - | type Future = StreamingBlobOperationInputFuture;
|
137 + | type Future = ConstrainedShapesOnlyInOutputOperationInputFuture;
|
150 138 |
|
151 139 | fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
|
152 140 | let fut = async move {
|
153 141 | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
154 142 | request.headers(),
|
155 - | &crate::mimes::CONTENT_TYPE_APPLICATION_OCTET_STREAM,
|
143 + | &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
|
156 144 | ) {
|
157 145 | return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
|
158 146 | }
|
159 - | crate::protocol_serde::shape_streaming_blob_operation::de_streaming_blob_operation_http_request(request)
|
147 + | crate::protocol_serde::shape_constrained_shapes_only_in_output_operation::de_constrained_shapes_only_in_output_operation_http_request(request)
|
160 148 | .await
|
161 149 | };
|
162 150 | use ::futures_util::future::TryFutureExt;
|
163 151 | let fut = fut.map_err(
|
164 152 | |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
|
165 153 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
166 154 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
|
167 155 | e,
|
168 156 | )
|
169 157 | },
|
170 158 | );
|
171 - | StreamingBlobOperationInputFuture {
|
159 + | ConstrainedShapesOnlyInOutputOperationInputFuture {
|
172 160 | inner: Box::pin(fut),
|
173 161 | }
|
174 162 | }
|
175 163 | }
|
176 164 | impl
|
177 165 | ::aws_smithy_http_server::response::IntoResponse<
|
178 166 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
179 - | > for crate::output::StreamingBlobOperationOutput
|
167 + | > for crate::output::ConstrainedShapesOnlyInOutputOperationOutput
|
180 168 | {
|
181 169 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
182 - | match crate::protocol_serde::shape_streaming_blob_operation::ser_streaming_blob_operation_http_response(self) {
|
170 + | match crate::protocol_serde::shape_constrained_shapes_only_in_output_operation::ser_constrained_shapes_only_in_output_operation_http_response(self) {
|
183 171 | Ok(response) => response,
|
184 172 | Err(e) => {
|
185 173 | ::tracing::error!(error = %e, "failed to serialize response");
|
186 174 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
187 175 | }
|
188 176 | }
|
189 177 | }
|
190 178 | }
|
191 179 |
|
192 180 | ::pin_project_lite::pin_project! {
|
193 181 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
194 - | /// [`NonStreamingBlobOperationInput`](crate::input::NonStreamingBlobOperationInput) using modelled bindings.
|
195 - | pub struct NonStreamingBlobOperationInputFuture {
|
196 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::NonStreamingBlobOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
182 + | /// [`ConstrainedHttpBoundShapesOperationInput`](crate::input::ConstrainedHttpBoundShapesOperationInput) using modelled bindings.
|
183 + | pub struct ConstrainedHttpBoundShapesOperationInputFuture {
|
184 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ConstrainedHttpBoundShapesOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
197 185 | }
|
198 186 | }
|
199 187 |
|
200 - | impl std::future::Future for NonStreamingBlobOperationInputFuture {
|
188 + | impl std::future::Future for ConstrainedHttpBoundShapesOperationInputFuture {
|
201 189 | type Output = Result<
|
202 - | crate::input::NonStreamingBlobOperationInput,
|
190 + | crate::input::ConstrainedHttpBoundShapesOperationInput,
|
203 191 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
|
204 192 | >;
|
205 193 |
|
206 194 | fn poll(
|
207 195 | self: std::pin::Pin<&mut Self>,
|
208 196 | cx: &mut std::task::Context<'_>,
|
209 197 | ) -> std::task::Poll<Self::Output> {
|
210 198 | let this = self.project();
|
211 199 | this.inner.as_mut().poll(cx)
|
212 200 | }
|
213 201 | }
|
214 202 |
|
215 203 | impl<B>
|
216 204 | ::aws_smithy_http_server::request::FromRequest<
|
217 205 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
218 206 | B,
|
219 - | > for crate::input::NonStreamingBlobOperationInput
|
207 + | > for crate::input::ConstrainedHttpBoundShapesOperationInput
|
220 208 | where
|
221 209 | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
222 210 | B: 'static,
|
223 211 |
|
224 212 | B::Data: Send,
|
225 213 | ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
|
226 214 | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
227 215 | {
|
228 216 | type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
|
229 - | type Future = NonStreamingBlobOperationInputFuture;
|
217 + | type Future = ConstrainedHttpBoundShapesOperationInputFuture;
|
230 218 |
|
231 219 | fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
|
232 220 | let fut = async move {
|
233 - | crate::protocol_serde::shape_non_streaming_blob_operation::de_non_streaming_blob_operation_http_request(request)
|
221 + | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
222 + | request.headers(),
|
223 + | &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
|
224 + | ) {
|
225 + | return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
|
226 + | }
|
227 + | crate::protocol_serde::shape_constrained_http_bound_shapes_operation::de_constrained_http_bound_shapes_operation_http_request(request)
|
234 228 | .await
|
235 229 | };
|
236 230 | use ::futures_util::future::TryFutureExt;
|
237 231 | let fut = fut.map_err(
|
238 232 | |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
|
239 233 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
240 234 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
|
241 235 | e,
|
242 236 | )
|
243 237 | },
|
244 238 | );
|
245 - | NonStreamingBlobOperationInputFuture {
|
239 + | ConstrainedHttpBoundShapesOperationInputFuture {
|
246 240 | inner: Box::pin(fut),
|
247 241 | }
|
248 242 | }
|
249 243 | }
|
250 244 | impl
|
251 245 | ::aws_smithy_http_server::response::IntoResponse<
|
252 246 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
253 - | > for crate::output::NonStreamingBlobOperationOutput
|
247 + | > for crate::output::ConstrainedHttpBoundShapesOperationOutput
|
254 248 | {
|
255 249 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
256 - | match crate::protocol_serde::shape_non_streaming_blob_operation::ser_non_streaming_blob_operation_http_response(self) {
|
250 + | match crate::protocol_serde::shape_constrained_http_bound_shapes_operation::ser_constrained_http_bound_shapes_operation_http_response(self) {
|
257 251 | Ok(response) => response,
|
258 252 | Err(e) => {
|
259 253 | ::tracing::error!(error = %e, "failed to serialize response");
|
260 254 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
261 255 | }
|
262 256 | }
|
263 257 | }
|
264 258 | }
|
259 + | impl
|
260 + | ::aws_smithy_http_server::response::IntoResponse<
|
261 + | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
262 + | > for crate::error::ConstrainedHttpBoundShapesOperationError
|
263 + | {
|
264 + | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
265 + | match crate::protocol_serde::shape_constrained_http_bound_shapes_operation::ser_constrained_http_bound_shapes_operation_http_error(&self) {
|
266 + | Ok(mut response) => {
|
267 + | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
268 + | response
|
269 + | },
|
270 + | Err(e) => {
|
271 + | ::tracing::error!(error = %e, "failed to serialize response");
|
272 + | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
273 + | }
|
274 + | }
|
275 + | }
|
276 + | }
|
265 277 |
|
266 278 | ::pin_project_lite::pin_project! {
|
267 279 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
268 - | /// [`QueryParamsTargetingMapOfEnumStringOperationInput`](crate::input::QueryParamsTargetingMapOfEnumStringOperationInput) using modelled bindings.
|
269 - | pub struct QueryParamsTargetingMapOfEnumStringOperationInputFuture {
|
270 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryParamsTargetingMapOfEnumStringOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
280 + | /// [`ConstrainedHttpPayloadBoundShapeOperationInput`](crate::input::ConstrainedHttpPayloadBoundShapeOperationInput) using modelled bindings.
|
281 + | pub struct ConstrainedHttpPayloadBoundShapeOperationInputFuture {
|
282 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ConstrainedHttpPayloadBoundShapeOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
271 283 | }
|
272 284 | }
|
273 285 |
|
274 - | impl std::future::Future for QueryParamsTargetingMapOfEnumStringOperationInputFuture {
|
286 + | impl std::future::Future for ConstrainedHttpPayloadBoundShapeOperationInputFuture {
|
275 287 | type Output = Result<
|
276 - | crate::input::QueryParamsTargetingMapOfEnumStringOperationInput,
|
288 + | crate::input::ConstrainedHttpPayloadBoundShapeOperationInput,
|
277 289 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
|
278 290 | >;
|
279 291 |
|
280 292 | fn poll(
|
281 293 | self: std::pin::Pin<&mut Self>,
|
282 294 | cx: &mut std::task::Context<'_>,
|
283 295 | ) -> std::task::Poll<Self::Output> {
|
284 296 | let this = self.project();
|
285 297 | this.inner.as_mut().poll(cx)
|
286 298 | }
|
287 299 | }
|
288 300 |
|
289 301 | impl<B>
|
290 302 | ::aws_smithy_http_server::request::FromRequest<
|
291 303 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
292 304 | B,
|
293 - | > for crate::input::QueryParamsTargetingMapOfEnumStringOperationInput
|
305 + | > for crate::input::ConstrainedHttpPayloadBoundShapeOperationInput
|
294 306 | where
|
295 307 | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
296 308 | B: 'static,
|
297 309 |
|
298 310 | B::Data: Send,
|
299 311 | ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
|
300 312 | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
301 313 | {
|
302 314 | type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
|
303 - | type Future = QueryParamsTargetingMapOfEnumStringOperationInputFuture;
|
315 + | type Future = ConstrainedHttpPayloadBoundShapeOperationInputFuture;
|
304 316 |
|
305 317 | fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
|
306 318 | let fut = async move {
|
307 319 | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
308 320 | request.headers(),
|
309 321 | &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
|
310 322 | ) {
|
311 323 | return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
|
312 324 | }
|
313 - | crate::protocol_serde::shape_query_params_targeting_map_of_enum_string_operation::de_query_params_targeting_map_of_enum_string_operation_http_request(request)
|
325 + | crate::protocol_serde::shape_constrained_http_payload_bound_shape_operation::de_constrained_http_payload_bound_shape_operation_http_request(request)
|
314 326 | .await
|
315 327 | };
|
316 328 | use ::futures_util::future::TryFutureExt;
|
317 329 | let fut = fut.map_err(
|
318 330 | |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
|
319 331 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
320 332 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
|
321 333 | e,
|
322 334 | )
|
323 335 | },
|
324 336 | );
|
325 - | QueryParamsTargetingMapOfEnumStringOperationInputFuture {
|
337 + | ConstrainedHttpPayloadBoundShapeOperationInputFuture {
|
326 338 | inner: Box::pin(fut),
|
327 339 | }
|
328 340 | }
|
329 341 | }
|
330 342 | impl
|
331 343 | ::aws_smithy_http_server::response::IntoResponse<
|
332 344 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
333 - | > for crate::output::QueryParamsTargetingMapOfEnumStringOperationOutput
|
345 + | > for crate::output::ConstrainedHttpPayloadBoundShapeOperationOutput
|
334 346 | {
|
335 347 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
336 - | match crate::protocol_serde::shape_query_params_targeting_map_of_enum_string_operation::ser_query_params_targeting_map_of_enum_string_operation_http_response(self) {
|
348 + | match crate::protocol_serde::shape_constrained_http_payload_bound_shape_operation::ser_constrained_http_payload_bound_shape_operation_http_response(self) {
|
337 349 | Ok(response) => response,
|
338 350 | Err(e) => {
|
339 351 | ::tracing::error!(error = %e, "failed to serialize response");
|
340 352 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
341 353 | }
|
342 354 | }
|
343 355 | }
|
344 356 | }
|
345 357 | impl
|
346 358 | ::aws_smithy_http_server::response::IntoResponse<
|
347 359 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
348 - | > for crate::error::QueryParamsTargetingMapOfEnumStringOperationError
|
360 + | > for crate::error::ConstrainedHttpPayloadBoundShapeOperationError
|
349 361 | {
|
350 362 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
351 - | match crate::protocol_serde::shape_query_params_targeting_map_of_enum_string_operation::ser_query_params_targeting_map_of_enum_string_operation_http_error(&self) {
|
363 + | match crate::protocol_serde::shape_constrained_http_payload_bound_shape_operation::ser_constrained_http_payload_bound_shape_operation_http_error(&self) {
|
352 364 | Ok(mut response) => {
|
353 365 | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
354 366 | response
|
355 367 | },
|
356 368 | Err(e) => {
|
357 369 | ::tracing::error!(error = %e, "failed to serialize response");
|
358 370 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
359 371 | }
|
360 372 | }
|
361 373 | }
|
362 374 | }
|
363 375 |
|
364 376 | ::pin_project_lite::pin_project! {
|
365 377 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
366 - | /// [`HttpPrefixHeadersTargetingLengthMapOperationInput`](crate::input::HttpPrefixHeadersTargetingLengthMapOperationInput) using modelled bindings.
|
367 - | pub struct HttpPrefixHeadersTargetingLengthMapOperationInputFuture {
|
368 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::HttpPrefixHeadersTargetingLengthMapOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
378 + | /// [`ConstrainedRecursiveShapesOperationInput`](crate::input::ConstrainedRecursiveShapesOperationInput) using modelled bindings.
|
379 + | pub struct ConstrainedRecursiveShapesOperationInputFuture {
|
380 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ConstrainedRecursiveShapesOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
369 381 | }
|
370 382 | }
|
371 383 |
|
372 - | impl std::future::Future for HttpPrefixHeadersTargetingLengthMapOperationInputFuture {
|
384 + | impl std::future::Future for ConstrainedRecursiveShapesOperationInputFuture {
|
373 385 | type Output = Result<
|
374 - | crate::input::HttpPrefixHeadersTargetingLengthMapOperationInput,
|
386 + | crate::input::ConstrainedRecursiveShapesOperationInput,
|
375 387 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
|
376 388 | >;
|
377 389 |
|
378 390 | fn poll(
|
379 391 | self: std::pin::Pin<&mut Self>,
|
380 392 | cx: &mut std::task::Context<'_>,
|
381 393 | ) -> std::task::Poll<Self::Output> {
|
382 394 | let this = self.project();
|
383 395 | this.inner.as_mut().poll(cx)
|
384 396 | }
|
385 397 | }
|
386 398 |
|
387 399 | impl<B>
|
388 400 | ::aws_smithy_http_server::request::FromRequest<
|
389 401 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
390 402 | B,
|
391 - | > for crate::input::HttpPrefixHeadersTargetingLengthMapOperationInput
|
403 + | > for crate::input::ConstrainedRecursiveShapesOperationInput
|
392 404 | where
|
393 405 | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
394 406 | B: 'static,
|
395 407 |
|
396 408 | B::Data: Send,
|
397 409 | ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
|
398 410 | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
399 411 | {
|
400 412 | type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
|
401 - | type Future = HttpPrefixHeadersTargetingLengthMapOperationInputFuture;
|
413 + | type Future = ConstrainedRecursiveShapesOperationInputFuture;
|
402 414 |
|
403 415 | fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
|
404 416 | let fut = async move {
|
405 417 | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
406 418 | request.headers(),
|
407 419 | &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
|
408 420 | ) {
|
409 421 | return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
|
410 422 | }
|
411 - | crate::protocol_serde::shape_http_prefix_headers_targeting_length_map_operation::de_http_prefix_headers_targeting_length_map_operation_http_request(request)
|
423 + | crate::protocol_serde::shape_constrained_recursive_shapes_operation::de_constrained_recursive_shapes_operation_http_request(request)
|
412 424 | .await
|
413 425 | };
|
414 426 | use ::futures_util::future::TryFutureExt;
|
415 427 | let fut = fut.map_err(
|
416 428 | |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
|
417 429 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
418 430 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
|
419 431 | e,
|
420 432 | )
|
421 433 | },
|
422 434 | );
|
423 - | HttpPrefixHeadersTargetingLengthMapOperationInputFuture {
|
435 + | ConstrainedRecursiveShapesOperationInputFuture {
|
424 436 | inner: Box::pin(fut),
|
425 437 | }
|
426 438 | }
|
427 439 | }
|
428 440 | impl
|
429 441 | ::aws_smithy_http_server::response::IntoResponse<
|
430 442 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
431 - | > for crate::output::HttpPrefixHeadersTargetingLengthMapOperationOutput
|
443 + | > for crate::output::ConstrainedRecursiveShapesOperationOutput
|
432 444 | {
|
433 445 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
434 - | match crate::protocol_serde::shape_http_prefix_headers_targeting_length_map_operation::ser_http_prefix_headers_targeting_length_map_operation_http_response(self) {
|
446 + | match crate::protocol_serde::shape_constrained_recursive_shapes_operation::ser_constrained_recursive_shapes_operation_http_response(self) {
|
435 447 | Ok(response) => response,
|
436 448 | Err(e) => {
|
437 449 | ::tracing::error!(error = %e, "failed to serialize response");
|
438 450 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
439 451 | }
|
440 452 | }
|
441 453 | }
|
442 454 | }
|
443 455 | impl
|
444 456 | ::aws_smithy_http_server::response::IntoResponse<
|
445 457 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
446 - | > for crate::error::HttpPrefixHeadersTargetingLengthMapOperationError
|
458 + | > for crate::error::ConstrainedRecursiveShapesOperationError
|
447 459 | {
|
448 460 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
449 - | match crate::protocol_serde::shape_http_prefix_headers_targeting_length_map_operation::ser_http_prefix_headers_targeting_length_map_operation_http_error(&self) {
|
461 + | match crate::protocol_serde::shape_constrained_recursive_shapes_operation::ser_constrained_recursive_shapes_operation_http_error(&self) {
|
450 462 | Ok(mut response) => {
|
451 463 | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
452 464 | response
|
453 465 | },
|
454 466 | Err(e) => {
|
455 467 | ::tracing::error!(error = %e, "failed to serialize response");
|
456 468 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
457 469 | }
|
458 470 | }
|
459 471 | }
|
460 472 | }
|
461 473 |
|
462 474 | ::pin_project_lite::pin_project! {
|
463 475 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
464 - | /// [`QueryParamsTargetingMapOfListOfLengthPatternStringOperationInput`](crate::input::QueryParamsTargetingMapOfListOfLengthPatternStringOperationInput) using modelled bindings.
|
465 - | pub struct QueryParamsTargetingMapOfListOfLengthPatternStringOperationInputFuture {
|
466 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryParamsTargetingMapOfListOfLengthPatternStringOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
476 + | /// [`QueryParamsTargetingLengthMapOperationInput`](crate::input::QueryParamsTargetingLengthMapOperationInput) using modelled bindings.
|
477 + | pub struct QueryParamsTargetingLengthMapOperationInputFuture {
|
478 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryParamsTargetingLengthMapOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
467 479 | }
|
468 480 | }
|
469 481 |
|
470 - | impl std::future::Future
|
471 - | for QueryParamsTargetingMapOfListOfLengthPatternStringOperationInputFuture
|
472 - | {
|
482 + | impl std::future::Future for QueryParamsTargetingLengthMapOperationInputFuture {
|
473 483 | type Output = Result<
|
474 - | crate::input::QueryParamsTargetingMapOfListOfLengthPatternStringOperationInput,
|
484 + | crate::input::QueryParamsTargetingLengthMapOperationInput,
|
475 485 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
|
476 486 | >;
|
477 487 |
|
478 488 | fn poll(
|
479 489 | self: std::pin::Pin<&mut Self>,
|
480 490 | cx: &mut std::task::Context<'_>,
|
481 491 | ) -> std::task::Poll<Self::Output> {
|
482 492 | let this = self.project();
|
483 493 | this.inner.as_mut().poll(cx)
|
484 494 | }
|
485 495 | }
|
486 496 |
|
487 497 | impl<B>
|
488 498 | ::aws_smithy_http_server::request::FromRequest<
|
489 499 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
490 500 | B,
|
491 - | > for crate::input::QueryParamsTargetingMapOfListOfLengthPatternStringOperationInput
|
501 + | > for crate::input::QueryParamsTargetingLengthMapOperationInput
|
492 502 | where
|
493 503 | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
494 504 | B: 'static,
|
495 505 |
|
496 506 | B::Data: Send,
|
497 507 | ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
|
498 508 | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
499 509 | {
|
500 510 | type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
|
501 - | type Future = QueryParamsTargetingMapOfListOfLengthPatternStringOperationInputFuture;
|
511 + | type Future = QueryParamsTargetingLengthMapOperationInputFuture;
|
502 512 |
|
503 513 | fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
|
504 514 | let fut = async move {
|
505 515 | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
506 516 | request.headers(),
|
507 517 | &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
|
508 518 | ) {
|
509 519 | return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
|
510 520 | }
|
511 - | crate::protocol_serde::shape_query_params_targeting_map_of_list_of_length_pattern_string_operation::de_query_params_targeting_map_of_list_of_length_pattern_string_operation_http_request(request)
|
521 + | crate::protocol_serde::shape_query_params_targeting_length_map_operation::de_query_params_targeting_length_map_operation_http_request(request)
|
512 522 | .await
|
513 523 | };
|
514 524 | use ::futures_util::future::TryFutureExt;
|
515 525 | let fut = fut.map_err(
|
516 526 | |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
|
517 527 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
518 528 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
|
519 529 | e,
|
520 530 | )
|
521 531 | },
|
522 532 | );
|
523 - | QueryParamsTargetingMapOfListOfLengthPatternStringOperationInputFuture {
|
533 + | QueryParamsTargetingLengthMapOperationInputFuture {
|
524 534 | inner: Box::pin(fut),
|
525 535 | }
|
526 536 | }
|
527 537 | }
|
528 538 | impl
|
529 539 | ::aws_smithy_http_server::response::IntoResponse<
|
530 540 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
531 - | > for crate::output::QueryParamsTargetingMapOfListOfLengthPatternStringOperationOutput
|
541 + | > for crate::output::QueryParamsTargetingLengthMapOperationOutput
|
532 542 | {
|
533 543 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
534 - | match crate::protocol_serde::shape_query_params_targeting_map_of_list_of_length_pattern_string_operation::ser_query_params_targeting_map_of_list_of_length_pattern_string_operation_http_response(self) {
|
544 + | match crate::protocol_serde::shape_query_params_targeting_length_map_operation::ser_query_params_targeting_length_map_operation_http_response(self) {
|
535 545 | Ok(response) => response,
|
536 546 | Err(e) => {
|
537 547 | ::tracing::error!(error = %e, "failed to serialize response");
|
538 548 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
539 549 | }
|
540 550 | }
|
541 551 | }
|
542 552 | }
|
543 553 | impl
|
544 554 | ::aws_smithy_http_server::response::IntoResponse<
|
545 555 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
546 - | > for crate::error::QueryParamsTargetingMapOfListOfLengthPatternStringOperationError
|
556 + | > for crate::error::QueryParamsTargetingLengthMapOperationError
|
547 557 | {
|
548 558 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
549 - | match crate::protocol_serde::shape_query_params_targeting_map_of_list_of_length_pattern_string_operation::ser_query_params_targeting_map_of_list_of_length_pattern_string_operation_http_error(&self) {
|
559 + | match crate::protocol_serde::shape_query_params_targeting_length_map_operation::ser_query_params_targeting_length_map_operation_http_error(&self) {
|
550 560 | Ok(mut response) => {
|
551 561 | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
552 562 | response
|
553 563 | },
|
554 564 | Err(e) => {
|
555 565 | ::tracing::error!(error = %e, "failed to serialize response");
|
556 566 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
557 567 | }
|
558 568 | }
|
559 569 | }
|
560 570 | }
|
561 571 |
|
562 572 | ::pin_project_lite::pin_project! {
|
563 573 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
564 - | /// [`QueryParamsTargetingMapOfLengthPatternStringOperationInput`](crate::input::QueryParamsTargetingMapOfLengthPatternStringOperationInput) using modelled bindings.
|
565 - | pub struct QueryParamsTargetingMapOfLengthPatternStringOperationInputFuture {
|
566 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryParamsTargetingMapOfLengthPatternStringOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
574 + | /// [`QueryParamsTargetingMapOfLengthStringOperationInput`](crate::input::QueryParamsTargetingMapOfLengthStringOperationInput) using modelled bindings.
|
575 + | pub struct QueryParamsTargetingMapOfLengthStringOperationInputFuture {
|
576 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryParamsTargetingMapOfLengthStringOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
567 577 | }
|
568 578 | }
|
569 579 |
|
570 - | impl std::future::Future for QueryParamsTargetingMapOfLengthPatternStringOperationInputFuture {
|
580 + | impl std::future::Future for QueryParamsTargetingMapOfLengthStringOperationInputFuture {
|
571 581 | type Output = Result<
|
572 - | crate::input::QueryParamsTargetingMapOfLengthPatternStringOperationInput,
|
582 + | crate::input::QueryParamsTargetingMapOfLengthStringOperationInput,
|
573 583 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
|
574 584 | >;
|
575 585 |
|
576 586 | fn poll(
|
577 587 | self: std::pin::Pin<&mut Self>,
|
578 588 | cx: &mut std::task::Context<'_>,
|
579 589 | ) -> std::task::Poll<Self::Output> {
|
580 590 | let this = self.project();
|
581 591 | this.inner.as_mut().poll(cx)
|
582 592 | }
|
583 593 | }
|
584 594 |
|
585 595 | impl<B>
|
586 596 | ::aws_smithy_http_server::request::FromRequest<
|
587 597 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
588 598 | B,
|
589 - | > for crate::input::QueryParamsTargetingMapOfLengthPatternStringOperationInput
|
599 + | > for crate::input::QueryParamsTargetingMapOfLengthStringOperationInput
|
590 600 | where
|
591 601 | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
592 602 | B: 'static,
|
593 603 |
|
594 604 | B::Data: Send,
|
595 605 | ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
|
596 606 | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
597 607 | {
|
598 608 | type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
|
599 - | type Future = QueryParamsTargetingMapOfLengthPatternStringOperationInputFuture;
|
609 + | type Future = QueryParamsTargetingMapOfLengthStringOperationInputFuture;
|
600 610 |
|
601 611 | fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
|
602 612 | let fut = async move {
|
603 613 | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
604 614 | request.headers(),
|
605 615 | &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
|
606 616 | ) {
|
607 617 | return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
|
608 618 | }
|
609 - | crate::protocol_serde::shape_query_params_targeting_map_of_length_pattern_string_operation::de_query_params_targeting_map_of_length_pattern_string_operation_http_request(request)
|
619 + | crate::protocol_serde::shape_query_params_targeting_map_of_length_string_operation::de_query_params_targeting_map_of_length_string_operation_http_request(request)
|
610 620 | .await
|
611 621 | };
|
612 622 | use ::futures_util::future::TryFutureExt;
|
613 623 | let fut = fut.map_err(
|
614 624 | |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
|
615 625 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
616 626 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
|
617 627 | e,
|
618 628 | )
|
619 629 | },
|
620 630 | );
|
621 - | QueryParamsTargetingMapOfLengthPatternStringOperationInputFuture {
|
631 + | QueryParamsTargetingMapOfLengthStringOperationInputFuture {
|
622 632 | inner: Box::pin(fut),
|
623 633 | }
|
624 634 | }
|
625 635 | }
|
626 636 | impl
|
627 637 | ::aws_smithy_http_server::response::IntoResponse<
|
628 638 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
629 - | > for crate::output::QueryParamsTargetingMapOfLengthPatternStringOperationOutput
|
639 + | > for crate::output::QueryParamsTargetingMapOfLengthStringOperationOutput
|
630 640 | {
|
631 641 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
632 - | match crate::protocol_serde::shape_query_params_targeting_map_of_length_pattern_string_operation::ser_query_params_targeting_map_of_length_pattern_string_operation_http_response(self) {
|
642 + | match crate::protocol_serde::shape_query_params_targeting_map_of_length_string_operation::ser_query_params_targeting_map_of_length_string_operation_http_response(self) {
|
633 643 | Ok(response) => response,
|
634 644 | Err(e) => {
|
635 645 | ::tracing::error!(error = %e, "failed to serialize response");
|
636 646 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
637 647 | }
|
638 648 | }
|
639 649 | }
|
640 650 | }
|
641 651 | impl
|
642 652 | ::aws_smithy_http_server::response::IntoResponse<
|
643 653 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
644 - | > for crate::error::QueryParamsTargetingMapOfLengthPatternStringOperationError
|
654 + | > for crate::error::QueryParamsTargetingMapOfLengthStringOperationError
|
645 655 | {
|
646 656 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
647 - | match crate::protocol_serde::shape_query_params_targeting_map_of_length_pattern_string_operation::ser_query_params_targeting_map_of_length_pattern_string_operation_http_error(&self) {
|
657 + | match crate::protocol_serde::shape_query_params_targeting_map_of_length_string_operation::ser_query_params_targeting_map_of_length_string_operation_http_error(&self) {
|
648 658 | Ok(mut response) => {
|
649 659 | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
650 660 | response
|
651 661 | },
|
652 662 | Err(e) => {
|
653 663 | ::tracing::error!(error = %e, "failed to serialize response");
|
654 664 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
655 665 | }
|
656 666 | }
|
657 667 | }
|
658 668 | }
|
659 669 |
|
660 670 | ::pin_project_lite::pin_project! {
|
661 671 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
662 - | /// [`QueryParamsTargetingMapOfListOfPatternStringOperationInput`](crate::input::QueryParamsTargetingMapOfListOfPatternStringOperationInput) using modelled bindings.
|
663 - | pub struct QueryParamsTargetingMapOfListOfPatternStringOperationInputFuture {
|
664 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryParamsTargetingMapOfListOfPatternStringOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
672 + | /// [`QueryParamsTargetingMapOfListOfLengthStringOperationInput`](crate::input::QueryParamsTargetingMapOfListOfLengthStringOperationInput) using modelled bindings.
|
673 + | pub struct QueryParamsTargetingMapOfListOfLengthStringOperationInputFuture {
|
674 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryParamsTargetingMapOfListOfLengthStringOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
665 675 | }
|
666 676 | }
|
667 677 |
|
668 - | impl std::future::Future for QueryParamsTargetingMapOfListOfPatternStringOperationInputFuture {
|
678 + | impl std::future::Future for QueryParamsTargetingMapOfListOfLengthStringOperationInputFuture {
|
669 679 | type Output = Result<
|
670 - | crate::input::QueryParamsTargetingMapOfListOfPatternStringOperationInput,
|
680 + | crate::input::QueryParamsTargetingMapOfListOfLengthStringOperationInput,
|
671 681 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
|
672 682 | >;
|
673 683 |
|
674 684 | fn poll(
|
675 685 | self: std::pin::Pin<&mut Self>,
|
676 686 | cx: &mut std::task::Context<'_>,
|
677 687 | ) -> std::task::Poll<Self::Output> {
|
678 688 | let this = self.project();
|
679 689 | this.inner.as_mut().poll(cx)
|
680 690 | }
|
681 691 | }
|
682 692 |
|
683 693 | impl<B>
|
684 694 | ::aws_smithy_http_server::request::FromRequest<
|
685 695 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
686 696 | B,
|
687 - | > for crate::input::QueryParamsTargetingMapOfListOfPatternStringOperationInput
|
697 + | > for crate::input::QueryParamsTargetingMapOfListOfLengthStringOperationInput
|
688 698 | where
|
689 699 | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
690 700 | B: 'static,
|
691 701 |
|
692 702 | B::Data: Send,
|
693 703 | ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
|
694 704 | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
695 705 | {
|
696 706 | type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
|
697 - | type Future = QueryParamsTargetingMapOfListOfPatternStringOperationInputFuture;
|
707 + | type Future = QueryParamsTargetingMapOfListOfLengthStringOperationInputFuture;
|
698 708 |
|
699 709 | fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
|
700 710 | let fut = async move {
|
701 711 | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
702 712 | request.headers(),
|
703 713 | &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
|
704 714 | ) {
|
705 715 | return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
|
706 716 | }
|
707 - | crate::protocol_serde::shape_query_params_targeting_map_of_list_of_pattern_string_operation::de_query_params_targeting_map_of_list_of_pattern_string_operation_http_request(request)
|
717 + | crate::protocol_serde::shape_query_params_targeting_map_of_list_of_length_string_operation::de_query_params_targeting_map_of_list_of_length_string_operation_http_request(request)
|
708 718 | .await
|
709 719 | };
|
710 720 | use ::futures_util::future::TryFutureExt;
|
711 721 | let fut = fut.map_err(
|
712 722 | |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
|
713 723 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
714 724 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
|
715 725 | e,
|
716 726 | )
|
717 727 | },
|
718 728 | );
|
719 - | QueryParamsTargetingMapOfListOfPatternStringOperationInputFuture {
|
729 + | QueryParamsTargetingMapOfListOfLengthStringOperationInputFuture {
|
720 730 | inner: Box::pin(fut),
|
721 731 | }
|
722 732 | }
|
723 733 | }
|
724 734 | impl
|
725 735 | ::aws_smithy_http_server::response::IntoResponse<
|
726 736 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
727 - | > for crate::output::QueryParamsTargetingMapOfListOfPatternStringOperationOutput
|
737 + | > for crate::output::QueryParamsTargetingMapOfListOfLengthStringOperationOutput
|
728 738 | {
|
729 739 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
730 - | match crate::protocol_serde::shape_query_params_targeting_map_of_list_of_pattern_string_operation::ser_query_params_targeting_map_of_list_of_pattern_string_operation_http_response(self) {
|
740 + | match crate::protocol_serde::shape_query_params_targeting_map_of_list_of_length_string_operation::ser_query_params_targeting_map_of_list_of_length_string_operation_http_response(self) {
|
731 741 | Ok(response) => response,
|
732 742 | Err(e) => {
|
733 743 | ::tracing::error!(error = %e, "failed to serialize response");
|
734 744 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
735 745 | }
|
736 746 | }
|
737 747 | }
|
738 748 | }
|
739 749 | impl
|
740 750 | ::aws_smithy_http_server::response::IntoResponse<
|
741 751 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
742 - | > for crate::error::QueryParamsTargetingMapOfListOfPatternStringOperationError
|
752 + | > for crate::error::QueryParamsTargetingMapOfListOfLengthStringOperationError
|
743 753 | {
|
744 754 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
745 - | match crate::protocol_serde::shape_query_params_targeting_map_of_list_of_pattern_string_operation::ser_query_params_targeting_map_of_list_of_pattern_string_operation_http_error(&self) {
|
755 + | match crate::protocol_serde::shape_query_params_targeting_map_of_list_of_length_string_operation::ser_query_params_targeting_map_of_list_of_length_string_operation_http_error(&self) {
|
746 756 | Ok(mut response) => {
|
747 757 | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
748 758 | response
|
749 759 | },
|
750 760 | Err(e) => {
|
751 761 | ::tracing::error!(error = %e, "failed to serialize response");
|
752 762 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
753 763 | }
|
754 764 | }
|
755 765 | }
|
756 766 | }
|
757 767 |
|
758 768 | ::pin_project_lite::pin_project! {
|
759 769 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
760 - | /// [`QueryParamsTargetingMapOfPatternStringOperationInput`](crate::input::QueryParamsTargetingMapOfPatternStringOperationInput) using modelled bindings.
|
761 - | pub struct QueryParamsTargetingMapOfPatternStringOperationInputFuture {
|
762 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryParamsTargetingMapOfPatternStringOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
770 + | /// [`QueryParamsTargetingMapOfSetOfLengthStringOperationInput`](crate::input::QueryParamsTargetingMapOfSetOfLengthStringOperationInput) using modelled bindings.
|
771 + | pub struct QueryParamsTargetingMapOfSetOfLengthStringOperationInputFuture {
|
772 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryParamsTargetingMapOfSetOfLengthStringOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
763 773 | }
|
764 774 | }
|
765 775 |
|
766 - | impl std::future::Future for QueryParamsTargetingMapOfPatternStringOperationInputFuture {
|
776 + | impl std::future::Future for QueryParamsTargetingMapOfSetOfLengthStringOperationInputFuture {
|
767 777 | type Output = Result<
|
768 - | crate::input::QueryParamsTargetingMapOfPatternStringOperationInput,
|
778 + | crate::input::QueryParamsTargetingMapOfSetOfLengthStringOperationInput,
|
769 779 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
|
770 780 | >;
|
771 781 |
|
772 782 | fn poll(
|
773 783 | self: std::pin::Pin<&mut Self>,
|
774 784 | cx: &mut std::task::Context<'_>,
|
775 785 | ) -> std::task::Poll<Self::Output> {
|
776 786 | let this = self.project();
|
777 787 | this.inner.as_mut().poll(cx)
|
778 788 | }
|
779 789 | }
|
780 790 |
|
781 791 | impl<B>
|
782 792 | ::aws_smithy_http_server::request::FromRequest<
|
783 793 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
784 794 | B,
|
785 - | > for crate::input::QueryParamsTargetingMapOfPatternStringOperationInput
|
795 + | > for crate::input::QueryParamsTargetingMapOfSetOfLengthStringOperationInput
|
786 796 | where
|
787 797 | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
788 798 | B: 'static,
|
789 799 |
|
790 800 | B::Data: Send,
|
791 801 | ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
|
792 802 | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
793 803 | {
|
794 804 | type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
|
795 - | type Future = QueryParamsTargetingMapOfPatternStringOperationInputFuture;
|
805 + | type Future = QueryParamsTargetingMapOfSetOfLengthStringOperationInputFuture;
|
796 806 |
|
797 807 | fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
|
798 808 | let fut = async move {
|
799 809 | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
800 810 | request.headers(),
|
801 811 | &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
|
802 812 | ) {
|
803 813 | return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
|
804 814 | }
|
805 - | crate::protocol_serde::shape_query_params_targeting_map_of_pattern_string_operation::de_query_params_targeting_map_of_pattern_string_operation_http_request(request)
|
815 + | crate::protocol_serde::shape_query_params_targeting_map_of_set_of_length_string_operation::de_query_params_targeting_map_of_set_of_length_string_operation_http_request(request)
|
806 816 | .await
|
807 817 | };
|
808 818 | use ::futures_util::future::TryFutureExt;
|
809 819 | let fut = fut.map_err(
|
810 820 | |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
|
811 821 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
812 822 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
|
813 823 | e,
|
814 824 | )
|
815 825 | },
|
816 826 | );
|
817 - | QueryParamsTargetingMapOfPatternStringOperationInputFuture {
|
827 + | QueryParamsTargetingMapOfSetOfLengthStringOperationInputFuture {
|
818 828 | inner: Box::pin(fut),
|
819 829 | }
|
820 830 | }
|
821 831 | }
|
822 832 | impl
|
823 833 | ::aws_smithy_http_server::response::IntoResponse<
|
824 834 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
825 - | > for crate::output::QueryParamsTargetingMapOfPatternStringOperationOutput
|
835 + | > for crate::output::QueryParamsTargetingMapOfSetOfLengthStringOperationOutput
|
826 836 | {
|
827 837 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
828 - | match crate::protocol_serde::shape_query_params_targeting_map_of_pattern_string_operation::ser_query_params_targeting_map_of_pattern_string_operation_http_response(self) {
|
838 + | match crate::protocol_serde::shape_query_params_targeting_map_of_set_of_length_string_operation::ser_query_params_targeting_map_of_set_of_length_string_operation_http_response(self) {
|
829 839 | Ok(response) => response,
|
830 840 | Err(e) => {
|
831 841 | ::tracing::error!(error = %e, "failed to serialize response");
|
832 842 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
833 843 | }
|
834 844 | }
|
835 845 | }
|
836 846 | }
|
837 847 | impl
|
838 848 | ::aws_smithy_http_server::response::IntoResponse<
|
839 849 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
840 - | > for crate::error::QueryParamsTargetingMapOfPatternStringOperationError
|
850 + | > for crate::error::QueryParamsTargetingMapOfSetOfLengthStringOperationError
|
841 851 | {
|
842 852 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
843 - | match crate::protocol_serde::shape_query_params_targeting_map_of_pattern_string_operation::ser_query_params_targeting_map_of_pattern_string_operation_http_error(&self) {
|
853 + | match crate::protocol_serde::shape_query_params_targeting_map_of_set_of_length_string_operation::ser_query_params_targeting_map_of_set_of_length_string_operation_http_error(&self) {
|
844 854 | Ok(mut response) => {
|
845 855 | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
846 856 | response
|
847 857 | },
|
848 858 | Err(e) => {
|
849 859 | ::tracing::error!(error = %e, "failed to serialize response");
|
850 860 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
851 861 | }
|
852 862 | }
|
853 863 | }
|
854 864 | }
|
855 865 |
|
856 866 | ::pin_project_lite::pin_project! {
|
857 867 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
858 - | /// [`QueryParamsTargetingMapOfListOfEnumStringOperationInput`](crate::input::QueryParamsTargetingMapOfListOfEnumStringOperationInput) using modelled bindings.
|
859 - | pub struct QueryParamsTargetingMapOfListOfEnumStringOperationInputFuture {
|
860 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryParamsTargetingMapOfListOfEnumStringOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
868 + | /// [`QueryParamsTargetingMapOfLengthListOfPatternStringOperationInput`](crate::input::QueryParamsTargetingMapOfLengthListOfPatternStringOperationInput) using modelled bindings.
|
869 + | pub struct QueryParamsTargetingMapOfLengthListOfPatternStringOperationInputFuture {
|
870 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryParamsTargetingMapOfLengthListOfPatternStringOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
861 871 | }
|
862 872 | }
|
863 873 |
|
864 - | impl std::future::Future for QueryParamsTargetingMapOfListOfEnumStringOperationInputFuture {
|
874 + | impl std::future::Future
|
875 + | for QueryParamsTargetingMapOfLengthListOfPatternStringOperationInputFuture
|
876 + | {
|
865 877 | type Output = Result<
|
866 - | crate::input::QueryParamsTargetingMapOfListOfEnumStringOperationInput,
|
878 + | crate::input::QueryParamsTargetingMapOfLengthListOfPatternStringOperationInput,
|
867 879 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
|
868 880 | >;
|
869 881 |
|
870 882 | fn poll(
|
871 883 | self: std::pin::Pin<&mut Self>,
|
872 884 | cx: &mut std::task::Context<'_>,
|
873 885 | ) -> std::task::Poll<Self::Output> {
|
874 886 | let this = self.project();
|
875 887 | this.inner.as_mut().poll(cx)
|
876 888 | }
|
877 889 | }
|
878 890 |
|
879 891 | impl<B>
|
880 892 | ::aws_smithy_http_server::request::FromRequest<
|
881 893 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
882 894 | B,
|
883 - | > for crate::input::QueryParamsTargetingMapOfListOfEnumStringOperationInput
|
895 + | > for crate::input::QueryParamsTargetingMapOfLengthListOfPatternStringOperationInput
|
884 896 | where
|
885 897 | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
886 898 | B: 'static,
|
887 899 |
|
888 900 | B::Data: Send,
|
889 901 | ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
|
890 902 | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
891 903 | {
|
892 904 | type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
|
893 - | type Future = QueryParamsTargetingMapOfListOfEnumStringOperationInputFuture;
|
905 + | type Future = QueryParamsTargetingMapOfLengthListOfPatternStringOperationInputFuture;
|
894 906 |
|
895 907 | fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
|
896 908 | let fut = async move {
|
897 909 | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
898 910 | request.headers(),
|
899 911 | &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
|
900 912 | ) {
|
901 913 | return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
|
902 914 | }
|
903 - | crate::protocol_serde::shape_query_params_targeting_map_of_list_of_enum_string_operation::de_query_params_targeting_map_of_list_of_enum_string_operation_http_request(request)
|
915 + | crate::protocol_serde::shape_query_params_targeting_map_of_length_list_of_pattern_string_operation::de_query_params_targeting_map_of_length_list_of_pattern_string_operation_http_request(request)
|
904 916 | .await
|
905 917 | };
|
906 918 | use ::futures_util::future::TryFutureExt;
|
907 919 | let fut = fut.map_err(
|
908 920 | |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
|
909 921 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
910 922 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
|
911 923 | e,
|
912 924 | )
|
913 925 | },
|
914 926 | );
|
915 - | QueryParamsTargetingMapOfListOfEnumStringOperationInputFuture {
|
927 + | QueryParamsTargetingMapOfLengthListOfPatternStringOperationInputFuture {
|
916 928 | inner: Box::pin(fut),
|
917 929 | }
|
918 930 | }
|
919 931 | }
|
920 932 | impl
|
921 933 | ::aws_smithy_http_server::response::IntoResponse<
|
922 934 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
923 - | > for crate::output::QueryParamsTargetingMapOfListOfEnumStringOperationOutput
|
935 + | > for crate::output::QueryParamsTargetingMapOfLengthListOfPatternStringOperationOutput
|
924 936 | {
|
925 937 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
926 - | match crate::protocol_serde::shape_query_params_targeting_map_of_list_of_enum_string_operation::ser_query_params_targeting_map_of_list_of_enum_string_operation_http_response(self) {
|
938 + | match crate::protocol_serde::shape_query_params_targeting_map_of_length_list_of_pattern_string_operation::ser_query_params_targeting_map_of_length_list_of_pattern_string_operation_http_response(self) {
|
927 939 | Ok(response) => response,
|
928 940 | Err(e) => {
|
929 941 | ::tracing::error!(error = %e, "failed to serialize response");
|
930 942 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
931 943 | }
|
932 944 | }
|
933 945 | }
|
934 946 | }
|
935 947 | impl
|
936 948 | ::aws_smithy_http_server::response::IntoResponse<
|
937 949 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
938 - | > for crate::error::QueryParamsTargetingMapOfListOfEnumStringOperationError
|
950 + | > for crate::error::QueryParamsTargetingMapOfLengthListOfPatternStringOperationError
|
939 951 | {
|
940 952 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
941 - | match crate::protocol_serde::shape_query_params_targeting_map_of_list_of_enum_string_operation::ser_query_params_targeting_map_of_list_of_enum_string_operation_http_error(&self) {
|
953 + | match crate::protocol_serde::shape_query_params_targeting_map_of_length_list_of_pattern_string_operation::ser_query_params_targeting_map_of_length_list_of_pattern_string_operation_http_error(&self) {
|
942 954 | Ok(mut response) => {
|
943 955 | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
944 956 | response
|
945 957 | },
|
946 958 | Err(e) => {
|
947 959 | ::tracing::error!(error = %e, "failed to serialize response");
|
948 960 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
949 961 | }
|
950 962 | }
|
951 963 | }
|
952 964 | }
|
953 965 |
|
954 966 | ::pin_project_lite::pin_project! {
|
955 967 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
956 - | /// [`QueryParamsTargetingMapOfLengthListOfPatternStringOperationInput`](crate::input::QueryParamsTargetingMapOfLengthListOfPatternStringOperationInput) using modelled bindings.
|
957 - | pub struct QueryParamsTargetingMapOfLengthListOfPatternStringOperationInputFuture {
|
958 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryParamsTargetingMapOfLengthListOfPatternStringOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
968 + | /// [`QueryParamsTargetingMapOfListOfEnumStringOperationInput`](crate::input::QueryParamsTargetingMapOfListOfEnumStringOperationInput) using modelled bindings.
|
969 + | pub struct QueryParamsTargetingMapOfListOfEnumStringOperationInputFuture {
|
970 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryParamsTargetingMapOfListOfEnumStringOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
959 971 | }
|
960 972 | }
|
961 973 |
|
962 - | impl std::future::Future
|
963 - | for QueryParamsTargetingMapOfLengthListOfPatternStringOperationInputFuture
|
964 - | {
|
974 + | impl std::future::Future for QueryParamsTargetingMapOfListOfEnumStringOperationInputFuture {
|
965 975 | type Output = Result<
|
966 - | crate::input::QueryParamsTargetingMapOfLengthListOfPatternStringOperationInput,
|
976 + | crate::input::QueryParamsTargetingMapOfListOfEnumStringOperationInput,
|
967 977 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
|
968 978 | >;
|
969 979 |
|
970 980 | fn poll(
|
971 981 | self: std::pin::Pin<&mut Self>,
|
972 982 | cx: &mut std::task::Context<'_>,
|
973 983 | ) -> std::task::Poll<Self::Output> {
|
974 984 | let this = self.project();
|
975 985 | this.inner.as_mut().poll(cx)
|
976 986 | }
|
977 987 | }
|
978 988 |
|
979 989 | impl<B>
|
980 990 | ::aws_smithy_http_server::request::FromRequest<
|
981 991 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
982 992 | B,
|
983 - | > for crate::input::QueryParamsTargetingMapOfLengthListOfPatternStringOperationInput
|
993 + | > for crate::input::QueryParamsTargetingMapOfListOfEnumStringOperationInput
|
984 994 | where
|
985 995 | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
986 996 | B: 'static,
|
987 997 |
|
988 998 | B::Data: Send,
|
989 999 | ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
|
990 1000 | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
991 1001 | {
|
992 1002 | type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
|
993 - | type Future = QueryParamsTargetingMapOfLengthListOfPatternStringOperationInputFuture;
|
1003 + | type Future = QueryParamsTargetingMapOfListOfEnumStringOperationInputFuture;
|
994 1004 |
|
995 1005 | fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
|
996 1006 | let fut = async move {
|
997 1007 | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
998 1008 | request.headers(),
|
999 1009 | &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
|
1000 1010 | ) {
|
1001 1011 | return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
|
1002 1012 | }
|
1003 - | crate::protocol_serde::shape_query_params_targeting_map_of_length_list_of_pattern_string_operation::de_query_params_targeting_map_of_length_list_of_pattern_string_operation_http_request(request)
|
1013 + | crate::protocol_serde::shape_query_params_targeting_map_of_list_of_enum_string_operation::de_query_params_targeting_map_of_list_of_enum_string_operation_http_request(request)
|
1004 1014 | .await
|
1005 1015 | };
|
1006 1016 | use ::futures_util::future::TryFutureExt;
|
1007 1017 | let fut = fut.map_err(
|
1008 1018 | |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
|
1009 1019 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1010 1020 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
|
1011 1021 | e,
|
1012 1022 | )
|
1013 1023 | },
|
1014 1024 | );
|
1015 - | QueryParamsTargetingMapOfLengthListOfPatternStringOperationInputFuture {
|
1025 + | QueryParamsTargetingMapOfListOfEnumStringOperationInputFuture {
|
1016 1026 | inner: Box::pin(fut),
|
1017 1027 | }
|
1018 1028 | }
|
1019 1029 | }
|
1020 1030 | impl
|
1021 1031 | ::aws_smithy_http_server::response::IntoResponse<
|
1022 1032 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1023 - | > for crate::output::QueryParamsTargetingMapOfLengthListOfPatternStringOperationOutput
|
1033 + | > for crate::output::QueryParamsTargetingMapOfListOfEnumStringOperationOutput
|
1024 1034 | {
|
1025 1035 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1026 - | match crate::protocol_serde::shape_query_params_targeting_map_of_length_list_of_pattern_string_operation::ser_query_params_targeting_map_of_length_list_of_pattern_string_operation_http_response(self) {
|
1036 + | match crate::protocol_serde::shape_query_params_targeting_map_of_list_of_enum_string_operation::ser_query_params_targeting_map_of_list_of_enum_string_operation_http_response(self) {
|
1027 1037 | Ok(response) => response,
|
1028 1038 | Err(e) => {
|
1029 1039 | ::tracing::error!(error = %e, "failed to serialize response");
|
1030 1040 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
1031 1041 | }
|
1032 1042 | }
|
1033 1043 | }
|
1034 1044 | }
|
1035 1045 | impl
|
1036 1046 | ::aws_smithy_http_server::response::IntoResponse<
|
1037 1047 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1038 - | > for crate::error::QueryParamsTargetingMapOfLengthListOfPatternStringOperationError
|
1048 + | > for crate::error::QueryParamsTargetingMapOfListOfEnumStringOperationError
|
1039 1049 | {
|
1040 1050 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1041 - | match crate::protocol_serde::shape_query_params_targeting_map_of_length_list_of_pattern_string_operation::ser_query_params_targeting_map_of_length_list_of_pattern_string_operation_http_error(&self) {
|
1051 + | match crate::protocol_serde::shape_query_params_targeting_map_of_list_of_enum_string_operation::ser_query_params_targeting_map_of_list_of_enum_string_operation_http_error(&self) {
|
1042 1052 | Ok(mut response) => {
|
1043 1053 | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1044 1054 | response
|
1045 1055 | },
|
1046 1056 | Err(e) => {
|
1047 1057 | ::tracing::error!(error = %e, "failed to serialize response");
|
1048 1058 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
1049 1059 | }
|
1050 1060 | }
|
1051 1061 | }
|
1052 1062 | }
|
1053 1063 |
|
1054 1064 | ::pin_project_lite::pin_project! {
|
1055 1065 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
1056 - | /// [`QueryParamsTargetingMapOfSetOfLengthStringOperationInput`](crate::input::QueryParamsTargetingMapOfSetOfLengthStringOperationInput) using modelled bindings.
|
1057 - | pub struct QueryParamsTargetingMapOfSetOfLengthStringOperationInputFuture {
|
1058 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryParamsTargetingMapOfSetOfLengthStringOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
1066 + | /// [`QueryParamsTargetingMapOfPatternStringOperationInput`](crate::input::QueryParamsTargetingMapOfPatternStringOperationInput) using modelled bindings.
|
1067 + | pub struct QueryParamsTargetingMapOfPatternStringOperationInputFuture {
|
1068 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryParamsTargetingMapOfPatternStringOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
1059 1069 | }
|
1060 1070 | }
|
1061 1071 |
|
1062 - | impl std::future::Future for QueryParamsTargetingMapOfSetOfLengthStringOperationInputFuture {
|
1072 + | impl std::future::Future for QueryParamsTargetingMapOfPatternStringOperationInputFuture {
|
1063 1073 | type Output = Result<
|
1064 - | crate::input::QueryParamsTargetingMapOfSetOfLengthStringOperationInput,
|
1074 + | crate::input::QueryParamsTargetingMapOfPatternStringOperationInput,
|
1065 1075 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
|
1066 1076 | >;
|
1067 1077 |
|
1068 1078 | fn poll(
|
1069 1079 | self: std::pin::Pin<&mut Self>,
|
1070 1080 | cx: &mut std::task::Context<'_>,
|
1071 1081 | ) -> std::task::Poll<Self::Output> {
|
1072 1082 | let this = self.project();
|
1073 1083 | this.inner.as_mut().poll(cx)
|
1074 1084 | }
|
1075 1085 | }
|
1076 1086 |
|
1077 1087 | impl<B>
|
1078 1088 | ::aws_smithy_http_server::request::FromRequest<
|
1079 1089 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1080 1090 | B,
|
1081 - | > for crate::input::QueryParamsTargetingMapOfSetOfLengthStringOperationInput
|
1091 + | > for crate::input::QueryParamsTargetingMapOfPatternStringOperationInput
|
1082 1092 | where
|
1083 1093 | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
1084 1094 | B: 'static,
|
1085 1095 |
|
1086 1096 | B::Data: Send,
|
1087 1097 | ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
|
1088 1098 | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
1089 1099 | {
|
1090 1100 | type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
|
1091 - | type Future = QueryParamsTargetingMapOfSetOfLengthStringOperationInputFuture;
|
1101 + | type Future = QueryParamsTargetingMapOfPatternStringOperationInputFuture;
|
1092 1102 |
|
1093 1103 | fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
|
1094 1104 | let fut = async move {
|
1095 1105 | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
1096 1106 | request.headers(),
|
1097 1107 | &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
|
1098 1108 | ) {
|
1099 1109 | return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
|
1100 1110 | }
|
1101 - | crate::protocol_serde::shape_query_params_targeting_map_of_set_of_length_string_operation::de_query_params_targeting_map_of_set_of_length_string_operation_http_request(request)
|
1111 + | crate::protocol_serde::shape_query_params_targeting_map_of_pattern_string_operation::de_query_params_targeting_map_of_pattern_string_operation_http_request(request)
|
1102 1112 | .await
|
1103 1113 | };
|
1104 1114 | use ::futures_util::future::TryFutureExt;
|
1105 1115 | let fut = fut.map_err(
|
1106 1116 | |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
|
1107 1117 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1108 1118 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
|
1109 1119 | e,
|
1110 1120 | )
|
1111 1121 | },
|
1112 1122 | );
|
1113 - | QueryParamsTargetingMapOfSetOfLengthStringOperationInputFuture {
|
1123 + | QueryParamsTargetingMapOfPatternStringOperationInputFuture {
|
1114 1124 | inner: Box::pin(fut),
|
1115 1125 | }
|
1116 1126 | }
|
1117 1127 | }
|
1118 1128 | impl
|
1119 1129 | ::aws_smithy_http_server::response::IntoResponse<
|
1120 1130 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1121 - | > for crate::output::QueryParamsTargetingMapOfSetOfLengthStringOperationOutput
|
1131 + | > for crate::output::QueryParamsTargetingMapOfPatternStringOperationOutput
|
1122 1132 | {
|
1123 1133 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1124 - | match crate::protocol_serde::shape_query_params_targeting_map_of_set_of_length_string_operation::ser_query_params_targeting_map_of_set_of_length_string_operation_http_response(self) {
|
1134 + | match crate::protocol_serde::shape_query_params_targeting_map_of_pattern_string_operation::ser_query_params_targeting_map_of_pattern_string_operation_http_response(self) {
|
1125 1135 | Ok(response) => response,
|
1126 1136 | Err(e) => {
|
1127 1137 | ::tracing::error!(error = %e, "failed to serialize response");
|
1128 1138 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
1129 1139 | }
|
1130 1140 | }
|
1131 1141 | }
|
1132 1142 | }
|
1133 1143 | impl
|
1134 1144 | ::aws_smithy_http_server::response::IntoResponse<
|
1135 1145 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1136 - | > for crate::error::QueryParamsTargetingMapOfSetOfLengthStringOperationError
|
1146 + | > for crate::error::QueryParamsTargetingMapOfPatternStringOperationError
|
1137 1147 | {
|
1138 1148 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1139 - | match crate::protocol_serde::shape_query_params_targeting_map_of_set_of_length_string_operation::ser_query_params_targeting_map_of_set_of_length_string_operation_http_error(&self) {
|
1149 + | match crate::protocol_serde::shape_query_params_targeting_map_of_pattern_string_operation::ser_query_params_targeting_map_of_pattern_string_operation_http_error(&self) {
|
1140 1150 | Ok(mut response) => {
|
1141 1151 | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1142 1152 | response
|
1143 1153 | },
|
1144 1154 | Err(e) => {
|
1145 1155 | ::tracing::error!(error = %e, "failed to serialize response");
|
1146 1156 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
1147 1157 | }
|
1148 1158 | }
|
1149 1159 | }
|
1150 1160 | }
|
1151 1161 |
|
1152 1162 | ::pin_project_lite::pin_project! {
|
1153 1163 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
1154 - | /// [`QueryParamsTargetingMapOfListOfLengthStringOperationInput`](crate::input::QueryParamsTargetingMapOfListOfLengthStringOperationInput) using modelled bindings.
|
1155 - | pub struct QueryParamsTargetingMapOfListOfLengthStringOperationInputFuture {
|
1156 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryParamsTargetingMapOfListOfLengthStringOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
1164 + | /// [`QueryParamsTargetingMapOfListOfPatternStringOperationInput`](crate::input::QueryParamsTargetingMapOfListOfPatternStringOperationInput) using modelled bindings.
|
1165 + | pub struct QueryParamsTargetingMapOfListOfPatternStringOperationInputFuture {
|
1166 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryParamsTargetingMapOfListOfPatternStringOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
1157 1167 | }
|
1158 1168 | }
|
1159 1169 |
|
1160 - | impl std::future::Future for QueryParamsTargetingMapOfListOfLengthStringOperationInputFuture {
|
1170 + | impl std::future::Future for QueryParamsTargetingMapOfListOfPatternStringOperationInputFuture {
|
1161 1171 | type Output = Result<
|
1162 - | crate::input::QueryParamsTargetingMapOfListOfLengthStringOperationInput,
|
1172 + | crate::input::QueryParamsTargetingMapOfListOfPatternStringOperationInput,
|
1163 1173 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
|
1164 1174 | >;
|
1165 1175 |
|
1166 1176 | fn poll(
|
1167 1177 | self: std::pin::Pin<&mut Self>,
|
1168 1178 | cx: &mut std::task::Context<'_>,
|
1169 1179 | ) -> std::task::Poll<Self::Output> {
|
1170 1180 | let this = self.project();
|
1171 1181 | this.inner.as_mut().poll(cx)
|
1172 1182 | }
|
1173 1183 | }
|
1174 1184 |
|
1175 1185 | impl<B>
|
1176 1186 | ::aws_smithy_http_server::request::FromRequest<
|
1177 1187 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1178 1188 | B,
|
1179 - | > for crate::input::QueryParamsTargetingMapOfListOfLengthStringOperationInput
|
1189 + | > for crate::input::QueryParamsTargetingMapOfListOfPatternStringOperationInput
|
1180 1190 | where
|
1181 1191 | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
1182 1192 | B: 'static,
|
1183 1193 |
|
1184 1194 | B::Data: Send,
|
1185 1195 | ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
|
1186 1196 | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
1187 1197 | {
|
1188 1198 | type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
|
1189 - | type Future = QueryParamsTargetingMapOfListOfLengthStringOperationInputFuture;
|
1199 + | type Future = QueryParamsTargetingMapOfListOfPatternStringOperationInputFuture;
|
1190 1200 |
|
1191 1201 | fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
|
1192 1202 | let fut = async move {
|
1193 1203 | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
1194 1204 | request.headers(),
|
1195 1205 | &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
|
1196 1206 | ) {
|
1197 1207 | return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
|
1198 1208 | }
|
1199 - | crate::protocol_serde::shape_query_params_targeting_map_of_list_of_length_string_operation::de_query_params_targeting_map_of_list_of_length_string_operation_http_request(request)
|
1209 + | crate::protocol_serde::shape_query_params_targeting_map_of_list_of_pattern_string_operation::de_query_params_targeting_map_of_list_of_pattern_string_operation_http_request(request)
|
1200 1210 | .await
|
1201 1211 | };
|
1202 1212 | use ::futures_util::future::TryFutureExt;
|
1203 1213 | let fut = fut.map_err(
|
1204 1214 | |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
|
1205 1215 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1206 1216 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
|
1207 1217 | e,
|
1208 1218 | )
|
1209 1219 | },
|
1210 1220 | );
|
1211 - | QueryParamsTargetingMapOfListOfLengthStringOperationInputFuture {
|
1221 + | QueryParamsTargetingMapOfListOfPatternStringOperationInputFuture {
|
1212 1222 | inner: Box::pin(fut),
|
1213 1223 | }
|
1214 1224 | }
|
1215 1225 | }
|
1216 1226 | impl
|
1217 1227 | ::aws_smithy_http_server::response::IntoResponse<
|
1218 1228 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1219 - | > for crate::output::QueryParamsTargetingMapOfListOfLengthStringOperationOutput
|
1229 + | > for crate::output::QueryParamsTargetingMapOfListOfPatternStringOperationOutput
|
1220 1230 | {
|
1221 1231 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1222 - | match crate::protocol_serde::shape_query_params_targeting_map_of_list_of_length_string_operation::ser_query_params_targeting_map_of_list_of_length_string_operation_http_response(self) {
|
1232 + | match crate::protocol_serde::shape_query_params_targeting_map_of_list_of_pattern_string_operation::ser_query_params_targeting_map_of_list_of_pattern_string_operation_http_response(self) {
|
1223 1233 | Ok(response) => response,
|
1224 1234 | Err(e) => {
|
1225 1235 | ::tracing::error!(error = %e, "failed to serialize response");
|
1226 1236 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
1227 1237 | }
|
1228 1238 | }
|
1229 1239 | }
|
1230 1240 | }
|
1231 1241 | impl
|
1232 1242 | ::aws_smithy_http_server::response::IntoResponse<
|
1233 1243 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1234 - | > for crate::error::QueryParamsTargetingMapOfListOfLengthStringOperationError
|
1244 + | > for crate::error::QueryParamsTargetingMapOfListOfPatternStringOperationError
|
1235 1245 | {
|
1236 1246 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1237 - | match crate::protocol_serde::shape_query_params_targeting_map_of_list_of_length_string_operation::ser_query_params_targeting_map_of_list_of_length_string_operation_http_error(&self) {
|
1247 + | match crate::protocol_serde::shape_query_params_targeting_map_of_list_of_pattern_string_operation::ser_query_params_targeting_map_of_list_of_pattern_string_operation_http_error(&self) {
|
1238 1248 | Ok(mut response) => {
|
1239 1249 | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1240 1250 | response
|
1241 1251 | },
|
1242 1252 | Err(e) => {
|
1243 1253 | ::tracing::error!(error = %e, "failed to serialize response");
|
1244 1254 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
1245 1255 | }
|
1246 1256 | }
|
1247 1257 | }
|
1248 1258 | }
|
1249 1259 |
|
1250 1260 | ::pin_project_lite::pin_project! {
|
1251 1261 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
1252 - | /// [`QueryParamsTargetingMapOfLengthStringOperationInput`](crate::input::QueryParamsTargetingMapOfLengthStringOperationInput) using modelled bindings.
|
1253 - | pub struct QueryParamsTargetingMapOfLengthStringOperationInputFuture {
|
1254 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryParamsTargetingMapOfLengthStringOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
1262 + | /// [`QueryParamsTargetingMapOfLengthPatternStringOperationInput`](crate::input::QueryParamsTargetingMapOfLengthPatternStringOperationInput) using modelled bindings.
|
1263 + | pub struct QueryParamsTargetingMapOfLengthPatternStringOperationInputFuture {
|
1264 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryParamsTargetingMapOfLengthPatternStringOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
1255 1265 | }
|
1256 1266 | }
|
1257 1267 |
|
1258 - | impl std::future::Future for QueryParamsTargetingMapOfLengthStringOperationInputFuture {
|
1268 + | impl std::future::Future for QueryParamsTargetingMapOfLengthPatternStringOperationInputFuture {
|
1259 1269 | type Output = Result<
|
1260 - | crate::input::QueryParamsTargetingMapOfLengthStringOperationInput,
|
1270 + | crate::input::QueryParamsTargetingMapOfLengthPatternStringOperationInput,
|
1261 1271 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
|
1262 1272 | >;
|
1263 1273 |
|
1264 1274 | fn poll(
|
1265 1275 | self: std::pin::Pin<&mut Self>,
|
1266 1276 | cx: &mut std::task::Context<'_>,
|
1267 1277 | ) -> std::task::Poll<Self::Output> {
|
1268 1278 | let this = self.project();
|
1269 1279 | this.inner.as_mut().poll(cx)
|
1270 1280 | }
|
1271 1281 | }
|
1272 1282 |
|
1273 1283 | impl<B>
|
1274 1284 | ::aws_smithy_http_server::request::FromRequest<
|
1275 1285 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1276 1286 | B,
|
1277 - | > for crate::input::QueryParamsTargetingMapOfLengthStringOperationInput
|
1287 + | > for crate::input::QueryParamsTargetingMapOfLengthPatternStringOperationInput
|
1278 1288 | where
|
1279 1289 | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
1280 1290 | B: 'static,
|
1281 1291 |
|
1282 1292 | B::Data: Send,
|
1283 1293 | ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
|
1284 1294 | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
1285 1295 | {
|
1286 1296 | type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
|
1287 - | type Future = QueryParamsTargetingMapOfLengthStringOperationInputFuture;
|
1297 + | type Future = QueryParamsTargetingMapOfLengthPatternStringOperationInputFuture;
|
1288 1298 |
|
1289 1299 | fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
|
1290 1300 | let fut = async move {
|
1291 1301 | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
1292 1302 | request.headers(),
|
1293 1303 | &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
|
1294 1304 | ) {
|
1295 1305 | return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
|
1296 1306 | }
|
1297 - | crate::protocol_serde::shape_query_params_targeting_map_of_length_string_operation::de_query_params_targeting_map_of_length_string_operation_http_request(request)
|
1307 + | crate::protocol_serde::shape_query_params_targeting_map_of_length_pattern_string_operation::de_query_params_targeting_map_of_length_pattern_string_operation_http_request(request)
|
1298 1308 | .await
|
1299 1309 | };
|
1300 1310 | use ::futures_util::future::TryFutureExt;
|
1301 1311 | let fut = fut.map_err(
|
1302 1312 | |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
|
1303 1313 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1304 1314 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
|
1305 1315 | e,
|
1306 1316 | )
|
1307 1317 | },
|
1308 1318 | );
|
1309 - | QueryParamsTargetingMapOfLengthStringOperationInputFuture {
|
1319 + | QueryParamsTargetingMapOfLengthPatternStringOperationInputFuture {
|
1310 1320 | inner: Box::pin(fut),
|
1311 1321 | }
|
1312 1322 | }
|
1313 1323 | }
|
1314 1324 | impl
|
1315 1325 | ::aws_smithy_http_server::response::IntoResponse<
|
1316 1326 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1317 - | > for crate::output::QueryParamsTargetingMapOfLengthStringOperationOutput
|
1327 + | > for crate::output::QueryParamsTargetingMapOfLengthPatternStringOperationOutput
|
1318 1328 | {
|
1319 1329 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1320 - | match crate::protocol_serde::shape_query_params_targeting_map_of_length_string_operation::ser_query_params_targeting_map_of_length_string_operation_http_response(self) {
|
1330 + | match crate::protocol_serde::shape_query_params_targeting_map_of_length_pattern_string_operation::ser_query_params_targeting_map_of_length_pattern_string_operation_http_response(self) {
|
1321 1331 | Ok(response) => response,
|
1322 1332 | Err(e) => {
|
1323 1333 | ::tracing::error!(error = %e, "failed to serialize response");
|
1324 1334 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
1325 1335 | }
|
1326 1336 | }
|
1327 1337 | }
|
1328 1338 | }
|
1329 1339 | impl
|
1330 1340 | ::aws_smithy_http_server::response::IntoResponse<
|
1331 1341 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1332 - | > for crate::error::QueryParamsTargetingMapOfLengthStringOperationError
|
1342 + | > for crate::error::QueryParamsTargetingMapOfLengthPatternStringOperationError
|
1333 1343 | {
|
1334 1344 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1335 - | match crate::protocol_serde::shape_query_params_targeting_map_of_length_string_operation::ser_query_params_targeting_map_of_length_string_operation_http_error(&self) {
|
1345 + | match crate::protocol_serde::shape_query_params_targeting_map_of_length_pattern_string_operation::ser_query_params_targeting_map_of_length_pattern_string_operation_http_error(&self) {
|
1336 1346 | Ok(mut response) => {
|
1337 1347 | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1338 1348 | response
|
1339 1349 | },
|
1340 1350 | Err(e) => {
|
1341 1351 | ::tracing::error!(error = %e, "failed to serialize response");
|
1342 1352 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
1343 1353 | }
|
1344 1354 | }
|
1345 1355 | }
|
1346 1356 | }
|
1347 1357 |
|
1348 1358 | ::pin_project_lite::pin_project! {
|
1349 1359 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
1350 - | /// [`QueryParamsTargetingLengthMapOperationInput`](crate::input::QueryParamsTargetingLengthMapOperationInput) using modelled bindings.
|
1351 - | pub struct QueryParamsTargetingLengthMapOperationInputFuture {
|
1352 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryParamsTargetingLengthMapOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
1360 + | /// [`QueryParamsTargetingMapOfListOfLengthPatternStringOperationInput`](crate::input::QueryParamsTargetingMapOfListOfLengthPatternStringOperationInput) using modelled bindings.
|
1361 + | pub struct QueryParamsTargetingMapOfListOfLengthPatternStringOperationInputFuture {
|
1362 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryParamsTargetingMapOfListOfLengthPatternStringOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
1353 1363 | }
|
1354 1364 | }
|
1355 1365 |
|
1356 - | impl std::future::Future for QueryParamsTargetingLengthMapOperationInputFuture {
|
1366 + | impl std::future::Future
|
1367 + | for QueryParamsTargetingMapOfListOfLengthPatternStringOperationInputFuture
|
1368 + | {
|
1357 1369 | type Output = Result<
|
1358 - | crate::input::QueryParamsTargetingLengthMapOperationInput,
|
1370 + | crate::input::QueryParamsTargetingMapOfListOfLengthPatternStringOperationInput,
|
1359 1371 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
|
1360 1372 | >;
|
1361 1373 |
|
1362 1374 | fn poll(
|
1363 1375 | self: std::pin::Pin<&mut Self>,
|
1364 1376 | cx: &mut std::task::Context<'_>,
|
1365 1377 | ) -> std::task::Poll<Self::Output> {
|
1366 1378 | let this = self.project();
|
1367 1379 | this.inner.as_mut().poll(cx)
|
1368 1380 | }
|
1369 1381 | }
|
1370 1382 |
|
1371 1383 | impl<B>
|
1372 1384 | ::aws_smithy_http_server::request::FromRequest<
|
1373 1385 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1374 1386 | B,
|
1375 - | > for crate::input::QueryParamsTargetingLengthMapOperationInput
|
1387 + | > for crate::input::QueryParamsTargetingMapOfListOfLengthPatternStringOperationInput
|
1376 1388 | where
|
1377 1389 | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
1378 1390 | B: 'static,
|
1379 1391 |
|
1380 1392 | B::Data: Send,
|
1381 1393 | ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
|
1382 1394 | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
1383 1395 | {
|
1384 1396 | type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
|
1385 - | type Future = QueryParamsTargetingLengthMapOperationInputFuture;
|
1397 + | type Future = QueryParamsTargetingMapOfListOfLengthPatternStringOperationInputFuture;
|
1386 1398 |
|
1387 1399 | fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
|
1388 1400 | let fut = async move {
|
1389 1401 | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
1390 1402 | request.headers(),
|
1391 1403 | &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
|
1392 1404 | ) {
|
1393 1405 | return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
|
1394 1406 | }
|
1395 - | crate::protocol_serde::shape_query_params_targeting_length_map_operation::de_query_params_targeting_length_map_operation_http_request(request)
|
1407 + | crate::protocol_serde::shape_query_params_targeting_map_of_list_of_length_pattern_string_operation::de_query_params_targeting_map_of_list_of_length_pattern_string_operation_http_request(request)
|
1396 1408 | .await
|
1397 1409 | };
|
1398 1410 | use ::futures_util::future::TryFutureExt;
|
1399 1411 | let fut = fut.map_err(
|
1400 1412 | |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
|
1401 1413 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1402 1414 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
|
1403 1415 | e,
|
1404 1416 | )
|
1405 1417 | },
|
1406 1418 | );
|
1407 - | QueryParamsTargetingLengthMapOperationInputFuture {
|
1419 + | QueryParamsTargetingMapOfListOfLengthPatternStringOperationInputFuture {
|
1408 1420 | inner: Box::pin(fut),
|
1409 1421 | }
|
1410 1422 | }
|
1411 1423 | }
|
1412 1424 | impl
|
1413 1425 | ::aws_smithy_http_server::response::IntoResponse<
|
1414 1426 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1415 - | > for crate::output::QueryParamsTargetingLengthMapOperationOutput
|
1427 + | > for crate::output::QueryParamsTargetingMapOfListOfLengthPatternStringOperationOutput
|
1416 1428 | {
|
1417 1429 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1418 - | match crate::protocol_serde::shape_query_params_targeting_length_map_operation::ser_query_params_targeting_length_map_operation_http_response(self) {
|
1430 + | match crate::protocol_serde::shape_query_params_targeting_map_of_list_of_length_pattern_string_operation::ser_query_params_targeting_map_of_list_of_length_pattern_string_operation_http_response(self) {
|
1419 1431 | Ok(response) => response,
|
1420 1432 | Err(e) => {
|
1421 1433 | ::tracing::error!(error = %e, "failed to serialize response");
|
1422 1434 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
1423 1435 | }
|
1424 1436 | }
|
1425 1437 | }
|
1426 1438 | }
|
1427 1439 | impl
|
1428 1440 | ::aws_smithy_http_server::response::IntoResponse<
|
1429 1441 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1430 - | > for crate::error::QueryParamsTargetingLengthMapOperationError
|
1442 + | > for crate::error::QueryParamsTargetingMapOfListOfLengthPatternStringOperationError
|
1431 1443 | {
|
1432 1444 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1433 - | match crate::protocol_serde::shape_query_params_targeting_length_map_operation::ser_query_params_targeting_length_map_operation_http_error(&self) {
|
1445 + | match crate::protocol_serde::shape_query_params_targeting_map_of_list_of_length_pattern_string_operation::ser_query_params_targeting_map_of_list_of_length_pattern_string_operation_http_error(&self) {
|
1434 1446 | Ok(mut response) => {
|
1435 1447 | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1436 1448 | response
|
1437 1449 | },
|
1438 1450 | Err(e) => {
|
1439 1451 | ::tracing::error!(error = %e, "failed to serialize response");
|
1440 1452 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
1441 1453 | }
|
1442 1454 | }
|
1443 1455 | }
|
1444 1456 | }
|
1445 1457 |
|
1446 1458 | ::pin_project_lite::pin_project! {
|
1447 1459 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
1448 - | /// [`ConstrainedRecursiveShapesOperationInput`](crate::input::ConstrainedRecursiveShapesOperationInput) using modelled bindings.
|
1449 - | pub struct ConstrainedRecursiveShapesOperationInputFuture {
|
1450 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ConstrainedRecursiveShapesOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
1460 + | /// [`HttpPrefixHeadersTargetingLengthMapOperationInput`](crate::input::HttpPrefixHeadersTargetingLengthMapOperationInput) using modelled bindings.
|
1461 + | pub struct HttpPrefixHeadersTargetingLengthMapOperationInputFuture {
|
1462 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::HttpPrefixHeadersTargetingLengthMapOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
1451 1463 | }
|
1452 1464 | }
|
1453 1465 |
|
1454 - | impl std::future::Future for ConstrainedRecursiveShapesOperationInputFuture {
|
1466 + | impl std::future::Future for HttpPrefixHeadersTargetingLengthMapOperationInputFuture {
|
1455 1467 | type Output = Result<
|
1456 - | crate::input::ConstrainedRecursiveShapesOperationInput,
|
1468 + | crate::input::HttpPrefixHeadersTargetingLengthMapOperationInput,
|
1457 1469 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
|
1458 1470 | >;
|
1459 1471 |
|
1460 1472 | fn poll(
|
1461 1473 | self: std::pin::Pin<&mut Self>,
|
1462 1474 | cx: &mut std::task::Context<'_>,
|
1463 1475 | ) -> std::task::Poll<Self::Output> {
|
1464 1476 | let this = self.project();
|
1465 1477 | this.inner.as_mut().poll(cx)
|
1466 1478 | }
|
1467 1479 | }
|
1468 1480 |
|
1469 1481 | impl<B>
|
1470 1482 | ::aws_smithy_http_server::request::FromRequest<
|
1471 1483 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1472 1484 | B,
|
1473 - | > for crate::input::ConstrainedRecursiveShapesOperationInput
|
1485 + | > for crate::input::HttpPrefixHeadersTargetingLengthMapOperationInput
|
1474 1486 | where
|
1475 1487 | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
1476 1488 | B: 'static,
|
1477 1489 |
|
1478 1490 | B::Data: Send,
|
1479 1491 | ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
|
1480 1492 | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
1481 1493 | {
|
1482 1494 | type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
|
1483 - | type Future = ConstrainedRecursiveShapesOperationInputFuture;
|
1495 + | type Future = HttpPrefixHeadersTargetingLengthMapOperationInputFuture;
|
1484 1496 |
|
1485 1497 | fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
|
1486 1498 | let fut = async move {
|
1487 1499 | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
1488 1500 | request.headers(),
|
1489 1501 | &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
|
1490 1502 | ) {
|
1491 1503 | return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
|
1492 1504 | }
|
1493 - | crate::protocol_serde::shape_constrained_recursive_shapes_operation::de_constrained_recursive_shapes_operation_http_request(request)
|
1505 + | crate::protocol_serde::shape_http_prefix_headers_targeting_length_map_operation::de_http_prefix_headers_targeting_length_map_operation_http_request(request)
|
1494 1506 | .await
|
1495 1507 | };
|
1496 1508 | use ::futures_util::future::TryFutureExt;
|
1497 1509 | let fut = fut.map_err(
|
1498 1510 | |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
|
1499 1511 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1500 1512 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
|
1501 1513 | e,
|
1502 1514 | )
|
1503 1515 | },
|
1504 1516 | );
|
1505 - | ConstrainedRecursiveShapesOperationInputFuture {
|
1517 + | HttpPrefixHeadersTargetingLengthMapOperationInputFuture {
|
1506 1518 | inner: Box::pin(fut),
|
1507 1519 | }
|
1508 1520 | }
|
1509 1521 | }
|
1510 1522 | impl
|
1511 1523 | ::aws_smithy_http_server::response::IntoResponse<
|
1512 1524 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1513 - | > for crate::output::ConstrainedRecursiveShapesOperationOutput
|
1525 + | > for crate::output::HttpPrefixHeadersTargetingLengthMapOperationOutput
|
1514 1526 | {
|
1515 1527 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1516 - | match crate::protocol_serde::shape_constrained_recursive_shapes_operation::ser_constrained_recursive_shapes_operation_http_response(self) {
|
1528 + | match crate::protocol_serde::shape_http_prefix_headers_targeting_length_map_operation::ser_http_prefix_headers_targeting_length_map_operation_http_response(self) {
|
1517 1529 | Ok(response) => response,
|
1518 1530 | Err(e) => {
|
1519 1531 | ::tracing::error!(error = %e, "failed to serialize response");
|
1520 1532 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
1521 1533 | }
|
1522 1534 | }
|
1523 1535 | }
|
1524 1536 | }
|
1525 1537 | impl
|
1526 1538 | ::aws_smithy_http_server::response::IntoResponse<
|
1527 1539 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1528 - | > for crate::error::ConstrainedRecursiveShapesOperationError
|
1540 + | > for crate::error::HttpPrefixHeadersTargetingLengthMapOperationError
|
1529 1541 | {
|
1530 1542 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1531 - | match crate::protocol_serde::shape_constrained_recursive_shapes_operation::ser_constrained_recursive_shapes_operation_http_error(&self) {
|
1543 + | match crate::protocol_serde::shape_http_prefix_headers_targeting_length_map_operation::ser_http_prefix_headers_targeting_length_map_operation_http_error(&self) {
|
1532 1544 | Ok(mut response) => {
|
1533 1545 | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1534 1546 | response
|
1535 1547 | },
|
1536 1548 | Err(e) => {
|
1537 1549 | ::tracing::error!(error = %e, "failed to serialize response");
|
1538 1550 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
1539 1551 | }
|
1540 1552 | }
|
1541 1553 | }
|
1542 1554 | }
|
1543 1555 |
|
1544 1556 | ::pin_project_lite::pin_project! {
|
1545 1557 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
1546 - | /// [`ConstrainedHttpPayloadBoundShapeOperationInput`](crate::input::ConstrainedHttpPayloadBoundShapeOperationInput) using modelled bindings.
|
1547 - | pub struct ConstrainedHttpPayloadBoundShapeOperationInputFuture {
|
1548 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ConstrainedHttpPayloadBoundShapeOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
1558 + | /// [`QueryParamsTargetingMapOfEnumStringOperationInput`](crate::input::QueryParamsTargetingMapOfEnumStringOperationInput) using modelled bindings.
|
1559 + | pub struct QueryParamsTargetingMapOfEnumStringOperationInputFuture {
|
1560 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::QueryParamsTargetingMapOfEnumStringOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
1549 1561 | }
|
1550 1562 | }
|
1551 1563 |
|
1552 - | impl std::future::Future for ConstrainedHttpPayloadBoundShapeOperationInputFuture {
|
1564 + | impl std::future::Future for QueryParamsTargetingMapOfEnumStringOperationInputFuture {
|
1553 1565 | type Output = Result<
|
1554 - | crate::input::ConstrainedHttpPayloadBoundShapeOperationInput,
|
1566 + | crate::input::QueryParamsTargetingMapOfEnumStringOperationInput,
|
1555 1567 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
|
1556 1568 | >;
|
1557 1569 |
|
1558 1570 | fn poll(
|
1559 1571 | self: std::pin::Pin<&mut Self>,
|
1560 1572 | cx: &mut std::task::Context<'_>,
|
1561 1573 | ) -> std::task::Poll<Self::Output> {
|
1562 1574 | let this = self.project();
|
1563 1575 | this.inner.as_mut().poll(cx)
|
1564 1576 | }
|
1565 1577 | }
|
1566 1578 |
|
1567 1579 | impl<B>
|
1568 1580 | ::aws_smithy_http_server::request::FromRequest<
|
1569 1581 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1570 1582 | B,
|
1571 - | > for crate::input::ConstrainedHttpPayloadBoundShapeOperationInput
|
1583 + | > for crate::input::QueryParamsTargetingMapOfEnumStringOperationInput
|
1572 1584 | where
|
1573 1585 | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
1574 1586 | B: 'static,
|
1575 1587 |
|
1576 1588 | B::Data: Send,
|
1577 1589 | ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
|
1578 1590 | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
1579 1591 | {
|
1580 1592 | type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
|
1581 - | type Future = ConstrainedHttpPayloadBoundShapeOperationInputFuture;
|
1593 + | type Future = QueryParamsTargetingMapOfEnumStringOperationInputFuture;
|
1582 1594 |
|
1583 1595 | fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
|
1584 1596 | let fut = async move {
|
1585 1597 | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
1586 1598 | request.headers(),
|
1587 1599 | &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
|
1588 1600 | ) {
|
1589 1601 | return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
|
1590 1602 | }
|
1591 - | crate::protocol_serde::shape_constrained_http_payload_bound_shape_operation::de_constrained_http_payload_bound_shape_operation_http_request(request)
|
1603 + | crate::protocol_serde::shape_query_params_targeting_map_of_enum_string_operation::de_query_params_targeting_map_of_enum_string_operation_http_request(request)
|
1592 1604 | .await
|
1593 1605 | };
|
1594 1606 | use ::futures_util::future::TryFutureExt;
|
1595 1607 | let fut = fut.map_err(
|
1596 1608 | |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
|
1597 1609 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1598 1610 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
|
1599 1611 | e,
|
1600 1612 | )
|
1601 1613 | },
|
1602 1614 | );
|
1603 - | ConstrainedHttpPayloadBoundShapeOperationInputFuture {
|
1615 + | QueryParamsTargetingMapOfEnumStringOperationInputFuture {
|
1604 1616 | inner: Box::pin(fut),
|
1605 1617 | }
|
1606 1618 | }
|
1607 1619 | }
|
1608 1620 | impl
|
1609 1621 | ::aws_smithy_http_server::response::IntoResponse<
|
1610 1622 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1611 - | > for crate::output::ConstrainedHttpPayloadBoundShapeOperationOutput
|
1623 + | > for crate::output::QueryParamsTargetingMapOfEnumStringOperationOutput
|
1612 1624 | {
|
1613 1625 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1614 - | match crate::protocol_serde::shape_constrained_http_payload_bound_shape_operation::ser_constrained_http_payload_bound_shape_operation_http_response(self) {
|
1626 + | match crate::protocol_serde::shape_query_params_targeting_map_of_enum_string_operation::ser_query_params_targeting_map_of_enum_string_operation_http_response(self) {
|
1615 1627 | Ok(response) => response,
|
1616 1628 | Err(e) => {
|
1617 1629 | ::tracing::error!(error = %e, "failed to serialize response");
|
1618 1630 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
1619 1631 | }
|
1620 1632 | }
|
1621 1633 | }
|
1622 1634 | }
|
1623 1635 | impl
|
1624 1636 | ::aws_smithy_http_server::response::IntoResponse<
|
1625 1637 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1626 - | > for crate::error::ConstrainedHttpPayloadBoundShapeOperationError
|
1638 + | > for crate::error::QueryParamsTargetingMapOfEnumStringOperationError
|
1627 1639 | {
|
1628 1640 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1629 - | match crate::protocol_serde::shape_constrained_http_payload_bound_shape_operation::ser_constrained_http_payload_bound_shape_operation_http_error(&self) {
|
1641 + | match crate::protocol_serde::shape_query_params_targeting_map_of_enum_string_operation::ser_query_params_targeting_map_of_enum_string_operation_http_error(&self) {
|
1630 1642 | Ok(mut response) => {
|
1631 1643 | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1632 1644 | response
|
1633 1645 | },
|
1634 1646 | Err(e) => {
|
1635 1647 | ::tracing::error!(error = %e, "failed to serialize response");
|
1636 1648 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
1637 1649 | }
|
1638 1650 | }
|
1639 1651 | }
|
1640 1652 | }
|
1641 1653 |
|
1642 1654 | ::pin_project_lite::pin_project! {
|
1643 1655 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
1644 - | /// [`ConstrainedHttpBoundShapesOperationInput`](crate::input::ConstrainedHttpBoundShapesOperationInput) using modelled bindings.
|
1645 - | pub struct ConstrainedHttpBoundShapesOperationInputFuture {
|
1646 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ConstrainedHttpBoundShapesOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
1656 + | /// [`NonStreamingBlobOperationInput`](crate::input::NonStreamingBlobOperationInput) using modelled bindings.
|
1657 + | pub struct NonStreamingBlobOperationInputFuture {
|
1658 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::NonStreamingBlobOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
1647 1659 | }
|
1648 1660 | }
|
1649 1661 |
|
1650 - | impl std::future::Future for ConstrainedHttpBoundShapesOperationInputFuture {
|
1662 + | impl std::future::Future for NonStreamingBlobOperationInputFuture {
|
1651 1663 | type Output = Result<
|
1652 - | crate::input::ConstrainedHttpBoundShapesOperationInput,
|
1664 + | crate::input::NonStreamingBlobOperationInput,
|
1653 1665 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
|
1654 1666 | >;
|
1655 1667 |
|
1656 1668 | fn poll(
|
1657 1669 | self: std::pin::Pin<&mut Self>,
|
1658 1670 | cx: &mut std::task::Context<'_>,
|
1659 1671 | ) -> std::task::Poll<Self::Output> {
|
1660 1672 | let this = self.project();
|
1661 1673 | this.inner.as_mut().poll(cx)
|
1662 1674 | }
|
1663 1675 | }
|
1664 1676 |
|
1665 1677 | impl<B>
|
1666 1678 | ::aws_smithy_http_server::request::FromRequest<
|
1667 1679 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1668 1680 | B,
|
1669 - | > for crate::input::ConstrainedHttpBoundShapesOperationInput
|
1681 + | > for crate::input::NonStreamingBlobOperationInput
|
1670 1682 | where
|
1671 1683 | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
1672 1684 | B: 'static,
|
1673 1685 |
|
1674 1686 | B::Data: Send,
|
1675 1687 | ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
|
1676 1688 | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
1677 1689 | {
|
1678 1690 | type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
|
1679 - | type Future = ConstrainedHttpBoundShapesOperationInputFuture;
|
1691 + | type Future = NonStreamingBlobOperationInputFuture;
|
1680 1692 |
|
1681 1693 | fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
|
1682 1694 | let fut = async move {
|
1683 - | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
1684 - | request.headers(),
|
1685 - | &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
|
1686 - | ) {
|
1687 - | return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
|
1688 - | }
|
1689 - | crate::protocol_serde::shape_constrained_http_bound_shapes_operation::de_constrained_http_bound_shapes_operation_http_request(request)
|
1695 + | crate::protocol_serde::shape_non_streaming_blob_operation::de_non_streaming_blob_operation_http_request(request)
|
1690 1696 | .await
|
1691 1697 | };
|
1692 1698 | use ::futures_util::future::TryFutureExt;
|
1693 1699 | let fut = fut.map_err(
|
1694 1700 | |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
|
1695 1701 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1696 1702 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
|
1697 1703 | e,
|
1698 1704 | )
|
1699 1705 | },
|
1700 1706 | );
|
1701 - | ConstrainedHttpBoundShapesOperationInputFuture {
|
1707 + | NonStreamingBlobOperationInputFuture {
|
1702 1708 | inner: Box::pin(fut),
|
1703 1709 | }
|
1704 1710 | }
|
1705 1711 | }
|
1706 1712 | impl
|
1707 1713 | ::aws_smithy_http_server::response::IntoResponse<
|
1708 1714 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1709 - | > for crate::output::ConstrainedHttpBoundShapesOperationOutput
|
1715 + | > for crate::output::NonStreamingBlobOperationOutput
|
1710 1716 | {
|
1711 1717 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1712 - | match crate::protocol_serde::shape_constrained_http_bound_shapes_operation::ser_constrained_http_bound_shapes_operation_http_response(self) {
|
1718 + | match crate::protocol_serde::shape_non_streaming_blob_operation::ser_non_streaming_blob_operation_http_response(self) {
|
1713 1719 | Ok(response) => response,
|
1714 1720 | Err(e) => {
|
1715 1721 | ::tracing::error!(error = %e, "failed to serialize response");
|
1716 1722 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
1717 1723 | }
|
1718 1724 | }
|
1719 1725 | }
|
1720 1726 | }
|
1721 - | impl
|
1722 - | ::aws_smithy_http_server::response::IntoResponse<
|
1723 - | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1724 - | > for crate::error::ConstrainedHttpBoundShapesOperationError
|
1725 - | {
|
1726 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1727 - | match crate::protocol_serde::shape_constrained_http_bound_shapes_operation::ser_constrained_http_bound_shapes_operation_http_error(&self) {
|
1728 - | Ok(mut response) => {
|
1729 - | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1730 - | response
|
1731 - | },
|
1732 - | Err(e) => {
|
1733 - | ::tracing::error!(error = %e, "failed to serialize response");
|
1734 - | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
1735 - | }
|
1736 - | }
|
1737 - | }
|
1738 - | }
|
1739 1727 |
|
1740 1728 | ::pin_project_lite::pin_project! {
|
1741 1729 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
1742 - | /// [`ConstrainedShapesOnlyInOutputOperationInput`](crate::input::ConstrainedShapesOnlyInOutputOperationInput) using modelled bindings.
|
1743 - | pub struct ConstrainedShapesOnlyInOutputOperationInputFuture {
|
1744 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ConstrainedShapesOnlyInOutputOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
1730 + | /// [`StreamingBlobOperationInput`](crate::input::StreamingBlobOperationInput) using modelled bindings.
|
1731 + | pub struct StreamingBlobOperationInputFuture {
|
1732 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::StreamingBlobOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
1745 1733 | }
|
1746 1734 | }
|
1747 1735 |
|
1748 - | impl std::future::Future for ConstrainedShapesOnlyInOutputOperationInputFuture {
|
1736 + | impl std::future::Future for StreamingBlobOperationInputFuture {
|
1749 1737 | type Output = Result<
|
1750 - | crate::input::ConstrainedShapesOnlyInOutputOperationInput,
|
1738 + | crate::input::StreamingBlobOperationInput,
|
1751 1739 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
|
1752 1740 | >;
|
1753 1741 |
|
1754 1742 | fn poll(
|
1755 1743 | self: std::pin::Pin<&mut Self>,
|
1756 1744 | cx: &mut std::task::Context<'_>,
|
1757 1745 | ) -> std::task::Poll<Self::Output> {
|
1758 1746 | let this = self.project();
|
1759 1747 | this.inner.as_mut().poll(cx)
|
1760 1748 | }
|
1761 1749 | }
|
1762 1750 |
|
1763 1751 | impl<B>
|
1764 1752 | ::aws_smithy_http_server::request::FromRequest<
|
1765 1753 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1766 1754 | B,
|
1767 - | > for crate::input::ConstrainedShapesOnlyInOutputOperationInput
|
1755 + | > for crate::input::StreamingBlobOperationInput
|
1768 1756 | where
|
1769 1757 | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
1770 1758 | B: 'static,
|
1771 1759 |
|
1760 + | B: ::http_body_1x::Body<Data = ::bytes::Bytes>
|
1761 + | + ::std::marker::Send
|
1762 + | + ::std::marker::Sync
|
1763 + | + 'static,
|
1764 + | B::Error: Into<::aws_smithy_types::body::Error> + 'static,
|
1765 + |
|
1772 1766 | B::Data: Send,
|
1773 1767 | ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
|
1774 1768 | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
1775 1769 | {
|
1776 1770 | type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
|
1777 - | type Future = ConstrainedShapesOnlyInOutputOperationInputFuture;
|
1771 + | type Future = StreamingBlobOperationInputFuture;
|
1778 1772 |
|
1779 1773 | fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
|
1780 1774 | let fut = async move {
|
1781 1775 | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
1782 1776 | request.headers(),
|
1783 - | &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
|
1777 + | &crate::mimes::CONTENT_TYPE_APPLICATION_OCTET_STREAM,
|
1784 1778 | ) {
|
1785 1779 | return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
|
1786 1780 | }
|
1787 - | crate::protocol_serde::shape_constrained_shapes_only_in_output_operation::de_constrained_shapes_only_in_output_operation_http_request(request)
|
1781 + | crate::protocol_serde::shape_streaming_blob_operation::de_streaming_blob_operation_http_request(request)
|
1788 1782 | .await
|
1789 1783 | };
|
1790 1784 | use ::futures_util::future::TryFutureExt;
|
1791 1785 | let fut = fut.map_err(
|
1792 1786 | |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
|
1793 1787 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1794 1788 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
|
1795 1789 | e,
|
1796 1790 | )
|
1797 1791 | },
|
1798 1792 | );
|
1799 - | ConstrainedShapesOnlyInOutputOperationInputFuture {
|
1793 + | StreamingBlobOperationInputFuture {
|
1800 1794 | inner: Box::pin(fut),
|
1801 1795 | }
|
1802 1796 | }
|
1803 1797 | }
|
1804 1798 | impl
|
1805 1799 | ::aws_smithy_http_server::response::IntoResponse<
|
1806 1800 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1807 - | > for crate::output::ConstrainedShapesOnlyInOutputOperationOutput
|
1801 + | > for crate::output::StreamingBlobOperationOutput
|
1808 1802 | {
|
1809 1803 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1810 - | match crate::protocol_serde::shape_constrained_shapes_only_in_output_operation::ser_constrained_shapes_only_in_output_operation_http_response(self) {
|
1804 + | match crate::protocol_serde::shape_streaming_blob_operation::ser_streaming_blob_operation_http_response(self) {
|
1811 1805 | Ok(response) => response,
|
1812 1806 | Err(e) => {
|
1813 1807 | ::tracing::error!(error = %e, "failed to serialize response");
|
1814 1808 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
1815 1809 | }
|
1816 1810 | }
|
1817 1811 | }
|
1818 1812 | }
|
1819 1813 |
|
1820 1814 | ::pin_project_lite::pin_project! {
|
1821 1815 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
1822 - | /// [`ConstrainedShapesOperationInput`](crate::input::ConstrainedShapesOperationInput) using modelled bindings.
|
1823 - | pub struct ConstrainedShapesOperationInputFuture {
|
1824 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ConstrainedShapesOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
1816 + | /// [`EventStreamsOperationInput`](crate::input::EventStreamsOperationInput) using modelled bindings.
|
1817 + | pub struct EventStreamsOperationInputFuture {
|
1818 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EventStreamsOperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
|
1825 1819 | }
|
1826 1820 | }
|
1827 1821 |
|
1828 - | impl std::future::Future for ConstrainedShapesOperationInputFuture {
|
1822 + | impl std::future::Future for EventStreamsOperationInputFuture {
|
1829 1823 | type Output = Result<
|
1830 - | crate::input::ConstrainedShapesOperationInput,
|
1824 + | crate::input::EventStreamsOperationInput,
|
1831 1825 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
|
1832 1826 | >;
|
1833 1827 |
|
1834 1828 | fn poll(
|
1835 1829 | self: std::pin::Pin<&mut Self>,
|
1836 1830 | cx: &mut std::task::Context<'_>,
|
1837 1831 | ) -> std::task::Poll<Self::Output> {
|
1838 1832 | let this = self.project();
|
1839 1833 | this.inner.as_mut().poll(cx)
|
1840 1834 | }
|
1841 1835 | }
|
1842 1836 |
|
1843 1837 | impl<B>
|
1844 1838 | ::aws_smithy_http_server::request::FromRequest<
|
1845 1839 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1846 1840 | B,
|
1847 - | > for crate::input::ConstrainedShapesOperationInput
|
1841 + | > for crate::input::EventStreamsOperationInput
|
1848 1842 | where
|
1849 1843 | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
1850 1844 | B: 'static,
|
1851 1845 |
|
1846 + | B: ::http_body_1x::Body<Data = ::bytes::Bytes>
|
1847 + | + ::std::marker::Send
|
1848 + | + ::std::marker::Sync
|
1849 + | + 'static,
|
1850 + | B::Error: Into<::aws_smithy_types::body::Error> + 'static,
|
1851 + |
|
1852 1852 | B::Data: Send,
|
1853 1853 | ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
|
1854 1854 | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
1855 1855 | {
|
1856 1856 | type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
|
1857 - | type Future = ConstrainedShapesOperationInputFuture;
|
1857 + | type Future = EventStreamsOperationInputFuture;
|
1858 1858 |
|
1859 1859 | fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
|
1860 1860 | let fut = async move {
|
1861 1861 | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
1862 1862 | request.headers(),
|
1863 - | &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
|
1863 + | &crate::mimes::CONTENT_TYPE_APPLICATION_VND_AMAZON_EVENTSTREAM,
|
1864 1864 | ) {
|
1865 1865 | return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
|
1866 1866 | }
|
1867 - | crate::protocol_serde::shape_constrained_shapes_operation::de_constrained_shapes_operation_http_request(request)
|
1867 + | crate::protocol_serde::shape_event_streams_operation::de_event_streams_operation_http_request(request)
|
1868 1868 | .await
|
1869 1869 | };
|
1870 1870 | use ::futures_util::future::TryFutureExt;
|
1871 1871 | let fut = fut.map_err(
|
1872 1872 | |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
|
1873 1873 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1874 1874 | ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
|
1875 1875 | e,
|
1876 1876 | )
|
1877 1877 | },
|
1878 1878 | );
|
1879 - | ConstrainedShapesOperationInputFuture {
|
1879 + | EventStreamsOperationInputFuture {
|
1880 1880 | inner: Box::pin(fut),
|
1881 1881 | }
|
1882 1882 | }
|
1883 1883 | }
|
1884 1884 | impl
|
1885 1885 | ::aws_smithy_http_server::response::IntoResponse<
|
1886 1886 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1887 - | > for crate::output::ConstrainedShapesOperationOutput
|
1887 + | > for crate::output::EventStreamsOperationOutput
|
1888 1888 | {
|
1889 1889 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1890 - | match crate::protocol_serde::shape_constrained_shapes_operation::ser_constrained_shapes_operation_http_response(self) {
|
1890 + | match crate::protocol_serde::shape_event_streams_operation::ser_event_streams_operation_http_response(self) {
|
1891 1891 | Ok(response) => response,
|
1892 1892 | Err(e) => {
|
1893 1893 | ::tracing::error!(error = %e, "failed to serialize response");
|
1894 1894 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
1895 1895 | }
|
1896 1896 | }
|
1897 1897 | }
|
1898 1898 | }
|
1899 1899 | impl
|
1900 1900 | ::aws_smithy_http_server::response::IntoResponse<
|
1901 1901 | ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
|
1902 - | > for crate::error::ConstrainedShapesOperationError
|
1902 + | > for crate::error::EventStreamsOperationError
|
1903 1903 | {
|
1904 1904 | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1905 - | match crate::protocol_serde::shape_constrained_shapes_operation::ser_constrained_shapes_operation_http_error(&self) {
|
1905 + | match crate::protocol_serde::shape_event_streams_operation::ser_event_streams_operation_http_error(&self) {
|
1906 1906 | Ok(mut response) => {
|
1907 1907 | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1908 1908 | response
|
1909 1909 | },
|
1910 1910 | Err(e) => {
|
1911 1911 | ::tracing::error!(error = %e, "failed to serialize response");
|
1912 1912 | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
|
1913 1913 | }
|
1914 1914 | }
|
1915 1915 | }
|