futures-rs
futures-rs copied to clipboard
rust-lang
Zero-cost asynchronous programming in Rust
It depends on the fact that `Waker` always stores the data of the waker behind a reference and never inline. If data was stored inline, `WakerRef` could be used to...
Hello, I am having a bit of trouble with multithreading when I am calling `async` functions, an simplified example is as follows: ```rust #![allow(unused_mut)] use tokio; use futures::{stream, StreamExt}; async...
Currently we have the `Stream::for_each_concurrent`, `buffer_unordered`, and `buffered`, which use `FuturesUnordered` to run streams concurrently. Calling the combinators "buffered" is not great for visibility in my experience, and it might...
[`OptionFuture`]'s design seems inconsistent to me. The docs don't clearly explain what it's for: > A future representing a value which may or may not be present. Which could describe...
Sometimes, you'd like to temporarily suspend a future until something else happens. I propose a `Pausable` API that allows one to render a `Future` as stopped. ## Public API ```rust...
Hi, When reading a known number of bytes from `futures::io::ReadAsync`, it is useful to use the idiom ```rust let mut a = vec![]; a.try_reserve(length0)?; reader .by_ref() .take(length0 as u64) .read_to_end(a)...
When `futures::executor::block_on` is called recursively it panics with: ``` thread 'main' panicked at 'cannot execute `LocalPool` executor from within another executor: EnterError', src/libcore/result.rs:1188:5 ``` Here is a complete program to...
EDIT(taiki-e): The regression that occurred in 0.3.18 has been fixed in 0.3.19, but the underlying problem that 0.3.18 tried to fix has not been fixed yet. This issue has been...
Instead of allowing polling of the underlying stream after the error, propagate this error first, and only after it will be received by the caller, allow to continue polling. The...
