akka 流中`Flow.batch`的逆

Question

是否有相反的

Flow.batch

我希望方法的签名是

Flow[Vector[T],T,NotUsed]

它应该打开

Vector

并将

Vector

下游的每个元素作为单个元素发出。

Answer 1

正如 Levi 在评论中所说，答案是

mapConcat

。正如文档所说，这个运算符“将每个元素转换为零个或多个元素，这些元素单独传递到下游。这可用于将集合展平为单个流元素。”

如果您想生成源而不是可迭代，请参阅

flatmapConcat

。