| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -269,6 +269,7 @@ async def async_wait(self, timeout: float) -> None: | |||
| 269 | 269 | await wait_for_future_set_or_timeout(loop, self._notify_futures, timeout) | |
| 270 | 270 | ||
| 271 | 271 | def notify_all(self) -> None: | |
| 272 | + """Wake every waiter and fire the listeners, from any thread.""" | ||
| 272 | 273 | assert self.loop is not None | |
| 273 | 274 | self.loop.call_soon_threadsafe(self.async_notify_all) | |
| 274 | 275 | ||
| Back | FazBrowse Home | New Git URL |
0 commit comments