DF
Благодарю за ликбез!
Size: a a a
2022 January 25
d
в самой футуре, которая должна закенселить другую сторону можно вопользоваться drop_guard, тогда cancel() пошлется автоматом по факту дропа футуры
f
при внешнем cancel tokene как раз можно is_cancelled отдавать в terminated, и получится реализация Fuse.
d
Человеку дали на выбор разные варианты, какой ему удобней решит сам :)
2022 January 29
A
Ребят, посоветуйте плз книгу для зелёного нубаса в беке, чтобы там можно было заюзать раст. Я вот прочёл парочку книг (hands on о игровом ecs и ещё с книгу с крабом - не помню названия), но вот пока что связано с сетью и на расте даже не знаю. Мб кто-нибудь даст совет? (Вроде не оффтоп)
DS
Тебе сюда @rust_beginners_ru
M
pub struct MyActor {
rx: Receiver<Msg>
}
impl MyActor {
pub fn new(rx: Receiver<Msg>) -> Self {
Self { rx: rx }
}
}
impl Actor for MyActor {
type Context = actix::prelude::Context<Self>;
fn started(&mut self, ctx: &mut Self::Context) {
Self::add_stream(ReceiverStream::new(self.rx), ctx);
}
}
impl StreamHandler<Msg> for MyActor {
}
ReceiverStream::new забирает владение своего аргумента, и я даже не против отдать - только вот как?
rx: Receiver<Msg>
}
impl MyActor {
pub fn new(rx: Receiver<Msg>) -> Self {
Self { rx: rx }
}
}
impl Actor for MyActor {
type Context = actix::prelude::Context<Self>;
fn started(&mut self, ctx: &mut Self::Context) {
Self::add_stream(ReceiverStream::new(self.rx), ctx);
}
}
impl StreamHandler<Msg> for MyActor {
}
ReceiverStream::new забирает владение своего аргумента, и я даже не против отдать - только вот как?
D
хз как принято в актиксе, но всегда можно сделать
и отдавать через
pub struct MyActor {
rx: Option<Receiver<Msg>>
}и отдавать через
self.rx.take().unwrap()M
Спс! То есть все же требуется грязный хак.
D
так, подожди
не, я всё же хз)
не, я всё же хз)
M
Проблема в том, что started() вызываю не я, а сам актикс, и где передержать переменную, чтобы избавиться от нее только там - я никак не придумаю.
M
Вот любопытно стало - а каким образом вообще имеется тотальная несовместимость между самыми свежими версиями actix, actix-rt и actix-web, если все это тесно взаимосвязано? Почему actix 0.12 конфликтует с actix-web 4.0, к примеру и они зависят от очень сильно разных actix-rt?
2022 January 30
ph
Что конфликтует? У обоих actix-rt 2
M
Ну там есть некие магические работающие комбинации, которые ни разу не включают в себя свежий actix 0.12, к примеру - всегда более древний.
M
На stackoverflow много подобных вопросов и ответов.
ph
actix-web = "4.0.0-beta.10"
actix = "0.12"
У меня все работает 🤷♀️
actix = "0.12"
У меня все работает 🤷♀️
M
А если актора своего сделать? Beta.10 зависит от actix_rt 2.2, а actix - от 2.0
D
зависимость от 2.0 не противоречит 2.2
D
всё ок вроде