о, спасибо, попробую!

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

мне по сути не понятно как в расте сделать что-то похожее на вот такое поведение: https://rxjs.dev/api/operators/window

доступен
облегчило дело

Тут нужно что-то вроде

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);
     }
    };
  };
});

можно на stream_generator условно как-то так

loop {
  let mut buf = Vec::new();
  select! {
    line => input.next() => {
       buf.push(line);
    }
    timer => timer.next() => {
      yielder.send(buf);
    }
}

а можно как-то скомпилировать и запустить тесты без сборки основного проекта?

А что тесты будут тестировать?

основной проект - это группа васм модулей, которые не компилятся в натив. А тесты - это способ запустить их в отдельном рантайме, они нужны больше для CI, где сначала будут скомпилены васмы отдельной командой.

В бигинерсах не отвечают, задам вопрос здесь 😁 В одном из топиков расткона заявили, что после "недавних изменений в васм" можно веб приложения делать только с использованием васм/раст. Может в кратце кто нить объяснить, что за изменения? Дали прямой доступ к дом дереву и все браузерным апи?

use это импорт библиотек?

Скорее импорт имён https://doc.rust-lang.org/reference/items/use-declarations.html

да

импорт библиотек - в Cargo.toml

так в книге все это есть. правда быстрее будет книгу пройти, чем в чате спрашивать

я параллельно прохожу книгу и копаюсь в проекте. Но кажется, в русскоязычной не все есть

дело конечно твое. может тогда в https://t.me/rust_beginners_ru базовые штуки спрашивать

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);
     }
    };
  };
});

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

положи их в init

чот у меня руки видимо не оттуда растут :(
https://gist.github.com/rust-play/6a7dc0913b97edd6fa4e04a824bef3a7

теперь пишет expected tuple, found '()'