Телеграмм чат группы rust

Предполагаю, что нужно "ручками склеивать" стримы. Видел, как мне кажется, похожее решение в примерах tokio https://github.com/tokio-rs/tokio/blob/master/examples/chat.rs#L164:L184 Может поможет

GitHub

tokio-rs/tokio

A runtime for writing reliable asynchronous applications with Rust. Provides I/O, networking, scheduling, timers, ... - tokio-rs/tokio

Товарищи, вчера был вопрос про объединение нескольких стримов с возможностью добавления/удаления
По наводке сделал минимальный пример с кастомным стримом в котором уже лежит вектор с другими стримами.. возможно кому-нибудь пригодится!

https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=233f67cc1f0387051e10123b2af080ca

источник

12:13пожаловаться #4

V

Vetro in Rust Async

mAX

Товарищи, вчера был вопрос про объединение нескольких стримов с возможностью добавления/удаления
По наводке сделал минимальный пример с кастомным стримом в котором уже лежит вектор с другими стримами.. возможно кому-нибудь пригодится!

https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=233f67cc1f0387051e10123b2af080ca

Бывший плюсовик? Сужу чисто по полному прописыванию пути к элементам стд)

источник

13:13пожаловаться #5

m

mAX in Rust Async

Vetro

Бывший плюсовик? Сужу чисто по полному прописыванию пути к элементам стд)

Да, немного на разном пишу.. Си/С++, Golang, js/ts/dart раст самый классный!
полные пути прописывать мне как-то удобнее что ли, я часто теряюсь если не вижу std::.. кажется что это что-то из пользовательского кода

источник

17:45пожаловаться #6

AI

Alex Ilizarov in Rust Async

mAX

Да, немного на разном пишу.. Си/С++, Golang, js/ts/dart раст самый классный!
полные пути прописывать мне как-то удобнее что ли, я часто теряюсь если не вижу std::.. кажется что это что-то из пользовательского кода

тоже пока среди тих больше раст нравится. С дартом не работал правда

источник

18:30пожаловаться #7

2020 July 01

m

mAX in Rust Async

Товарищи, подскажите пожалуйста.. можно ли как-то сделать poll_next у потока, но при этом не забирать значение, а просто посмотреть значение, и после анализа уже решить забирать из потока его или нет

источник

15:49пожаловаться #8

D

Denis in Rust Async

mAX

Товарищи, подскажите пожалуйста.. можно ли как-то сделать poll_next у потока, но при этом не забирать значение, а просто посмотреть значение, и после анализа уже решить забирать из потока его или нет

https://docs.rs/futures-util/0.3.5/futures_util/stream/trait.StreamExt.html#method.peekable

docs.rs

futures_util::stream::StreamExt - Rust

API documentation for the Rust `StreamExt` trait in crate `futures_util`.

источник

15:54пожаловаться #9

m

mAX in Rust Async

Denis

https://docs.rs/futures-util/0.3.5/futures_util/stream/trait.StreamExt.html#method.peekable

docs.rs

futures_util::stream::StreamExt - Rust

API documentation for the Rust `StreamExt` trait in crate `futures_util`.

Спасибо, большое! Буду изучать

источник

18:49пожаловаться #10

D

Denis in Rust Async

mAX

Спасибо, большое! Буду изучать

да не за что, и изучать там в общем-то нечего )

источник

18:49пожаловаться #11

m

mAX in Rust Async

Сделал минимальный пример с poll_peek()
https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=4c2ac87ce2d714c6b15dc5b3e4fe7181
в двух случаях работает по-разному..
когда внутри tokio::spawn() отправляю значения в UnboundedSender, то мой poll снаружи tokio::spawn() не дергается..
но если сделать фьючу и дернуть сразу обе через join!(), то все работает как нужно

Правильно ли я понял и написал в комментариях что tokio::spawn создает новый цикл обработки сообщений, который не связан с общим? Или это что-то другое?

источник

19:53пожаловаться #12

m

mAX in Rust Async

если добавить #[tokio::main(basic_scheduler)], то с tokio::spawn приходит на один элемент больше, чем просто #[tokio::main]

https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=21e81a58c8bb41b701104841f9304007

источник

20:13пожаловаться #13

d

diabolo in Rust Async

mAX

Сделал минимальный пример с poll_peek()
https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=4c2ac87ce2d714c6b15dc5b3e4fe7181
в двух случаях работает по-разному..
когда внутри tokio::spawn() отправляю значения в UnboundedSender, то мой poll снаружи tokio::spawn() не дергается..
но если сделать фьючу и дернуть сразу обе через join!(), то все работает как нужно

Правильно ли я понял и написал в комментариях что tokio::spawn создает новый цикл обработки сообщений, который не связан с общим? Или это что-то другое?

просто программа там завершается раньше, чем до дела доходит)

источник

20:13пожаловаться #14

m

mAX in Rust Async

diabolo

просто программа там завершается раньше, чем до дела доходит)

но ведь с join нормально работает

источник

20:13пожаловаться #15

m

mAX in Rust Async