futures-rs

futures-rs copied to clipboard

block_on in wasm

1

New to rust, so appreciate the help. I'm trying to call block on an async function within rust and it's throwing errors, was wondering if this is possible. Using `futures...

simonwarchol

Improve comment for `FuturesOrdered` and `FuturesUnordered`

6

For `FuturesOrdered` there is a comment that says the futures would run in parallel, which is misleading. This PR makes clear that futures for `FuturesOrdered` and `FuturesUnordered` run to completion...

th4s

`StreamExt::find` method analogous to `Iterator::find`?

3

https://doc.rust-lang.org/std/iter/trait.Iterator.html#method.find This is something I've always wanted in `Stream`-based code. Right now I have to use manual while-loop iteration for anything involving "read from this stream until something you need...

nullchinchilla

Missed wake call using `.shared()`

5

This is the reproduction: ```rs use std::{ io::Write, pin::Pin, task::{Context, Poll}, }; use futures::prelude::*; pub async fn yield_now() { /// Yield implementation struct YieldNow { yielded: bool, } impl Future...

steffahn

Implement `oneshot::Receiver::blocking_recv` for [`oneshot::Receiver`](https://docs.rs/futures/latest/futures/channel/oneshot/struct.Receiver.html) as in [Tokio](https://docs.rs/tokio/latest/tokio/sync/oneshot/struct.Receiver.html#method.blocking_recv).

byte-sourcerer

Document cancel safety of `StreamExt::next`

1

Here: https://docs.rs/futures/latest/futures/stream/trait.StreamExt.html#method.next And the equivalent tokio docs: https://docs.rs/tokio-stream/latest/tokio_stream/trait.StreamExt.html#method.next I think it's critical that users know if stream items can be accidentally dropped if the future is cancelled.

bonsairobo

I need to perform ~20k API calls. To speed things up I wanted to execute them in parallel + using `buffer_unordered` My code looks like this: pub async fn read()...

Enigo

https://docs.rs/futures/latest/futures/io/struct.ReadHalf.html > The readable half of an object returned from `AsyncRead::split`. https://docs.rs/futures/latest/futures/io/struct.WriteHalf.html > The writable half of an object returned from `AsyncRead::split`. Both should be "... returned from `AsyncReadExt::split`"

taiki-e

#### Usecase It would be nice to be able to figure out which branch in the `try_join` statement ran into an error. For example I would like to wrap any...

dvdsk

FuturesUnordered poll ordering guarantees

1

The tokio-postgres crate executes queries in the order in which they are first polled. If two queries depend on each other, then their initial polling order must be the correct...

david-monroe