Hi, I'm trying to run a function (that can fail) repeatedly, and asynchronously, until one of the invocations of the functions returns successfully, with some time delay in between. My current attempt is to have an array of futures, and launch multiple instances of the function, until 10 futures a…

I solved it! Apparently I needed to box and pin the futures: futures.push(some_function().boxed()); For this I also needed the FutureExt trait: use futures::future::FutureExt; Then I obtain the result, the index of the completed future in the futures array and the futures remaining inco…

Select_all for async function with async-std task in tokio runtime

alice December 27, 2019, 3:05pm 4

Note that this discussion has continued here.

Topic		Replies	Views
The trait `Unpin` is not implemented for `GenFuture` (error when using `join_all`)	6	5592	January 12, 2023
Usage of futures::future::select_ok	19	1447	October 17, 2020
The trait Unpin is not implemented for `std::future::GenFuture` help	4	3023	January 12, 2023
[Solved] Is it possible to run async code in a trait method (with StdFuture/async/await)? help	9	3771	January 12, 2023
Using futures::select macro with async functions	1	714	November 12, 2019

Select_all for async function with async-std task in tokio runtime

Related Topics