f
fuse он же спасает от того чтобы завершенную фьючу второй раз не заполлить
Size: a a a
2021 February 19
f
чтобы паника не вылетела
MB
fuse он же спасает от того чтобы завершенную фьючу второй раз не заполлить
Да, но это и не может случиться если ты муваешь футуру внутрь селекта
С
Посмотри на abortable из future вместо tokio, может там корректно будет.
f
Да, но это и не может случиться если ты муваешь футуру внутрь селекта
всмысле что он сам следит чтобы фьюча не поллилась если уже вернула Ready?
f
мхм
MB
всмысле что он сам следит чтобы фьюча не поллилась если уже вернула Ready?
Да
f
то есть токиовский селект сам
loop делает?f
прикольно! Посмотрю на него
f
надеюсь он норм работает с фьючами, запущенными из async_std :)
MB
то есть токиовский селект сам
loop делает?Ну почти, только не loop а poll_fn().await: https://github.com/tokio-rs/tokio/blob/master/tokio/src/macros/select.rs#L354
MB
select из futures тоже по циклу поллит переданные футуры, пока какая-нибудь не завершится
f
угу. А если надо дождаться чтобы все завершились, то
loop { select!() }, и потому fusedf
afaict
С
угу. А если надо дождаться чтобы все завершились, то
loop { select!() }, и потому fusedлучше future::FuturesUnordered
f
лучше future::FuturesUnordered
FuturesUnordered не дает паттерн-матч-like синтаксиса
f
select! {
e = stream.select_next_some() => {
// foo(e)
},
_ = fused_future,
e = another_one => {
// bar(e)
}
}f
вот так с FuturesUnordered не выйдет сделать. Можно то же самое руками написать на poll_fn, и обойтись без loop, но это сложный путь
f
могу быть неправ :)
F
А я правильно понимаю, что стейбл расте сейчас нельзя внутри замыкания вызвать что-то с .await?