The current implementation assumes that the peer will send and acknowledging flow frame when we've sent a drain request. The spec doesn't appear to require this, and while SB does in some cases, we've also seen it take several seconds for the reply to show up. This causes the Drain() API to be a bit flakey. In addition, ActiveMQ doesn't appear to send an ack, making this API broken for that broker.
The current implementation assumes that the peer will send and acknowledging flow frame when we've sent a drain request. The spec doesn't appear to require this, and while SB does in some cases, we've also seen it take several seconds for the reply to show up. This causes the Drain() API to be a bit flakey. In addition, ActiveMQ doesn't appear to send an ack, making this API broken for that broker.
It can always be added later as required.