Method
headers_received
(
self,
start_line: Union[httputil.RequestStartLine, httputil.ResponseStartLine],
headers: httputil.HTTPHeaders,
)
Source from the content-addressed store, hash-verified
| 2465 | self.stream_request_body = _has_stream_request_body(self.handler_class) |
| 2466 | |
| 2467 | def headers_received( |
| 2468 | self, |
| 2469 | start_line: Union[httputil.RequestStartLine, httputil.ResponseStartLine], |
| 2470 | headers: httputil.HTTPHeaders, |
| 2471 | ) -> Optional[Awaitable[None]]: |
| 2472 | if self.stream_request_body: |
| 2473 | self.request._body_future = Future() |
| 2474 | return self.execute() |
| 2475 | return None |
| 2476 | |
| 2477 | def data_received(self, data: bytes) -> Optional[Awaitable[None]]: |
| 2478 | if self.stream_request_body: |
Callers
nothing calls this directly
Tested by
no test coverage detected