futures-rs
futures-rs copied to clipboard
rust-lang
Zero-cost asynchronous programming in Rust
The combinators that poll a stream for exhaustion in a loop have a problem that's already been raised in #869: if the upstream consecutively returns `Ready` for a long time,...
Consider the following example for the threadpool, which is close to the example from the documentation: [https://docs.rs/futures/0.3.15/futures/executor/struct.ThreadPool.html](https://docs.rs/futures/0.3.15/futures/executor/struct.ThreadPool.html) ```rust use std::thread::sleep; use std::time::Duration; use futures::FutureExt; use futures::executor::ThreadPool; async fn cpu_intensive(i: u64)...
This is useful when you don't necessarily want to consume the entire stream as a reader, but still want to retain the stream for other uses. ~The nested tuple/`Option`/tuple is...
It might be desirable to have adaptative parallelism for the processing of buffered futures. An example use case would be to cope with the ever changing network conditions when sending...
This moves type aliases (BoxFuture, LocalBoxFuture, BoxStream, LocalBoxStream) and Trait aliases (TryFuture, TryStream) to futures-util. part of #2207 > - Type aliases (BoxFuture, LocalBoxFuture, BoxStream, LocalBoxStream) > - Move to...
I'm puzzled on this one. I could understand Rust not being able to infer the type with how generic `Stream::collect` is but Rust can somehow infer it from the declaration...
https://github.com/rust-lang/futures-rs/pull/2433#issuecomment-836929899
Would it be possible to expose `BiLock` in a way that follows semver, even if it is separate from the normal future crates? I don't even mind if it updates...
