Set eoc on closure (again)

goodboy · Dec 16, 2021 · 57f2aca · 57f2aca
1 parent 1652716
commit 57f2aca
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/tractor/_streaming.py b/tractor/_streaming.py
@@ -186,6 +186,7 @@ async def aclose(self):
             # https://trio.readthedocs.io/en/stable/reference-io.html#trio.abc.AsyncResource.aclose
             return
 
+        self._eoc = True
         self._closed = True
 
         # NOTE: this is super subtle IPC messaging stuff: