是否存在Flow.batch的逆我希望方法的签名是Flow[Vector[T],T,NotUsed]它应该展开一个Vector，并将Vector的每个元素作为单个元素向下游发出。
Flow.batch
Flow[Vector[T],T,NotUsed]
Vector
cxfofazt1#
正如Levi在评论中所说，答案是mapConcat。正如the docs所说，这个操作符“将每个元素转换为零个或多个元素，这些元素被单独传递到下游。这可以用于将集合扁平化为单个流元素。”如果你想生成一个源代码而不是一个可迭代对象，请参见flatmapConcat。
mapConcat
flatmapConcat
1条答案
按热度按时间cxfofazt1#
正如Levi在评论中所说，答案是
mapConcat。正如the docs所说，这个操作符“将每个元素转换为零个或多个元素，这些元素被单独传递到下游。这可以用于将集合扁平化为单个流元素。”如果你想生成一个源代码而不是一个可迭代对象，请参见
flatmapConcat。