(&mut self, req: LambdaEvent<LambdaRequest>)
| 72 | } |
| 73 | |
| 74 | fn call(&mut self, req: LambdaEvent<LambdaRequest>) -> Self::Future { |
| 75 | let LambdaEvent { payload, context } = req; |
| 76 | let mut event: Request = payload.into(); |
| 77 | update_xray_trace_id_header(event.headers_mut(), &context); |
| 78 | Box::pin( |
| 79 | self.service |
| 80 | .call(event.with_lambda_context(context)) |
| 81 | .map_ok(into_stream_response), |
| 82 | ) |
| 83 | } |
| 84 | } |
| 85 | |
| 86 | /// Builds a streaming-aware Tower service from a `Service<Request>` **without** |
nothing calls this directly
no test coverage detected