diff --git a/tractor/_ipc.py b/tractor/_ipc.py index 9e0ced1..b996c5f 100644 --- a/tractor/_ipc.py +++ b/tractor/_ipc.py @@ -121,11 +121,12 @@ class MsgpackTCPStream: self.drained: list[dict] = [] async def _iter_packets(self) -> AsyncGenerator[dict, None]: - """Yield packets from the underlying stream. - """ + ''' + Yield packets from the underlying stream. + + ''' unpacker = msgpack.Unpacker( raw=False, - strict_map_key=False ) while True: try: