我正在寻找一个“聚合器”块在akka-streams。例如,一个块等待直到它接收到3个字符串,然后触发一个操作-比如计算平均长度-并向下传播该操作的结果。
该流将等待接收三个字符串
"hallo" "boat" "cat"
然后评估平均长度
4
然后把它送到下游。实现这一目标的最简单方法是什么?
https://stackoverflow.com/questions/41537172
相似问题