src/main/java/io/reactivex/internal/operators/flowable/FlowableReplay.java
public static <T> ConnectableFlowable<T> create(Flowable<T> source,
            final long maxAge, final TimeUnit unit, final Scheduler scheduler, final int bufferSize) {
        return create(source, new ScheduledReplayBufferTask<T>(bufferSize, maxAge, unit, scheduler));
    }
public static <T> ConnectableFlowable<T> create(Flowable<T> source,
            final long maxAge, final TimeUnit unit, final Scheduler scheduler, final int bufferSize) {
        return create(source, new ScheduledReplayBufferTask<T>(bufferSize, maxAge, unit, scheduler));
    }
public static < T > ConnectableFlowable < T > create ( Flowable < T > source , final long maxAge , final TimeUnit unit , final Scheduler scheduler , final int bufferSize ) { return create ( source , new ScheduledReplayBufferTask < T > ( bufferSize , maxAge , unit , scheduler ) ) ; }
Creates a replaying ConnectableObservable with a size and time bound buffer.
@param <T> the value type
@param source the source Flowable to use
@param maxAge the maximum age of entries
@param unit the unit of measure of the age amount
@param scheduler the target scheduler providing the current time
@param bufferSize the maximum number of elements to hold
@return the new ConnectableFlowable instance
Creates a replaying ConnectableObservable with a size and time bound buffer .