High/Low Water mark support?

[junkblocker]

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.

[sbinet]

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)

[junkblocker]

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.