From ae9ab81ff36152d42161fd5e6010d066cb5937d4 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Thu, 5 Jul 2018 15:30:31 -0400 Subject: [PATCH] Don't bother unsetting the squeue; let errors propogate up --- piker/ipc.py | 4 ---- 1 file changed, 4 deletions(-) diff --git a/piker/ipc.py b/piker/ipc.py index c643ccc..7bc647c 100644 --- a/piker/ipc.py +++ b/piker/ipc.py @@ -86,7 +86,6 @@ class Channel: self._destaddr = destaddr or self.squeue.raddr # set after handshake - always uid of far end self.uid = None - self.event = None def __repr__(self): if self.squeue: @@ -122,12 +121,10 @@ class Channel: if self._autorecon: await self._reconnect() return await self.recv() - self.squeue = None async def aclose(self, *args): log.debug(f"Closing {self}") await self.squeue.stream.aclose() - self.squeue = None async def __aenter__(self): await self.connect() @@ -184,7 +181,6 @@ class Channel: if not self._autorecon: raise await self.aclose() - self.squeue = None if self._autorecon: # attempt reconnect await self._reconnect() continue