@Test public void cancelOnArrival2() { MaybeSubject<Integer> ms = MaybeSubject.create(); ms.test(); ms .test(true) .assertEmpty(); }
@CheckReturnValue @NonNull public static <T> MaybeSubject<T> create() { return new MaybeSubject<T>(); }
MaybeSubject extends Maybe<T> implements MaybeObserver<T> { @CheckReturnValue @NonNull public static <T> MaybeSubject<T> create() { return new MaybeSubject<T>(); } }
MaybeSubject extends Maybe<T> implements MaybeObserver<T> { @CheckReturnValue @NonNull public static <T> MaybeSubject<T> create() { return new MaybeSubject<T>(); } @SuppressWarnings("unchecked")  MaybeSubject(); }
MaybeSubject extends Maybe<T> implements MaybeObserver<T> { @CheckReturnValue @NonNull public static <T> MaybeSubject<T> create() { return new MaybeSubject<T>(); } @SuppressWarnings("unchecked")  MaybeSubject(); @CheckReturnValue @NonNull static MaybeSubject<T> create(); @Override void onSubscribe(Disposable d); @SuppressWarnings("unchecked") @Override void onSuccess(T value); @SuppressWarnings("unchecked") @Override void onError(Throwable e); @SuppressWarnings("unchecked") @Override void onComplete(); @Nullable T getValue(); boolean hasValue(); @Nullable Throwable getThrowable(); boolean hasThrowable(); boolean hasComplete(); boolean hasObservers(); }
MaybeSubject extends Maybe<T> implements MaybeObserver<T> { @CheckReturnValue @NonNull public static <T> MaybeSubject<T> create() { return new MaybeSubject<T>(); } @SuppressWarnings("unchecked")  MaybeSubject(); @CheckReturnValue @NonNull static MaybeSubject<T> create(); @Override void onSubscribe(Disposable d); @SuppressWarnings("unchecked") @Override void onSuccess(T value); @SuppressWarnings("unchecked") @Override void onError(Throwable e); @SuppressWarnings("unchecked") @Override void onComplete(); @Nullable T getValue(); boolean hasValue(); @Nullable Throwable getThrowable(); boolean hasThrowable(); boolean hasComplete(); boolean hasObservers();  }