Привет, подскажите плиз
Если у меня есть сервис и внутри него есть поле dao:

struct Service{
 dao: MyDao<La>
}

При этом чтобы вызвать дао self должен быть: &mut self

Как собственно в Futures/Tokio стримах (внутри future/async) вызывать self метод (self.some_work(i) ), который дальше вызовет метод дао (self.dao.insert) требующий мутабельности?

Такой вариант не работает 🙁


async fn some_work(&mut self, …)->hz {
 …
 .then(|i| move async {
     self.call_self_method(i).await
   }).collect().await.unwrap();
 …
}

другой async self метод :

async fn call_self_method(&mut self, I: SomeType)->hz {
 …
 self.dao.insert(i).await
}

Как собственно правильно это делать в Futures/Tokio стримах?

Привет, а на что компилятоп ругается?

если просто вызвать метод self.call_self_method внутри стрима:

…
 .then(|i| move async {
     self.call_self_method(i).await
   }).collect().await.unwrap();
 …

cannot move out of self, a captured variable in an FnMut closure

Если сделать обернуть поле с dao Rc + Mutex, то при вызове self.call_self_method(i).await ничего не меняется

Ну во-первых вижу move async, насколько знаю должно быть async move
Во-вторых здесь этот move не нужен, как раз компиль коворит что ты пытаешься передать владение self в кложуру

Стрим же этот только до конца метода живет?

это опечатка, упростил пример

А, какой тип у i ?

Всмысле не Copy?

упростил для примера. После конвертации объекта в стринг летит такая ошибка

captured variable cannot escape FnMut closure body

returns an async block that contains a reference to a captured variable, which then escapes the closure body

вопрос в чём: как грамотно дергать async функции внутри актикс акторов?

и ещё вопрос: правда ли, что actix использует однопоточный рантайм? а следовательно и сами акторы исполняются только в одном потоке?

Интересует именно actix, не actix-web