kanal
kanal copied to clipboard
fereidani
The fast sync and async channel that Rust deserves
I open this issue for those kind people who are interested provide help to develop Kanal. We need help in these areas: 1. Auditing Kanal for UB and security-related issues....
Have deadlock here https://github.com/botika/unblock/actions/runs/4009192427/jobs/6884250212
I have a scenario like this ```rust let table = Arc::new(DashMap::new()); let (tx, rx) = kannal::oneshot_async(); table.insert(1, tx); tokio::spawn(async move { tabl.remove(1).unwrap().send(()).await; }); rx.await ``` But I got error[E0277]: `*mut...
Would it be possible to add a `SendSink` for `AsyncSender` similar to `ReceiveStream` for `AsyncReceiver`? This would be nice to have and `flume` also supports this. You could add a...
I used the `AsyncSender` and `AsyncReceiver` channels and this code started panicking when using kanal. I tried it with Flume and Tokio mpsc channels and there's no issue. It happens...
OneshotAsyncSender::send is async, and OneshotSender::send uses a for loop they are not necessary, as an oneshot sender can immediately know if a receiver is dropped. e.g. tokio::sync::oneshot::Sender provides a send...
Hi! First, thank you very much for this crate (IMHO it has the best API). kanal bounded_async channels seems to work differently than tokio and go channels on select. Suprisingly,...
