src/main/java/io/reactivex/processors/MulticastProcessor.java
@CheckReturnValue
    @NonNull
    public static <T> MulticastProcessor<T> create(boolean refCount) {
        return new MulticastProcessor<T>(bufferSize(), refCount);
    }
@CheckReturnValue
    @NonNull
    public static <T> MulticastProcessor<T> create(boolean refCount) {
        return new MulticastProcessor<T>(bufferSize(), refCount);
    }
@ CheckReturnValue @ NonNull public static < T > MulticastProcessor < T > create ( boolean refCount ) { return new MulticastProcessor < T > ( bufferSize ( ) , refCount ) ; }
Constructs a fresh instance with the default Flowable.bufferSize() prefetch
amount and the optional refCount-behavior.
@param <T> the input and output value type
@param refCount if true and if all Subscribers have canceled, the upstream
is cancelled
@return the new MulticastProcessor instance
Constructs a fresh instance with the default Flowable . bufferSize () prefetch amount and the optional refCount - behavior .