Akka Streams中是否存在Flow.batch的逆操作？需拆解Vector为单元素

Akka Stream里有现成的算子可以实现你需要的Flow.batch逆功能，完全匹配你期望的Flow[Vector[T], T, NotUsed]签名。

最适合的是mapConcat算子：

• 它的作用是接收单个输入元素，将其转换为Iterable（Vector本身就属于Iterable），随后把这个Iterable中的每个元素逐个发送给下游，正好完成批量集合到单个元素的拆分。
• 实现代码非常简洁，直接传入identity函数即可：

Flow[Vector[T]].mapConcat(identity)

你也可以用flatMapConcat实现类似效果，写法是Flow[Vector[T]].flatMapConcat(Source(_))，但mapConcat在处理集合展开的场景下性能更优，是更推荐的方案。

内容的提问来源于stack exchange，提问作者Chris Stewart