Привет! Хочется необычного: Пишу p2p-приложение, в котором есть структура Peer, держащая

Question

Привет! Хочется необычного: Пишу p2p-приложение, в котором есть структура Peer, держащая

соединение с каким-то пиром. Юзаю tokio и TcpStream.

Так вот, хочется в методе start(&mut self) разделить стрим на две половины для чтения и записи. Половину чтения отправить в отдельный async-task, где будут читаться сообщения от пира, и отправляться на уровень абстракции выше (наверное через mpsc).
Но отправлять надо не все месседжи, а только с данными. Есть месседжи, меняющие состояние пира, то есть поле в структуре.
Но тут подстава - из отдельного async task нельзя получить доступ к полям.
Что же делать? :(

#backend #embedded #programming #russian #rust

0

07.11.2023

20 ответов

69 просмотров

Revertron ⚛ Автор вопроса

Rustam
в плане нельзя получить доступ к полям?

0

07.11.2023

mental stability🥺✨

Разделяй вне асинка

0

07.11.2023

Revertron ⚛ Автор вопроса

mental stability🥺✨
Разделяй вне асинка

так и делаю, в смысле до новой таски

0

07.11.2023

Rustam

async fn start_read(self: Arc<Self>)

0

07.11.2023

mental stability🥺✨

Revertron ⚛
так и делаю, в смысле до новой таски

Есть сомнения, т.к. в асинк блок захватывается что-то с лайфтаймом &mut self Вероятно, read_half: Struct<'a>

0

07.11.2023

Revertron ⚛ Автор вопроса

mental stability🥺✨
Есть сомнения, т.к. в асинк блок захватывается что...

Да не, там у меня Option<OwnedReadHalf>, из которого я делаю take() перед созданием таска.

0

07.11.2023

mental stability🥺✨

Revertron ⚛
Да не, там у меня Option<OwnedReadHalf>, из которо...

take же отдаёт &mut T

0

07.11.2023

mental stability🥺✨

Revertron ⚛

А есть больше контекста? Нужно понять, почему self захватывается в асинк

0

07.11.2023

кiтя aka. Танечка, aka. Стэф, aka. Мамочка, aka. Виктория, aka. Дарья, aka. Грудь, aka. Лавашик, aka. Не Илья

mental stability🥺✨
А есть больше контекста? Нужно понять, почему self...

А чё тут думать, судя по всему read_half это поле в self

0

07.11.2023

mental stability🥺✨

кiтя aka. Танечка, aka. Стэф, aka. Мамочка, aka. Виктория, aka. Дарья, aka. Грудь, aka. Лавашик, aka. Не Илья
А чё тут думать, судя по всему read_half это поле ...

мне кажется там че-то типа self.stream.into_split().take()

0

07.11.2023

Revertron ⚛ Автор вопроса

mental stability🥺✨
А есть больше контекста? Нужно понять, почему self...

Сначала идёт так: let (read, write) = connection_stream.into_split(); self.read_half = Some(read); self.write_half = Some(write); Потом так: async fn start_read(mut self: Arc<Self>) { let mut read_half = match self.read_half.take() { None => return, Some(half) => half }; let mut buf = vec![0; 16_397]; let mut this = Arc::clone(&self); tokio::task::spawn(async move { let mut read = 0; loop { read_half.readable().await.unwrap(); ... Ну тут я уже пробую предложенный вариант с Arc<Self>

0

07.11.2023

Revertron ⚛ Автор вопроса

Revertron ⚛
Сначала идёт так: let (read, write) = connection_s...

И тут чуть ниже надо записать в булевое поле...

0

07.11.2023

mental stability🥺✨

Revertron ⚛
Сначала идёт так: let (read, write) = connection_s...

А, ну тогда логично всё. Я думал, что into_split делается аккурат перед tokio::spawn. В данном коде остаётся только this.read_half использовать, утащив this в футуру

0

07.11.2023

Revertron ⚛ Автор вопроса

mental stability🥺✨
А, ну тогда логично всё. Я думал, что into_split д...