From 57f2aca18c3994b0795e00a9084b22ceeed9d634 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Wed, 15 Dec 2021 17:19:04 -0500 Subject: [PATCH] Set eoc on closure (again) --- tractor/_streaming.py | 1 + 1 file changed, 1 insertion(+) diff --git a/tractor/_streaming.py b/tractor/_streaming.py index fbf253b..05932b8 100644 --- a/tractor/_streaming.py +++ b/tractor/_streaming.py @@ -186,6 +186,7 @@ class ReceiveMsgStream(trio.abc.ReceiveChannel): # 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: