`upstream.publish { zip(it, it.skip(1), it.skip(2)...
# rx
j
upstream.publish { zip(it, it.skip(1), it.skip(2), ::Tuple) }
Because that's not the same thing nor does it solve the original problem statement.