in src/main/scala/com/twitter/stitch/Arrow.scala [965:1011]
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),
a12(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(TryBuffer.copy(ts), ls),
a12.run(ts, ls)
)
.flatMap {
case (ts1, ts2, ts3, ts4, ts5, ts6, ts7, ts8, ts9, ts10, ts11, ts12) =>
tail.run(
TryBuffer.joinMap(ts1, ts2, ts3, ts4, ts5, ts6, ts7, ts8, ts9, ts10, ts11, ts12, k),
ls
)
}
}