or `upstream.switchMap(u -> just(u).concatWith(...
# rx
j
or
upstream.switchMap(u -> just(u).concatWith(just(this).delaySubscription(X, TIME)))