python (12.9k questions)

javascript (9.2k questions)

reactjs (4.7k questions)

java (4.2k questions)

java (4.2k questions)

c# (3.5k questions)

c# (3.5k questions)

html (3.3k questions)

Questions - rust-tokio

tokio::select! but for a Vec of futures

I have a Vec of futures which I want to execute concurrently (but not necessarily in parallel). Basically, I'm looking for some kind of select function that is similar to tokio::select! but takes a co...
test-img

Florian Brucker

rust

rust-tokio

Votes: 0

Answers: 2

Latest Answer

This is exactly what futures::stream::FuturesUnordered is for (which I've found by looking through the source of StreamExt::for_each_concurrent): use futures::{stream::FuturesUnordered, StreamExt}; us...
test-img

Florian Brucker

Cannot use `form_urlencoded::Serializer` in `async` function

I have a hyper server set up more or less exactly as the third example here: https://docs.rs/hyper/0.14.16/hyper/server/index.html . My version of the handle function calls some other async functions,...
test-img

BallpointBen

rust

rust-tokio

hyper

x-www-form-urlencoded

Votes: 0

Answers: 1

Latest Answer

Caesar hit the nail on the head. The trick of putting s in a scope fixed it.
test-img

BallpointBen

Rust tokio alternative to fold and map to run a function concurrently with different inputs

I need a way to run the same function many times with different inputs. And since the function depends on a slow web API, I need to run it concurrently and collect the results in one variable. I use t...
test-img

PFA hard

asynchronous

rust

rust-tokio

Votes: 0

Answers: 1

Latest Answer

IIUC what you want, you can use tokio::spawn to launch your tasks in the background and futures::join_all to wait until they have all completed. E.g. something like this (untested): async fn run(input...
test-img

Jmb

Call stored closure from an async closure in rust

I have a closure that mutates variables designed outside of it. How would I go about calling this closure that modifies the state from inside an async scope? I have the following code (abstracted, to ...
test-img

SnailsSeveral

rust

rust-tokio

rust-futures

Votes: 0

Answers: 1

Latest Answer

In rust, usually, you need to use some kind of synchronization mechanisms. It would be really difficult to send a reference to a normal variable. So you would need to use some Arc, RwLock, Mutex depen...
test-img

Netwave

Posts

Questions

Blogs

Jobs