tractor/_root.py

@@ -243,6 +243,7 @@ async def open_root_actor(
                 logger.cancel("Shutting down root actor")
                 await actor.cancel()
     finally:
+        _state._current_actor = None
         logger.runtime("Root actor terminated")
 
 

tractor/_streaming.py

@@ -69,7 +69,7 @@ class ReceiveMsgStream(trio.abc.ReceiveChannel):
     '''
     def __init__(
         self,
-        ctx: Context,  # typing: ignore # noqa
+        ctx: 'Context',  # typing: ignore # noqa
         rx_chan: trio.MemoryReceiveChannel,
         _broadcaster: Optional[BroadcastReceiver] = None,
 
@@ -82,9 +82,6 @@ class ReceiveMsgStream(trio.abc.ReceiveChannel):
         self._eoc: bool = False
         self._closed: bool = False
 
-    def ctx(self) -> Context:
-        return self._ctx
-
     # delegate directly to underlying mem channel
     def receive_nowait(self):
         msg = self._rx_chan.receive_nowait()
@@ -383,7 +380,7 @@ class Context:
     # only set on the callee side
     _scope_nursery: Optional[trio.Nursery] = None
 
-    _backpressure: bool = True
+    _backpressure: bool = False
 
     async def send_yield(self, data: Any) -> None: