here's another fun variant: `upstream.publish { o ...

# rx

[jw]

here's another fun variant: upstream.publish { o -> just(specialValue).delaySubscription(3, SECONDS).takeUntil(o).mergeWith(o) }