Broadcast и Concat не работают в Akka Stream

Я хочу создать график с Broadcast и Concat в Akka Stream, но следующий код не работает. Я хочу знать, почему это не работает.

  val src = Source(1 to 3)
  val sink = Sink.foreach(println)
  RunnableGraph.fromGraph(GraphDSL.create() { implicit b =>
    import GraphDSL.Implicits._
    val bcast = b.add(Broadcast[Int](2))
    val concat = b.add(Concat[Int](2))

    src  ~> bcast ~> concat ~> sink
            bcast ~> concat

    ClosedShape
  }).run()

Мой ожидаемый результат

1
2
3
1
2
3

Но на самом деле ничего не выводится. Я хотел бы, чтобы вы сказали, почему мой код не работает.