`upstream publish u gt u mergeWith u switchMap ignored gt ju kotlinlang #rx

`upstream.publish(u -> u.mergeWith(u.switchMap(...

05/12/2018, 2:24 AM

upstream.publish(u -> u.mergeWith(u.switchMap(ignored -> just(this).delaySubscription(X, TIME))))