From 286e75d342acecfdb2e0b808d0cd9878974b595a Mon Sep 17 00:00:00 2001
From: Tyler Goodlet <jgbt@protonmail.com>
Date: Wed, 14 Feb 2024 16:13:32 -0500
Subject: [PATCH] Offer `unpack_error(hid_tb: bool)` for `pdbp` REPL config

---
 tractor/_exceptions.py | 14 ++++++++++----
 1 file changed, 10 insertions(+), 4 deletions(-)

diff --git a/tractor/_exceptions.py b/tractor/_exceptions.py
index 7e14858..c75b785 100644
--- a/tractor/_exceptions.py
+++ b/tractor/_exceptions.py
@@ -185,7 +185,8 @@ def unpack_error(
 
     msg: dict[str, Any],
     chan=None,
-    err_type=RemoteActorError
+    err_type=RemoteActorError,
+    hide_tb: bool = True,
 
 ) -> None | Exception:
     '''
@@ -196,7 +197,7 @@ def unpack_error(
     which is the responsibilitiy of the caller.
 
     '''
-    __tracebackhide__: bool = True
+    __tracebackhide__: bool = hide_tb
 
     error_dict: dict[str, dict] | None
     if (
@@ -309,6 +310,11 @@ def _raise_from_no_key_in_msg(
         # value out of the underlying feed mem chan!
         stream._eoc: bool = True
 
+        # TODO: if the a local task is already blocking on
+        # a `Context.result()` and thus a `.receive()` on the
+        # rx-chan, we close the chan and set state ensuring that
+        # an eoc is raised!
+
         # # when the send is closed we assume the stream has
         # # terminated and signal this local iterator to stop
         # await stream.aclose()
@@ -317,8 +323,8 @@ def _raise_from_no_key_in_msg(
         # raise a ``StopAsyncIteration`` **and** in our catch
         # block below it will trigger ``.aclose()``.
         raise trio.EndOfChannel(
-                'Context[{cid}] stream ended due to msg:\n'
-                f'{pformat(msg)}'
+            f'Context stream ended due to msg:\n'
+            f'{pformat(msg)}'
         ) from src_err