mirror of
https://github.com/exo-explore/exo.git
synced 2026-02-18 14:55:13 -05:00
Compare commits
1 Commits
main
...
fix/mp-rec
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
faac462d9a |
@@ -204,6 +204,10 @@ class MpReceiver[T]:
|
||||
def close(self) -> None:
|
||||
if not self._state.closed.is_set():
|
||||
self._state.closed.set()
|
||||
try: # noqa: SIM105
|
||||
self._state.buffer.put_nowait(_MpEndOfStream())
|
||||
except Exception:
|
||||
pass
|
||||
self._state.buffer.close()
|
||||
|
||||
# == unique to Mp channels ==
|
||||
|
||||
Reference in New Issue
Block a user