From fc36e7362877cfe294baee16bf1a1ea50ee4926c Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Wed, 28 Apr 2021 16:40:38 -0400 Subject: [PATCH] Comment out `MsgStream` for now --- tractor/_streaming.py | 24 +++++++++++------------- 1 file changed, 11 insertions(+), 13 deletions(-) diff --git a/tractor/_streaming.py b/tractor/_streaming.py index 8e8edf88e..0836f4e2d 100644 --- a/tractor/_streaming.py +++ b/tractor/_streaming.py @@ -101,7 +101,7 @@ def stream(func): params = sig.parameters if 'stream' not in params and 'ctx' in params: warnings.warn( - "`@tractr.stream decorated funcs should now declare a `stream` " + "`@tractor.stream decorated funcs should now declare a `stream` " " arg, `ctx` is now designated for use with @tractor.context", DeprecationWarning, stacklevel=2, @@ -141,7 +141,6 @@ def __init__( self._ctx = ctx self._rx_chan = rx_chan self._portal = portal - # self._chan = portal.channel self._shielded = False # delegate directly to underlying mem channel @@ -152,7 +151,6 @@ async def receive(self): try: msg = await self._rx_chan.receive() return msg['yield'] - # return msg['yield'] except KeyError: # internal error should never get here @@ -249,14 +247,14 @@ async def aclose(self): # ) -class MsgStream(ReceiveMsgStream, trio.abc.Channel): - """ - Bidirectional message stream for use within an inter-actor actor - ``Context```. +# class MsgStream(ReceiveMsgStream, trio.abc.Channel): +# """ +# Bidirectional message stream for use within an inter-actor actor +# ``Context```. - """ - async def send( - self, - data: Any - ) -> None: - await self._ctx.chan.send({'yield': data, 'cid': self._ctx.cid}) +# """ +# async def send( +# self, +# data: Any +# ) -> None: +# await self._ctx.chan.send({'yield': data, 'cid': self._ctx.cid})