내가 하려고 concat 두 개의 흐름과 저는지 설명할 수 있 출력을 나의 구현합니다.
val source = Source(1 to 10)
val sink = Sink.foreach(println)
val flow1 = Flow[Int].map(s => s + 1)
val flow2 = Flow[Int].map(s => s * 10)
val flowGraph = Flow.fromGraph(
GraphDSL.create() { implicit builder =>
import GraphDSL.Implicits._
val concat = builder.add(Concat[Int](2))
val broadcast = builder.add(Broadcast[Int](2))
broadcast ~> flow1 ~> concat.in(0)
broadcast ~> flow2 ~> concat.in(1)
FlowShape(broadcast.in, concat.out)
}
)
source.via(flowGraph).runWith(sink)
나는 다음 출력에서 이 코드입니다.
2
3
4
.
.
.
11
10
20
.
.
.
100
대신,나만 보"2"되고 인쇄했습니다. 할 수 있는 것은 잘못이 무엇인지 설명해 내 implmentation 어떻게 변화 프로그램으로 원하는 출력을 얻을.