src/main/java/io/reactivex/internal/operators/flowable/FlowableReplay.java
@SuppressWarnings("unchecked")
    public static <T> ConnectableFlowable<T> createFrom(Flowable<? extends T> source) {
        return create(source, DEFAULT_UNBOUNDED_FACTORY);
    }
@SuppressWarnings("unchecked")
    public static <T> ConnectableFlowable<T> createFrom(Flowable<? extends T> source) {
        return create(source, DEFAULT_UNBOUNDED_FACTORY);
    }
@ SuppressWarnings ( "unchecked" ) public static < T > ConnectableFlowable < T > createFrom ( Flowable < ? extends T > source ) { return create ( source , DEFAULT_UNBOUNDED_FACTORY ) ; }
Creates a replaying ConnectableObservable with an unbounded buffer.
@param <T> the value type
@param source the source Publisher to use
@return the new ConnectableObservable instance
Creates a replaying ConnectableObservable with an unbounded buffer .