(self, item: _T)
| 315 | # End of the overridable methods. |
| 316 | |
| 317 | def __put_internal(self, item: _T) -> None: |
| 318 | self._unfinished_tasks += 1 |
| 319 | self._finished.clear() |
| 320 | self._put(item) |
| 321 | |
| 322 | def _consume_expired(self) -> None: |
| 323 | # Remove timed-out waiters. |
no test coverage detected