diff --git a/scapy/scapypipes.py b/scapy/scapypipes.py
index 6a4bd5062e6bce0764a6a21d9300cc80416e9786..d378ce99079103fea4cc4d829c8ccbb0f8fbbb92 100644
--- a/scapy/scapypipes.py
+++ b/scapy/scapypipes.py
@@ -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):