src/main/java/io/reactivex/internal/operators/flowable/FlowableReplay.java
public static <T> ConnectableFlowable<T> create(Flowable<T> source,
            final int bufferSize) {
        if (bufferSize == Integer.MAX_VALUE) {
            return createFrom(source);
        }
        return create(source, new ReplayBufferTask<T>(bufferSize));
    }
public static <T> ConnectableFlowable<T> create(Flowable<T> source,
            final int bufferSize) {
        if (bufferSize == Integer.MAX_VALUE) {
            return createFrom(source);
        }
        return create(source, new ReplayBufferTask<T>(bufferSize));
    }
public static < T > ConnectableFlowable < T > create ( Flowable < T > source , final int bufferSize ) { if ( bufferSize == Integer . MAX_VALUE ) { return createFrom ( source ) ; } return create ( source , new ReplayBufferTask < T > ( bufferSize ) ) ; }
Creates a replaying ConnectableObservable with a size bound buffer.
@param <T> the value type
@param source the source Flowable to use
@param bufferSize the maximum number of elements to hold
@return the new ConnectableObservable instance
Creates a replaying ConnectableObservable with a size bound buffer .