flume
flume copied to clipboard
zesterer
A safe and fast multi-producer, multi-consumer channel.
I know it's pretty custom and not a typical usecase but I think it'd be pretty cool to show the power of the library to show how to do *exact*...
This is a new from-scratch implementation of Flume with an async core. A few things to note about the design: - The core is async-only and is `no_std`. I use...
Hi, I'm trying to catch panics in some code with Flume: ```rust pub fn add_allocation(&self, address: usize, size: usize) { // simplified from real code. catch_unwind(|| { self.sender.send( AddAllocationCommand {...
This may or may not be a problem in general; in my case it caused a deadlock. Scenario: ```rust struct Command { sender: flume::Sender } impl Command { fn new()...
If this is feature equivalent, wouldn't it be a good idea to try and get it merged into std?
I find myself in a situation where I want to try to send a message in a channel and if buffer is full I want to send it to another...
Please consider adding the async-channel crate to the benchmarks. It's part of the async-std and smol stacks, and I would like to see how it compares.
```rust channel_match!( rx => |x:X| println!("{}",x) rx => |y:Y| println!("{}",y) ) ``` ``` enum SelectMatch2{ A(Q) B(S) } ... { let a = |x:X| println!("{}",x) let b = |y:Y|1 println!("{}",y)...
We have to disable three timeout tests in #17. I tried to increase error bound up to 100 milliseconds but the bound exceeded to 150ms. Some other attempts failed: *...
A common pattern is to use `Selector` in an infinite loop. Now a user need to reconstruct a new `Selector` in each iteration because `wait` consumes it. This can have...
