f
Хотя нет. Всё равно не очень понятно, одинаковый ли эффект имеет
context.waker.wake() и возвращение Poll::Ready. Или, может, немного разный.Size: a a a
2021 January 18
f
с тз просыпания и повторного полла стрима
D
это ортогональные вещи
f
Ну у меня вот есть выбор
или
if (workDone) {
context.waker().wake()
return Poll::Pending
}или
if (workDone) {
return Poll::Ready(())
}D
не очень понятно, как первый вариант должен работать в принципе
D
если ты пендинг возвращаешь, то откуда пользователь будет значения получать?
f
если ты пендинг возвращаешь, то откуда пользователь будет значения получать?
ему не надо ничего получать, я ничего не возвращаю никогда. У меня просто есть loop с процессингом внутри. Процессинг инертный, т.е. его надо вот так вот поллить
D
может тебе проще таску для этого заспавнить отдельную?
f
Вот почему я вообще делаю этот выбор
vs.
if (A.poll().is_ready()) {
context.waker().wake()
}
if (B.poll().is_ready()) {
context.waker().wake()
}
return Poll::Pendingvs.
if (A.poll().is_ready()) {
return Poll::Ready(())
}
if (B.poll().is_ready()) {
return Poll::Ready(())
}
return Poll::PendingD
эти два решения принципиально разные
f
в первом случае я и A и B протолкну разом, и буду иметь 1 return в функции. А во втором случае дерну сначала один, потом другой, и буду иметь несколько return-ов
D
в первом случае ты всегда поллишь и A и B, а во втором если A готово, то B не поллится
f
ну да, Бэ голодать будет
D
а зачем ты вообще это делаешь, если можно заменить на
select!?f
let a_ready = A.poll().is_ready();
let b_ready = B.poll().is_ready();
if (a_ready || b_ready) {
return Poll::Ready(())
}
return Poll::Pendingf
а зачем ты вообще это делаешь, если можно заменить на
select!?на селект не получится, селект работает только с фьючами, на уровень выше, в async контексте. Он с Poll не работает напрямую.
f
ну, я могу ошибаться конечно
D
так зачем теде полл вручную дёргать-то?
f
на меня это спущено сверху, libp2p
f
но оно в итоге шедулится в обычном экзекьюторе, так что должны работать те же правила, что и у любых стримов/фьючей