From f7b66ba3cbc26a568fa0003c2bb62ef6c96afbc6 Mon Sep 17 00:00:00 2001
From: Tyler Goodlet <jgbt@protonmail.com>
Date: Mon, 14 Nov 2022 16:11:33 -0500
Subject: [PATCH] Don't raise on a broken IPC-context when sending stop msg

---
 tractor/_streaming.py | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/tractor/_streaming.py b/tractor/_streaming.py
index bb99dc5..11ff47d 100644
--- a/tractor/_streaming.py
+++ b/tractor/_streaming.py
@@ -271,7 +271,8 @@ class ReceiveMsgStream(trio.abc.ReceiveChannel):
         self,
 
     ) -> AsyncIterator[BroadcastReceiver]:
-        '''Allocate and return a ``BroadcastReceiver`` which delegates
+        '''
+        Allocate and return a ``BroadcastReceiver`` which delegates
         to this message stream.
 
         This allows multiple local tasks to receive each their own copy
@@ -609,7 +610,14 @@ class Context:
                 # XXX: Make the stream "one-shot use".  On exit, signal
                 # ``trio.EndOfChannel``/``StopAsyncIteration`` to the
                 # far end.
-                await self.send_stop()
+                try:
+                    await self.send_stop()
+                except trio.BrokenResourceError:
+                    log.warning(
+                        f"Couldn't close: stream already broken?\n"
+                        f'actor: {self.chan.uid}\n'
+                        f'ctx id: {self.cid}'
+                    )
 
             finally:
                 if self._portal: