我想知道是否有一种优雅的方式来实现这样的目标:
val l = Stream.from(1)
val parts = l.some_function(3) //any number
parts.foreach( println(_) )
> 1,4,7,10...
> 2,5,8,11...
> 3,6,9,12...
实际上我需要在Streams上进行并行化这样的操作 - 在多个actor之间拆分数据而不将整个内容加载到内存中.