src/main/java/io/reactivex/processors/UnicastProcessor.java
@CheckReturnValue
    @NonNull
    public static <T> UnicastProcessor<T> create(int capacityHint) {
        return new UnicastProcessor<T>(capacityHint);
    }
@CheckReturnValue
    @NonNull
    public static <T> UnicastProcessor<T> create(int capacityHint) {
        return new UnicastProcessor<T>(capacityHint);
    }
Creates an UnicastProcessor with the given internal buffer capacity hint.
@param <T> the value type
@param capacityHint the hint to size the internal unbounded buffer
@return an UnicastProcessor instance