Is there a rx `publish { observsble -> ... }`eq...

# coroutines

[ursus]

Is there a rx `publish { observsble -> ... }`equivalent? I found useful for creating pseudo operators like

publish { o -> merge(o.take(1)... , o.skip(1)....) }