src/main/java/io/reactivex/processors/UnicastProcessor.java
@CheckReturnValue
    @NonNull
    public static <T> UnicastProcessor<T> create(boolean delayError) {
        return new UnicastProcessor<T>(bufferSize(), null, delayError);
    }
@CheckReturnValue
    @NonNull
    public static <T> UnicastProcessor<T> create(boolean delayError) {
        return new UnicastProcessor<T>(bufferSize(), null, delayError);
    }
@ CheckReturnValue @ NonNull public static < T > UnicastProcessor < T > create ( boolean delayError ) { return new UnicastProcessor < T > ( bufferSize ( ) , null , delayError ) ; }
Creates an UnicastProcessor with default internal buffer capacity hint and delay error flag.
<p>History: 2.0.8 - experimental
@param <T> the value type
@param delayError deliver pending onNext events before onError
@return an UnicastProcessor instance
@since 2.2
Creates an UnicastProcessor with default internal buffer capacity hint and delay error flag . <p > History : 2 . 0 . 8 - experimental