publish { o -> merge(o.take 1, o.skip 1. delay ...
# rx
u
publish { o -> merge(o.take 1, o.skip 1. delay bla bla}