Size: a a a

2021 March 16

D

Denis in Rust Async
если такого жёсткого требования нет, то по идее tokio::select! должен решить вопрос
источник

D

Denis in Rust Async
он там внутри в условно-случайном порядке поллит
источник

в🧇

вафель 🧇 in Rust Async
Fortunato
Вот как futures::join_all(), только возврат в порядке выполнения
FuturesUnordered?
источник

F

Fortunato in Rust Async
Denis
если такого жёсткого требования нет, то по идее tokio::select! должен решить вопрос
Так там ведь только на одну фьючу реакция будет?
источник

D

Denis in Rust Async
Fortunato
Так там ведь только на одну фьючу реакция будет?
да
источник

D

Denis in Rust Async
вафель 🧇
FuturesUnordered?
^ this
источник

D

Denis in Rust Async
только не совсем понятно значение фразы

> и узнать потом, какая выполнилась первой
источник

D

Denis in Rust Async
ну, можно обернуть фьючу и добавить к результату какой-нибудь счётчик :)
источник

s

std::mpa in Rust Async
Denis
только не совсем понятно значение фразы

> и узнать потом, какая выполнилась первой
наверное, поллить много футур одновременно, пока одна не выполнится
источник

ph

pl 🦑 hk in Rust Async
источник

D

Denis in Rust Async
> Upon completion the item resolved will be returned, along with the index of the future that was ready and the list of all the remaining futures

10/10
источник

F

Fortunato in Rust Async
То, что нужно, спасибо
источник

F

Fortunato in Rust Async
А пример использования этого добра есть где? А то он мне ошибку с Unpin вываливает
источник

F

Fortunato in Rust Async
источник

D

Denis in Rust Async
ну, асинк-генератор возвращает футуру, которая не имплементит Unpin
источник

D

Denis in Rust Async
ты можешь либо запинить футуры на стеке, либо забоксить
источник

F

Fortunato in Rust Async
Ага, спасибо
источник
2021 March 22

MF

Max Frai in Rust Async
Подскажите, я раньше делал
tokio::task::spawn(async move {
Но мне нужно там использовать библиотеку где тип не Send. Посоветовали взять LocalSet:
local.run_until(async move {
все работает компилится, но мне не нужно блокировать поток и делать await на run_until, а без этого оно не выполняется. spawn же запускал логику и не требует await
источник

K

Kitsu in Rust Async
spawn_local?
источник

MB

Mikail Bagishov in Rust Async
По идее, LocalSet надо гонять на отдельном потоке, и потом пересылать в него футуры, которые надо выполнить (ну вернее штуки вида FnOnce() -> Future).
источник