Blog post snippet

rxjava_share_post_2.java

// don't start emitting items just yet by turning the observable to a connected one
ConnectableObservable<Object> tapEventEmitter = _rxBus.toObserverable().publish();

tapEventEmitter.publish((Func1) (stream) -> {

    // inside `publish`, "stream" is truly multicasted

    // applying the same technique for getting a debounced buffer sequence
    return stream.buffer(stream.debounce(1, TimeUnit.SECONDS));

}).subscribe((Action1) (taps) {
    _showTapCount(taps.size());
});

// start listening to events now
tapEventEmitter.connect();

operatorCeption :)