我有一些代码，类似于以下内容：

object Test extends App {
  val SomeComplicatedFlow: Flow[Int, Int, NotUsed] =
    Flow.fromGraph(GraphDSL.create() { implicit builder =>
      import GraphDSL.Implicits._

      val input = builder.add(Balance[Int](1)) //Question 1) how to get rid of this input
      val buffer = Flow[Int].buffer(12, OverflowStrategy.backpressure)
      val balance = builder.add(Balance[Int](2))

      val flow1 = Flow[Int].map(_*2)
      val flow2 = Flow[Int].map(_*2)

      val zip = builder.add(ZipWith[Int, Int, Int]((left, right) => {
        left + right
      }))

      val flow3 = Flow[Int].map(_*2)

      input ~> buffer ~> balance.in
      balance.out(0) ~> flow1 ~> zip.in0
      balance.out(1) ~> flow2 ~> zip.in1
      zip.out ~> flow3

      FlowShape(input.in, flow3) //Question 2) how to make an outlet here
    })
}

注意，我必须添加一个名为input的Balance，因为我无法从我想要创建的FlowShape的第一个Buffer中检索到Inlet。有没有其他更简单的方法来解决这个问题？用1个Outlet创建一个Balance似乎是错误的方法。
我的第二个问题是类似的。我不能从flow3中检索Outlet。我知道的解决这个问题的唯一方法是创建另一个Balance，并将其Outlet公开为整个FlowShape的Outlet。有更好的方法来解决这个问题吗？