diff options
Diffstat (limited to 'src/fq.cpp')
-rw-r--r-- | src/fq.cpp | 5 |
1 files changed, 5 insertions, 0 deletions
@@ -75,6 +75,11 @@ void zmq::fq_t::terminate () { terminating = true; + if (pipes.empty ()) { + sink->terminated (); + return; + } + for (pipes_t::size_type i = 0; i != pipes.size (); i++) pipes [i]->terminate (); } |