Commit f9c84a1a authored by Martin Hurton's avatar Martin Hurton

Implement flow control for ZMQ_DOWNSTREAM sockets

parent 5d4f6b18
......@@ -67,7 +67,7 @@ void zmq::downstream_t::xrevive (class reader_t *pipe_)
void zmq::downstream_t::xrevive (class writer_t *pipe_)
{
zmq_not_implemented ();
lb.revive (pipe_);
}
int zmq::downstream_t::xsetsockopt (int option_, const void *optval_,
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment