zmq4
zmq4 copied to clipboard
High/Low Water mark support?
I want to be able to PUSH only a limited number of packets to avoid losing them if the PULL side crashes. Is this possible or planned? Looking at the code I see that go's io.ReadWriteCloser
is used underneath so it seems no message level limiting is possible.
It probably isn't possible right now but it's definitely something most people will need at some point.
I don't think having based the transport on 'io.ReadWriteCloser' will prevent to implement that (but happy to hear otherwise)
Since I need it soon, I'd like to take a stab at implementing this. Any general clues about the implementation design to save me time investigating would be highly appreciated.