RP
о да, спасибо =)
Size: a a a
2021 November 26
RP
рад, что документация развивается, и не надо перелопачивать тонны кода и ставить гипотезы, чтобы разобраться в подобного рода вещах
RP
ого. знатно
2021 December 04
УМ
привет, я мимопроходил, учу Токио. стало интересно, можно ли каким-то образом реализовать трекинг "прогресса" футур? то есть мы имеем какую-то футуру с 7ю await-ами, мы её поллим и видим, что она ещё Pending, но при этом можем скзаать, что в ней 5 из 7ми await-ов уже прошли.
DF
а откуда нам знать что там 7 авейтов а не 99?)
DF
ведь каждый авейт может произвольное число раз вернуть Pending, хоть бесконечное
УМ
это понимаю
УМ
это не очень
DF
у тебя рантайм поллит твою футуру когда захочет
RP
можно. делаешь
struct TrackingFuture<F: Future> {
future: F.
num_pending: usize,
}
impl Future for TrackingFuture {
fn poll(...) {
let res = self.future.poll(...);
if res is pending {
self.num_pending += 1;
}
res
}
}
struct TrackingFuture<F: Future> {
future: F.
num_pending: usize,
}
impl Future for TrackingFuture {
fn poll(...) {
let res = self.future.poll(...);
if res is pending {
self.num_pending += 1;
}
res
}
}
RP
к примеру, можно туда и название футуры закинуть и какой-нибудь id генератор и сливать инфу в прометеус
П
Если реализуешь футуру ручками, то реализуй для нее дебаг, например
УМ
в общем из того что я вижу можно сказать, что
стандартный тип футуры нужно расширить из
стандартный тип футуры нужно расширить из
pub enum Poll<T> {
Ready(T),
Pending,
}
вpub enum Poll<T, P = ()> {
Ready(T),
Pending(P),
}
что даст возможность возвращать что угодно (в т.ч. инфу о прогрессе) из Pending футур. а ещё сломает весь существующий асинк кодУМ
как именно?
RP
так я тебе выше показал
П
impl Future for MyEnum
MB
Тут явно не это нужно
MB
Руками await-ы разворачивать сомнительное удовольствие
П
Но можно же :D