src/main/java/io/reactivex/internal/operators/flowable/FlowableReplay.java
public static <T> ConnectableFlowable<T> observeOn(final ConnectableFlowable<T> cf, final Scheduler scheduler) {
        final Flowable<T> flowable = cf.observeOn(scheduler);
        return RxJavaPlugins.onAssembly(new ConnectableFlowableReplay<T>(cf, flowable));
    }
public static <T> ConnectableFlowable<T> observeOn(final ConnectableFlowable<T> cf, final Scheduler scheduler) {
        final Flowable<T> flowable = cf.observeOn(scheduler);
        return RxJavaPlugins.onAssembly(new ConnectableFlowableReplay<T>(cf, flowable));
    }
Child Subscribers will observe the events of the ConnectableObservable on the
specified scheduler.
@param <T> the value type
@param cf the ConnectableFlowable to wrap
@param scheduler the target scheduler
@return the new ConnectableObservable instance