Но ведь тут получается что я из исходного стрима делаю

Question

Но ведь тут получается что я из исходного стрима делаю

"обрезаный вариант", который, допустим, я могу сфолдить в вектор, а как быть со следующей секундой? мне же всё-таки нужен стрим в итоге.
Сорри если вопросы глупые, я в доке заблудился :)

#backend #embedded #programming #russian #rust

0

09.11.2020

8 ответов

15 просмотров

Михаил Автор вопроса

red75prime
Тут нужно что-то вроде let string_stream = ...; le...

не получается только запихать стримы внутрь анфолда

0

09.11.2020

вафель 🧇🍓

Михаил

не получается только запихать стримы внутрь анфолд...

положи их в init

0

09.11.2020

Михаил Автор вопроса

вафель 🧇🍓
положи их в init

чот у меня руки видимо не оттуда растут :( https://gist.github.com/rust-play/6a7dc0913b97edd6fa4e04a824bef3a7 теперь пишет expected tuple, found '()'

0

09.11.2020

Alexey Gerasimov

Михаил
чот у меня руки видимо не оттуда растут :( https:/...

тебе же надо на каждой «итерации» возвращать значение + новое состояние, а ты возвращаешь значение + пустой кортеж

0

09.11.2020

red75prime

Михаил
чот у меня руки видимо не оттуда растут :( https:/...

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

0

09.11.2020

red75prime

red75prime
https://play.rust-lang.org/?version=stable&mode=de...

timer_stream должен быть бесконечным. Если нужно обрабатывать и конечный, надо добавить проверку возвращаемого значения у timer.next()

0

09.11.2020

Михаил Автор вопроса

red75prime
https://play.rust-lang.org/?version=stable&mode=de...

оо, спасибо огромное! теперь понятно где я тупил. Правда я сломался на понимании почему теперь его надо пинить :(

0

09.11.2020

red75prime · Accepted Answer

red75prime

Тут нужно что-то вроде let string_stream = ...; let timer_stream = ...; let window_stream = stream::unfold((), |_| async move { let mut items = vec![]; loop{ select! { _ = timer_stream.next() => { if items.is_empty() { continue }; return Some((items, ())); } item = string_stream.next() => { items.push(item); } }; }; });

0

09.11.2020

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

Но ведь тут получается что я из исходного стрима делаю

8 ответов

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