override def run[S]()

in src/main/scala/com/twitter/stitch/Arrow.scala [903:947]


    override def run[S](t: Try[A], l: Locals, tail: Arrow[R, S]): Stitch[S] =
      tail(
        Stitch
          .joinMap(
            a1(t, l),
            a2(t, l),
            a3(t, l),
            a4(t, l),
            a5(t, l),
            a6(t, l),
            a7(t, l),
            a8(t, l),
            a9(t, l),
            a10(t, l),
            a11(t, l)
          )(k),
        l
      )

    override def run[T2 <: A, S](
      ts: ArrayBuffer[Try[T2]],
      ls: ArrayBuffer[Locals],
      tail: Arrow[R, S]
    ): Stitch[ArrayBuffer[Try[S]]] = {
      Stitch
        .join(
          a1.run(TryBuffer.copy(ts), ls),
          a2.run(TryBuffer.copy(ts), ls),
          a3.run(TryBuffer.copy(ts), ls),
          a4.run(TryBuffer.copy(ts), ls),
          a5.run(TryBuffer.copy(ts), ls),
          a6.run(TryBuffer.copy(ts), ls),
          a7.run(TryBuffer.copy(ts), ls),
          a8.run(TryBuffer.copy(ts), ls),
          a9.run(TryBuffer.copy(ts), ls),
          a10.run(TryBuffer.copy(ts), ls),
          a11.run(ts, ls)
        )
        .flatMap {
          case (ts1, ts2, ts3, ts4, ts5, ts6, ts7, ts8, ts9, ts10, ts11) =>
            tail.run(
              TryBuffer.joinMap(ts1, ts2, ts3, ts4, ts5, ts6, ts7, ts8, ts9, ts10, ts11, k),
              ls)
        }
    }