@Test(expected = IllegalArgumentException.class) public void zeroCapacityHint() { UnicastSubject.create(0); }
@CheckReturnValue @NonNull public static <T> UnicastSubject<T> create() { return new UnicastSubject<T>(bufferSize(), true); }
UnicastSubject extends Subject<T> { @CheckReturnValue @NonNull public static <T> UnicastSubject<T> create() { return new UnicastSubject<T>(bufferSize(), true); } }
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); }
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); @CheckReturnValue @NonNull static UnicastSubject<T> create(); @CheckReturnValue @NonNull static UnicastSubject<T> create(int capacityHint); @CheckReturnValue @NonNull static UnicastSubject<T> create(int capacityHint, Runnable onTerminate); @CheckReturnValue @Experimental @NonNull static UnicastSubject<T> create(int capacityHint, Runnable onTerminate, boolean delayError); @CheckReturnValue @Experimental @NonNull static UnicastSubject<T> create(boolean delayError); @Override void onSubscribe(Disposable s); @Override void onNext(T t); @Override void onError(Throwable t); @Override void onComplete(); @Override boolean hasObservers(); @Override @Nullable Throwable getThrowable(); @Override boolean hasThrowable(); @Override boolean hasComplete(); }
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); @CheckReturnValue @NonNull static UnicastSubject<T> create(); @CheckReturnValue @NonNull static UnicastSubject<T> create(int capacityHint); @CheckReturnValue @NonNull static UnicastSubject<T> create(int capacityHint, Runnable onTerminate); @CheckReturnValue @Experimental @NonNull static UnicastSubject<T> create(int capacityHint, Runnable onTerminate, boolean delayError); @CheckReturnValue @Experimental @NonNull static UnicastSubject<T> create(boolean delayError); @Override void onSubscribe(Disposable s); @Override void onNext(T t); @Override void onError(Throwable t); @Override void onComplete(); @Override boolean hasObservers(); @Override @Nullable Throwable getThrowable(); @Override boolean hasThrowable(); @Override boolean hasComplete();  }