1
4

1 回答 1

1

如果我理解正确,案例类 A 本质上是函数 A => Seq[B]

那么解决方案可能是

val sourceB: Process[Task,B] = sourceA.flatMap(emitAll(_.elems))
于 2014-12-12T07:03:10.830 回答