(self, coro)
| 33 | self._loop.run_forever() |
| 34 | |
| 35 | def _submit(self, coro): |
| 36 | if self._closed: |
| 37 | raise RuntimeError("Viewer storage has been closed.") |
| 38 | return asyncio.run_coroutine_threadsafe(coro, self._loop) |
| 39 | |
| 40 | def _run(self, coro): |
| 41 | return self._submit(coro).result() |