jc211
/
tractor
forked from goodboy/tractor
1
0
Fork 0
Code Pull Requests Activity

Add uid,event attrs to `Channel`

asyncgen_closing_fix
Tyler Goodlet 2018-06-21 17:09:22 -04:00
parent 2e9cbec93c
commit bed7e240de
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
piker/ipc.py
View File

@ -81,6 +81,9 @@ class Channel:
f"A stream was provided with local addr {self.laddr}" f"A stream was provided with local addr {self.laddr}"
) )
self._destaddr = destaddr or self.squeue.raddr self._destaddr = destaddr or self.squeue.raddr
# set after handshake - always uid of far end
self.uid = None
self.event = None
def __repr__(self): def __repr__(self):
if self.squeue: if self.squeue:
@ -106,6 +109,7 @@ class Channel:
return stream return stream
async def send(self, item): async def send(self, item):
log.debug(f"send `{item}`")
await self.squeue.put(item) await self.squeue.put(item)
async def recv(self): async def recv(self):
@ -180,3 +184,6 @@ class Channel:
continue continue
else: else:
return return
def connected(self):
return self.squeue is not None