akka-поток потоков с отслеживанием состояния подпотока

#scala #akka #akka-stream Вопрос: Существует поток с отслеживанием состояния: val stream = Flow[Event].statefulMapConcat { () => val state = ... { element => // change the state element :: Nil…