multiqueue
multiqueue copied to clipboard
A fast mpmc queue with broadcast capabilities
This should fix issue #19, it's probably better than just exporting the error since this way all the error types are just the ones used in the `std::sync::mpsc` module instead...
This would help in choosing between them.
Unbounded readers is a huge edge case and wildly complicates the code since there's no GC
I'm attempting to use `BroadcastFutReceiver` as a stream combinator to get a `Clone`able stream that I can share across threads. I have tried something similar to the following: ```rust fn...
The examples mention that unsubscribing from certain streams is necessary in order to stop other streams from "starving". It would be helpful if the documentation could explain what the conditions...
The automatically-derived Clone trait on MPMCFutSender (and I assume other Senders) requires that T be Clone - however this is unnecessary since no T is never actually cloned while cloning...
It would be great if there was a futures queue which only implemented stream and not sink so readers didn't have to notify the senders
Like channels, this should support the recv_timeout method
This needs support for reading and writing raw byte steams, which would probably be able to use a fundamentally similar queue algorithm.