diff options
| -rw-r--r-- | src/pipe.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/pipe.cpp b/src/pipe.cpp index d62085d..ff64716 100644 --- a/src/pipe.cpp +++ b/src/pipe.cpp @@ -204,7 +204,7 @@ void zmq::writer_t::term () msg.content = (void*) (offset + ZMQ_DELIMITER); msg.flags = 0; pipe->write (msg, false); - pipe->flush (); + flush (); } void zmq::writer_t::process_reader_info (uint64_t msgs_read_) |