将 Slick 3.0 查询结果转换为 Akka Streams GraphStage

Question

是否有任何示例可以使用 slick3.0 查询 mysql 并将查询结果转换为 AkkaStream GraphStage？

我不想编写自己的自定义 GraphStage（除非绝对必要）。

我很确定应该有某种方法可以将查询结果转换为 GraphStage

Answer 1

Slick 支持查询结果流，这是通过遵守 Reactive Streams API.

您可以在 Slick 数据库上调用 .stream，并返回 org.reactivestreams.Publisher。

这可以通过调用 Source.fromPublisher(dbPublisher).

包装到 Akka 流中 Source

您可以在 docs, and a complete example in this repo 中找到更多信息。