@SuppressWarnings("unchecked")
    public static <T> ConnectableFlowable<T> createFrom(Flowable<? extends T> source) {
    """
	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
    """
        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 .