futures-rs
futures-rs copied to clipboard
rust-lang
Zero-cost asynchronous programming in Rust
Would it be possible to support async transformations on arrays? ```rust async fn map_async( array: [A;N], fun: Fn(A) -> Fut ) -> [B;N] where Fut: Future; ``` I ran into...
Hi, I found no AsyncSeek support for `Take` which makes a `File` is not seekable after `take`. Is it possible to implement AsyncSeek for Take if R is AsyncSeek?
https://docs.rs/futures/latest/futures/io/struct.Take.html#method.get_ref > Acquires a reference to the underlying **sink or stream** that this combinator is pulling from. These methods are defined by the delegate_access_inner macro and we need to fix...
Add `RwLock`
Resolves #2015 This branch adds an asynchronous version of [`std::sync::RwLock`](https://doc.rust-lang.org/std/sync/struct.RwLock.html) to `futures_util::lock`. New public data types: + `futures::lock::RwLock` + `futures::lock::RwLockReadFuture` + `futures::lock::RwLockWriteFuture` + `futures::lock::RwLockReadGuard` + `futures::lock::RwLockWriteGuard` Feel free to check...
The proposal to add a similar method from std [`map_while`](https://doc.rust-lang.org/std/iter/trait.Iterator.html#method.map_while) for stream. This would be convenient to reduce this: ```rust stream.map(|x| u32::checked_div(16, x)) .take_while(|x| future::ready(x.is_some())) .map(|x| x.unwrap()) ``` to this:...
Corresponding std::io change done in Rust 1.73: https://github.com/rust-lang/rust/pull/98154
If I've not mistaken then `Shared::poll` will wake up the very same waker that was actually polling it, and return a `Poll::Ready` at the same time. https://github.com/rust-lang/futures-rs/blob/bb63c376ca2d3f277f7bfb2b178c913faa00b947/futures-util/src/future/future/shared.rs#L347-L352 Which is confusing...
How to reuse `AbortRegistration` for multiple futures? I have a future that I want to make `Abortable`. When that future completes, I need to make a new one and have...
Here is the definition of [`Iterator::eq`](https://doc.rust-lang.org/std/iter/trait.Iterator.html#method.eq).
