Skip to content
Snippets Groups Projects
Commit f3ff7177 authored by phil's avatar phil Committed by Guillaume Valadon
Browse files

Had TCPListenPipe triggers when a connection happens

parent 21fa4486
No related branches found
No related tags found
No related merge requests found
......@@ -173,7 +173,7 @@ class TCPConnectPipe(Source):
class TCPListenPipe(TCPConnectPipe):
"""TCP listen on [addr:]port and use first connection as source and sink ; send peer address to high output
+-------------+
+------^------+
>>-| +-[peer]-|->>
| / |
>-|-[addr:port]-|->
......@@ -208,6 +208,7 @@ class TCPListenPipe(TCPConnectPipe):
self.fd.send(self.q.get(block=False))
except Queue.Empty:
break
self._trigger(repr(frm))
class TriggeredMessage(Drain):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment