我已经成功使用FileIO来传输文件的内容,为每一行计算一些转换并聚合/减少结果.
现在我有一个非常具体的用例,我希望在达到条件时停止流,这样就不必读取整个文件,但过程会尽快完成.推荐的方法是什么？
scala akka-stream
akka-stream ×1
scala ×1