futures-rs
futures-rs copied to clipboard
rust-lang
Zero-cost asynchronous programming in Rust
SpawnError currently only has the notion that spawning can fail because the executor is shutdown, however eventually when allocator-api is stabilized we will want to be able to fail to...
I'm trying to generate a stream to work on a `&mut [u8]`. To do this I've tried to use: ```rust async fn process(buffer: &mut [u8]) -> Result { stream::iter(buffer).enumerate().try_for_each(async |(index,...
Currently there is no way to see the currently in progress futures in a [`BufferUnordered`](https://docs.rs/futures/latest/futures/prelude/stream/struct.BufferUnordered.html) when these are directly accessible in [`FuturesUnordered`](https://docs.rs/futures/latest/futures/stream/struct.FuturesUnordered.html) which it uses. This would have the same...
async closures have been stabilized in https://github.com/rust-lang/rust/pull/132706 (Rust 1.85).
I found out today that there is no BoxSink alias, which seems like it could be handy sometimes. I saw that in https://github.com/rust-lang/futures-rs/pull/808 it was removed, but no explanation was...
It would be helpful if `StreamExt` had a `reduce` method (similar to [`Iterator::reduce`](https://doc.rust-lang.org/std/iter/trait.Iterator.html#method.reduce)), and also if `TryStreamExt` had a `try_reduce` method (similar to [`Iterator::try_reduce`](https://doc.rust-lang.org/std/iter/trait.Iterator.html#method.try_reduce)).
Currently, the `select!` macro works only in the std environment. This PR fixes the implementation so that the `select!` macro also works in no-std environments for 32- and 64-bit CPUs....
The future extension method [FutureExt::shared](https://docs.rs/futures/latest/futures/future/trait.FutureExt.html#method.shared) does not specify in its documentation that it does not poll the inner future until the `Shared` it creates is polled. For people finding or...
