src/main/java/io/reactivex/processors/MulticastProcessor.java
@CheckReturnValue
    @NonNull
    public static <T> MulticastProcessor<T> create() {
        return new MulticastProcessor<T>(bufferSize(), false);
    }
@CheckReturnValue
    @NonNull
    public static <T> MulticastProcessor<T> create() {
        return new MulticastProcessor<T>(bufferSize(), false);
    }
Constructs a fresh instance with the default Flowable.bufferSize() prefetch
amount and no refCount-behavior.
@param <T> the input and output value type
@return the new MulticastProcessor instance