複数のシンクが

Question

私はこの二つのシンクなどのストリームを持っているが、一方のみが一度に使用されます。

Source.fromElements(1, 2, 3) 
.via(flow) 
.runWith(sink1) 

または

Source.fromElements(1, 2, 3) 
.via(flow) 
.runWith(sink2) 

それは設定可能です我々が使用沈みます両方のシンクを並行して使用するとどうなりますか？ どうすればいいですか？

私はSink.combineについて考えましたが、マージ戦略も必要であり、これらのシンクの結果をどのように組み合わせても構いません。私は本当に気にしないので、同じデータをHTTP経由でいくつかのエンドポイントに送信し、同時にそれらをデータベースに送信したいと思います。 シンクの組み合わせはブロードキャストと非常によく似ていますが、スクラッチからブロードキャストを実装するとコードの可読性が低下します。シンプルなソース、フロー、シンクしかなく、低レベルのグラフステージはありません。

あなたはそれを行うための適切な方法を知っていますか（背圧と、1つのシンクだけを使用している他のもの）？

Answer 1

あなたは（API docsを参照）alsoToを使用することができます。

Flow[Int].alsoTo(Sink.foreach(println(_))).to(Sink.ignore) 

Answer 2

放送は可読性を低下させてはならない最も単純な形式でGraphDSLを使用して - 実際には、1にも何らかの形で~>節が視覚化することを主張するかもしれませんストリーム構造：

val graph = RunnableGraph.fromGraph(GraphDSL.create() { implicit builder => 
    import GraphDSL.Implicits._ 
    val bcast = builder.add(Broadcast[Int](2)) 

    Source.fromElements(1, 2, 3) ~> flow ~> bcast.in 
    bcast.out(0) ~> sink1 
    bcast.out(1) ~> sink2 

    ClosedShape 
}) 
graph.run()