(
self,
start_line: Union[httputil.RequestStartLine, httputil.ResponseStartLine],
headers: httputil.HTTPHeaders,
)
| 383 | self.delegate = delegate |
| 384 | |
| 385 | def headers_received( |
| 386 | self, |
| 387 | start_line: Union[httputil.RequestStartLine, httputil.ResponseStartLine], |
| 388 | headers: httputil.HTTPHeaders, |
| 389 | ) -> Optional[Awaitable[None]]: |
| 390 | # TODO: either make context an official part of the |
| 391 | # HTTPConnection interface or figure out some other way to do this. |
| 392 | self.connection.context._apply_xheaders(headers) # type: ignore |
| 393 | return self.delegate.headers_received(start_line, headers) |
| 394 | |
| 395 | def data_received(self, chunk: bytes) -> Optional[Awaitable[None]]: |
| 396 | return self.delegate.data_received(chunk) |
nothing calls this directly
no test coverage detected