class UnicastProcessor extends FlowableProcessor<T> {

    @CheckReturnValue
    @NonNull
    public static <T> UnicastProcessor<T> create() {
        return new UnicastProcessor<T>(bufferSize());
    }

      UnicastProcessor(int capacityHint);
      UnicastProcessor(int capacityHint, Runnable onTerminate);
      UnicastProcessor(int capacityHint, Runnable onTerminate, boolean delayError);

}