nats.rs
nats.rs copied to clipboard
Implement the "drain" feature for subscriptions and connections
Based on the proposal in #1325, implementing the functionality described in this NATS doc.
I would love suggestions for further tests. I tried adding tests for more complex timing/corner cases but they all wound up looking like exactly like the tests I have here