class UnicastSubject extends Subject<T> {

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

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

}