scala - 从 scalaz 流过程中收集结果

Question

最近我开始在 Scala/Akka 中使用 scalaz 流。我正在从 nosql 数据库中获取记录。我想将记录映射到消息项（通过translateItem: Item）并创建它们的包（1 个包 = 100 个项）。例如，有 500 条记录。

 val readChunks = records.chunk(100)
 val createPackages = readChunks.map(chunk => translateItem(chunk))
                                .map(i => toPackage(i))
 val result = createPackages.runLog.run.toList

我试图List[Package]通过runLog. 日志的输出看起来不错。但我不需要日志记录开销。

但是如何将结果写入列表，例如？

或者我可能会返回 aFuture[List[Package]]并将其传递给 Akka actor 以获取 ( Await.result) 它。我可能会将 scalaz 转换Task为Future.

提前致谢。