Scala pipelines - 用于构建 DAG 工作流程的 DSL

Question

我对当前的 Scala 和 Akka 库很好奇，它们可以让我优雅地构建工作流程管道。

就我而言，工作流程只是操作的 DAG，因此 actor/Akka 感觉很合适。

我的问题是最好的方法是什么？有像 react 流这样的库，它们允许真正优雅地组成管道，但它们似乎非常注重记录。

我的用例是在它们之间传递消息的操作流程。 future 的组合很好，但一段时间后语法就会变得笨拙。也许scalaz和shapeless有更好的东西。

使用消息传递为计算步骤管道构建 DSL 的方法和工具有哪些？

Answer 1

虽然仍处于早期开发阶段(撰写本文时为 1.0 之前)，但您应该查看 akka-streams ，这正是 - 一种描述计算图然后异步运行它的方法。