(self, item)
| 463 | self._aq.notify() |
| 464 | |
| 465 | def put(self, item) -> None: |
| 466 | self._aq.put_nowait(item) |
| 467 | |
| 468 | if self._loop.is_running(): |
| 469 | asyncio.run_coroutine_threadsafe(self._notify(), self._loop) |
| 470 | else: |
| 471 | raise AsyncQueue.EventLoopShutdownError() |
| 472 | |
| 473 | def put_nowait(self, item) -> None: |
| 474 | """ Put item without notify the event. """ |
nothing calls this directly
no test coverage detected