Find centralized, trusted content and collaborate around the technologies you use most.
Teams
Q&A for work
Connect and share knowledge within a single location that is structured and easy to search.
如果我理解正确,案例类 A 本质上是函数 A => Seq[B]
那么解决方案可能是
val sourceB: Process[Task,B] = sourceA.flatMap(emitAll(_.elems))