window в стримах, при использовании suppress чтобы финальный результат агрегации пропагейтился сразу после закрытия окна (grace период нулевой), а не ждал следующего сообщения ?
suppress используется так:
.suppress(untilWindowCloses(Suppressed.BufferConfig.unbounded()))
Интересный вопрос. Я хотел ответить: да просто подождать пока откроется следующее окно, но ведь оно откроется при следующем сообщении
Обсуждают сегодня