summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/zmq_engine.cpp3
1 files changed, 3 insertions, 0 deletions
diff --git a/src/zmq_engine.cpp b/src/zmq_engine.cpp
index 3cab4c9..f12fe1a 100644
--- a/src/zmq_engine.cpp
+++ b/src/zmq_engine.cpp
@@ -58,6 +58,9 @@ void zmq::zmq_engine_t::plug (i_inout *inout_)
set_pollout (handle);
inout = inout_;
+
+ // Flush all the data that may have been already received downstream.
+ in_event ();
}
void zmq::zmq_engine_t::unplug ()