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