1 files changed, 6 insertions, 2 deletions
diff --git a/src/zmq_engine.cpp b/src/zmq_engine.cpp
index dace6ae..01fe98c 100644
--- a/src/zmq_engine.cpp
+++ b/src/zmq_engine.cpp
@@ -81,6 +81,8 @@ void zmq::zmq_engine_t::unplug ()
 
 void zmq::zmq_engine_t::in_event ()
 {
+    bool disconnection = false;
+
     //  If there's no data to process in the buffer...
     if (!insize) {
 
@@ -91,8 +93,7 @@ void zmq::zmq_engine_t::in_event ()
         //  Check whether the peer has closed the connection.
         if (insize == (size_t) -1) {
             insize = 0;
-            error ();
-            return;
+            disconnection = true;
         }
     }
 
@@ -114,6 +115,9 @@ void zmq::zmq_engine_t::in_event ()
 
     //  Flush all messages the decoder may have produced.
     inout->flush ();
+
+    if (disconnection)
+        error ();
 }
 
 void zmq::zmq_engine_t::out_event ()