MB
Abortable<Future<Output = ()>>doesn't have a size known at compile-time
Box<dyn Future<Output = ()>>
doesn't have a size known at compile-time
Size: a a a
2020 December 18
doesn't have a size known at compile-time
MB
Точнее Pin<Box<...>>
AT
Точнее Pin<Box<...>>
тогда простите за тупой вопрос, а как из Abortable::new() сделать Pin<Box>?
K
тогда простите за тупой вопрос, а как из Abortable::new() сделать Pin<Box>?
Лучш параметризовать дженериком и не боксить ничего
AT
отбой, все сломалось.
dyn futures::Future<Output = ()> + 'static)` cannot be sent between threads safely
надо мне что-то другое придумывать
dyn futures::Future<Output = ()> + 'static)` cannot be sent between threads safely
надо мне что-то другое придумывать
IB
Лучш параметризовать дженериком и не боксить ничего
It depends. Ему их нужно складывать в контейнер.
IB
отбой, все сломалось.
dyn futures::Future<Output = ()> + 'static)` cannot be sent between threads safely
надо мне что-то другое придумывать
dyn futures::Future<Output = ()> + 'static)` cannot be sent between threads safely
надо мне что-то другое придумывать
Pin<Box<dyn Futures ... + Sync + Send>>
K
struct MegaTimer<F> {
future: Abortable<F>
abort_handle: AbortHandle,
}
async fn timer_future(...) -> MegaTimer<impl Future<Output = ()>> { .. }что-то такое кажется должно работать
АГ
ну, процедуры же бывают)
Процедура это функция, возвращающая unit (
() )AT
struct MegaTimer<F> {
future: Abortable<F>
abort_handle: AbortHandle,
}
async fn timer_future(...) -> MegaTimer<impl Future<Output = ()>> { .. }что-то такое кажется должно работать
это все сильно усложняет, потому что много где появляется этот <F>
попробую с + Sync + ...
попробую с + Sync + ...
K
это все сильно усложняет, потому что много где появляется этот <F>
попробую с + Sync + ...
попробую с + Sync + ...
зато зирокостненько и блейзинг фаст
AT
а можно как-то конкретизировать параметр? чтоб не писать везде <F>
K
Ну и да, к подобным "протеканиям" стоит быть готовым. Не переписывать же половину кода, если вдруг один внутренний тип внезапно надо будет параметризовать. В частности если обобщить
State, то вероятно подобная проблема для *State типов уйдетK
а можно как-то конкретизировать параметр? чтоб не писать везде <F>
Можно написать свой тип-футуру, но мне кажется ты этого не хочешь
AT
Можно написать свой тип-футуру, но мне кажется ты этого не хочешь
может, я вообще не то делаю?) не знаю, как идиоматичнее.
IB
А вообще зачем тебе хранить Abortable? Тебе его надо отправить на выполнение. А в таймере хранить только AbortHandle.
AT
есть tbot, у которого хендлеры - |context, state| async move { … }
в хендлере я могу получить доступ к state.read().await
при создании бота происходит:
[СЮДА]
в [СЮДА] мне нужно создать футуру и положить ее в стейт, чтобы хендлеры могли из стейта останавливать/ресетать/стартовать
в хендлере я могу получить доступ к state.read().await
при создании бота происходит:
let bot = Bot::from_env("TG_TOKEN");
let start_state = State::default();[СЮДА]
let mut event_loop = bot.stateful_event_loop(start_state);
event_loop.command(…);
…
event_loop.polling().start().await.unwrap();в [СЮДА] мне нужно создать футуру и положить ее в стейт, чтобы хендлеры могли из стейта останавливать/ресетать/стартовать
AT
сформулировал на случай проблемы XY
AT
А вообще зачем тебе хранить Abortable? Тебе его надо отправить на выполнение. А в таймере хранить только AbortHandle.
эти футуры обычно крутятся вечно, выполнилось - и заново пошла.
IB
Футуры разве не одноразовые?