multiqueue icon indicating copy to clipboard operation
multiqueue copied to clipboard

A fast mpmc queue with broadcast capabilities

Results 20 multiqueue issues
Sort by recently updated
recently updated
newest added

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...

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.