(
http_request: Request,
cancel: Callable[[], None],
)
| 15746 | ) |
| 15747 | |
| 15748 | async def watch_http_disconnect( |
| 15749 | http_request: Request, |
| 15750 | cancel: Callable[[], None], |
| 15751 | ) -> None: |
| 15752 | while True: |
| 15753 | message = await http_request.receive() |
| 15754 | if message["type"] == "http.disconnect": |
| 15755 | cancel() |
| 15756 | return |
| 15757 | |
| 15758 | async def disconnected_cancelled_response_or_raise( |
| 15759 | http_request: Request, |
no outgoing calls
no test coverage detected
searching dependent graphs…