KR
tokio::sync::mpsc::Sender не иплементит futures::sink::Sink?Size: a a a
2020 June 16
С
... или не решает. Какого черта
там свой sink, т.к. спеки на стримы-синки не синхронизированы, но есть трейт-адаптер
Ct
В токио все еще никакого примитива для отмены тасков не завезли? Всё так же используем
select?С
В токио все еще никакого примитива для отмены тасков не завезли? Всё так же используем
select?ты получаешь handle при spawn, через него вроде можно отменить
С
или в futures был механизм, не помню точно
Ct
ты получаешь handle при spawn, через него вроде можно отменить
spawn вот эту штуку возвращает: https://docs.rs/tokio/0.2.21/tokio/task/struct.JoinHandle.htmlОно только ждать завершения таска позволяет вроде.
С
spawn вот эту штуку возвращает: https://docs.rs/tokio/0.2.21/tokio/task/struct.JoinHandle.htmlОно только ждать завершения таска позволяет вроде.
A
Переслано от Andrew
2020 June 19
AI
так ребят, а где в современном токио искать codec / decoder/encoder / framed?
ph
tokio-util
AI
спасибо
2020 June 21
n
Хочу на основе примера из https://actix.rs/docs/websockets/ сделать так, чтобы можно было в
main создать какого-нибудь актора и прокинуть Recipient<_> на него внутрь функции index из примера, чтобы потом MyWs мог общаться с этим созданным вначале актором. Как такое можно реализовать?n
Пытаюсь через глобальный
tokio::sync::Mutex, ругается что ::new() не constCt
Пытаюсь через глобальный
tokio::sync::Mutex, ругается что ::new() не constБери
lazy_static
n
Бери
lazy_staticДа, с lazy_static заработало, сам не сразу додумался
n
А этот
once_cell::sync::Lazy, он разве что немного удобнее кажется чем lazy_static + оборачивать в OptionMB
А еще он без макросов.
n
А хотя нет, подождите, мне ведь надо в мейне создавать актора, тогда не прокатит
Lazy. Только OnceCell, может с ним даже получится выбросить Mutex