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

потому что не все футуры - корневые (или наоборот, листовые, если таску считать корнем). Не нужно вручную делать wake если вы поллите другую футуру внутри своей, нужно лишь передать контекст вниз по стеку вызовов, и он зарегается в самом низу. Вручную его дергать надо только если нет других футур, резолва которых вы ожидаете, тот есть ваша футура и есть конечная

источник

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

Casual tears in Rust Async

¯\_(ツ)_/¯

а можно let _ = tasks.iter().map(|t| t.abort());?

Надо for_each вместо map, иначе у тебя abort не вызовется.

источник

18:43пожаловаться #6

2020 September 08

Piu Piu in Rust Async

> If you want to work more directly with the streams and sink, consider calling split on the UdpFramed returned by this method, which will break them into separate objects, allowing them to interact more easily.

подскажите пытаюсь заюзать UdpFramed из tokio-util

про какой split имеется в виду в документации? не очень понимаю

источник

10:41пожаловаться #7

Vetro in Rust Async

Piu Piu

> If you want to work more directly with the streams and sink, consider calling split on the UdpFramed returned by this method, which will break them into separate objects, allowing them to interact more easily.

подскажите пытаюсь заюзать UdpFramed из tokio-util

про какой split имеется в виду в документации? не очень понимаю

https://docs.rs/tokio/0.2.22/tokio/io/fn.split.html

docs.rs

tokio::io::split - Rust

API documentation for the Rust `split` fn in crate `tokio`.

источник

10:42пожаловаться #8

Piu Piu in Rust Async

Vetro

https://docs.rs/tokio/0.2.22/tokio/io/fn.split.html

docs.rs

tokio::io::split - Rust

API documentation for the Rust `split` fn in crate `tokio`.

the trait bound tokio_util::udp::frame::UdpFramed<net::Codec>: tokio::io::async_write::AsyncWrite is not satisfied
the trait tokio::io::async_write::AsyncWrite is not implemented for tokio_util::udp::frame::UdpFramed<net::Codec>

источник

10:43пожаловаться #9

Piu Piu in Rust Async

нет имплов AsyncRead и AsyncWrite для UdpFramed

источник

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

Vetro in Rust Async

тогда https://docs.rs/futures-util/0.3.5/futures_util/stream/trait.StreamExt.html#method.split

для Stream + Sink

docs.rs

futures_util::stream::StreamExt - Rust

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

источник

10:45пожаловаться #11

Vetro in Rust Async

а их UdpFramed точно имплементит

источник

10:46пожаловаться #12

Piu Piu in Rust Async

Vetro

тогда https://docs.rs/futures-util/0.3.5/futures_util/stream/trait.StreamExt.html#method.split

для Stream + Sink

docs.rs

futures_util::stream::StreamExt - Rust

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

шаришь

я тупой опять взял StreamExt из токио стрима а не из футурс

источник

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

Anton in Rust Async

Товварищи, есть какой нить аналог LocalSet для rt-threaded?

источник

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

Anton in Rust Async

Мне нужно создать пул заспавнить туда таски, и дождатся их выполнения

источник

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

Anton in Rust Async

Можно конечно в FuturesUnordered joinHandle складывать, но как то все некрасиво

источник

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

Denis in Rust Async

Anton

Можно конечно в FuturesUnordered joinHandle складывать, но как то все некрасиво

да вроде норм схема

источник

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

Anton in Rust Async

Denis

да вроде норм схема

но красивей былобы

let task_set = TaskSet::new();
for .. {
    task_set.spawn(async move {})
}
task_set.await

источник

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

Denis in Rust Async

сделай обвязку :) готового вроде ничего нет

источник

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

pl 🦑 hk in Rust Async

https://docs.rs/waitgroup/0.1.1/waitgroup/

docs.rs

waitgroup - Rust

API documentation for the Rust `waitgroup` crate.

источник

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