Wake up any pending receive() call.
(self)
| 206 | return self._closed or self._body_wait_expired |
| 207 | |
| 208 | def _wake_waiter(self): |
| 209 | """Wake up any pending receive() call.""" |
| 210 | if self._waiter is not None and not self._waiter.done(): |
| 211 | self._waiter.set_result(None) |
| 212 | |
| 213 | async def receive(self): # pylint: disable=too-many-return-statements |
| 214 | """ASGI receive callable - returns body chunks or disconnect.""" |
no outgoing calls
no test coverage detected