Как в цикле .chain-ить несколько Stream и вернуть результирующий?

Question

Как в цикле .chain-ить несколько Stream и вернуть результирующий?

let mut submissions = stream_map_submissions(posts);

while let Some(after) = maybe_after {
posts = cfg.subreddit
.hot(100, Some(FeedOption::new().after(&after)))
.await?;
maybe_after = posts.data.after.clone();
submissions = submissions.chain(stream_map_submissions(posts))
}
Типа этого, но так нельзя, type mismatch

#backend #embedded #programming #russian #rust

0

24.08.2021

8 ответов

22 просмотра

constant suffering Автор вопроса

вафля'
Ну можно попробовать забоксить submissions

let submissions: Box<dyn Stream<Item=X>> ?

0

24.08.2021

вафля'

вафля'
Ну можно попробовать забоксить submissions

Pin<Box<dyn Stream + Send>> и всё такое

0

24.08.2021

constant suffering Автор вопроса

вафля'
Pin<Box<dyn Stream + Send>> и всё такое

Блин, страшно..

0

24.08.2021

вафля'

constant suffering
let submissions: Box<dyn Stream<Item=X>> ?

Ну примерно, да. Можешь алиас из futures использовать https://docs.rs/futures/0.3.16/futures/stream/type.BoxStream.html let submissions: BoxStream<_> = Box::pin(...);

0

24.08.2021

constant suffering Автор вопроса

вафля'
Ну примерно, да. Можешь алиас из futures использов...

Оо, так выглядит менее страшно.. Какие минусы такого подхода?

0

24.08.2021

вафля'

constant suffering
Оо, так выглядит менее страшно.. Какие минусы тако...

Ну боксинг происходит. Но ты рекурсию без боксинга anyway не сделаешь, так что :shrug:

0

24.08.2021

constant suffering Автор вопроса

вафля'
Ну боксинг происходит. Но ты рекурсию без боксинга...

В общем ладно, сильно медленнее стать не должно. У меня было что несколько функций возвращают футуру от Vec<_> и с этим работают. Я решил что пускай все они стримы возвращают..

0

24.08.2021

вафля' · Accepted Answer

вафля'

Ну можно попробовать забоксить submissions

0

24.08.2021

172 похожих чатов

Как в цикле .chain-ить несколько Stream и вернуть результирующий?

8 ответов

Похожие вопросы