Руслан ).
В fs2 есть комбинатор evalMapAccumulate:
def evalMapAccumulate[S, O2](s: S)(f: (S, O) => F[(S, O2)]): Stream[F, (S, O2)]
По сути стэйтфул мап с эффектом. В akka-streams я похожего не нашел. есть scanAsync, но он эмитит только стейт. Получается, мапнутый элемент надо в стейт втягивать. Может я плохо искал и есть какой-то более элегантный способ?
Может ответили уже... statefulMapConcat это называется в Akka Streams, если я правильно вопрос понял.
Обсуждают сегодня