m
понятно как сделать это если async {}
и внутри
и внутри
tokio::time::delay_for(std::time::Duration::from_micros(step_delay_us)).await;Size: a a a
2020 July 07
m
но как сделать если я хочу внутри poll_next такое?
m
те poll_next с задержкой)
KR
Создаёшь Delay, либо Interval и поллишь их внутри своего poll_next
V
Товарищи, а можно как-то фьюче задать чтобы poll дернулся через определенное время?
типа как cx.waker().wake_by_ref(); но с задержкой, а не сразу
типа как cx.waker().wake_by_ref(); но с задержкой, а не сразу
Как вариант, думаю, можно внутри держать https://docs.rs/tokio/0.2.21/tokio/time/struct.Delay.html и его поллить
V
А, уже ответили
V
Интернет)
V
А вообще вопрос скорее нужны ли вам манипуляции именно с ручными имплементациями футур?
KR
Vetro
А вообще вопрос скорее нужны ли вам манипуляции именно с ручными имплементациями футур?
Часто они очень удобны.
m
Понятно, спасибо! я думал есть вариант как-то уведомить контекст через waker что хочу через какое-то время подергать poll)
m
ну я сделал реализацию сперва просто на async/await
потом удобно было кое-что завернуть внутрь кастомного стрима
да, видимо иногда удобно
потом удобно было кое-что завернуть внутрь кастомного стрима
да, видимо иногда удобно
D
Понятно, спасибо! я думал есть вариант как-то уведомить контекст через waker что хочу через какое-то время подергать poll)
1) У вейкера всего два-три метода
2) Магии нет
Делаем выводы )))
2) Магии нет
Делаем выводы )))
KR
Понятно, спасибо! я думал есть вариант как-то уведомить контекст через waker что хочу через какое-то время подергать poll)
Он споллит фьючу таймера и вернётся Pending, а когда таймер дотикает, то будет вызван вейкер и твой таск споллят снова.
D
я юзал пока писал в async
а теперь у меня такая ситуация что есть стрим какой-то из которого вылятся элементы, а я хочу их выдавать раз в секунду допустим
а теперь у меня такая ситуация что есть стрим какой-то из которого вылятся элементы, а я хочу их выдавать раз в секунду допустим
m
Понятно, спасибо!) балдею от раста блин..
KR
ну я сделал реализацию сперва просто на async/await
потом удобно было кое-что завернуть внутрь кастомного стрима
да, видимо иногда удобно
потом удобно было кое-что завернуть внутрь кастомного стрима
да, видимо иногда удобно
Особенно если до дропов доходит.
2020 July 08
KR
PP
Ого, крутяк. Как-то раньше не замечал
ее вроде выпиливали когда на 0.2 переход был потом опять вернули помню как искал когда переписывал проект на 0.2
2020 July 10
A