()
| 261 | ) |
| 262 | |
| 263 | async def continuation() -> Optional[Response]: |
| 264 | event = await waiter.result() |
| 265 | if "error" in event: |
| 266 | raise Error(event["error"]) |
| 267 | if waitUntil not in self._load_states: |
| 268 | t = deadline - monotonic_time() |
| 269 | if t > 0: |
| 270 | await self._wait_for_load_state_impl(state=waitUntil, timeout=t) |
| 271 | if "newDocument" in event and "request" in event["newDocument"]: |
| 272 | request = from_channel(event["newDocument"]["request"]) |
| 273 | return await request.response() |
| 274 | return None |
| 275 | |
| 276 | return EventContextManagerImpl(asyncio.create_task(continuation())) |
| 277 |
nothing calls this directly
no test coverage detected