Slick 3.0のクエリ結果をAkka Streams GraphStageに変換する

Question

somoneがslick3.0を使用してmysqlにクエリを行い、クエリの結果がAkkaStream GraphStageに変換される例はありますか？

自分でカスタムのGraphStageを書いてみたい（絶対に必要な場合を除き）。

私は

Answer 1

スリックは、クエリ結果のストリーミングをサポートGraphStageにクエリ結果を変換するいくつかの方法があるべきことをかなり確信している、そしてそれはReactive Streams APIに付着することによって行われます。

Slickデータベースで.streamと電話して、org.reactivestreams.Publisherに戻ることができます。

これは、Source.fromPublisher(dbPublisher)を呼び出すことによって、AkkaストリームSourceにラップすることができます。

詳細はdocsで、完全な例はthis repoです。