`upstream.publish { zip(it, it.skip(1), ::Pair) }`

# rx

[jw]

upstream.publish { zip(it, it.skip(1), ::Pair) }