@Test public void dispose() { TestHelper.checkDisposed(PublishSubject.create().singleOrError().toObservable()); }
@Experimental public static <T> SingleObserver<T> create(Observer<? super T> downstream) { return new SingleToObservableObserver<T>(downstream); }
SingleToObservable extends Observable<T> { @Experimental public static <T> SingleObserver<T> create(Observer<? super T> downstream) { return new SingleToObservableObserver<T>(downstream); } }
SingleToObservable extends Observable<T> { @Experimental public static <T> SingleObserver<T> create(Observer<? super T> downstream) { return new SingleToObservableObserver<T>(downstream); } SingleToObservable(SingleSource<? extends T> source); }
SingleToObservable extends Observable<T> { @Experimental public static <T> SingleObserver<T> create(Observer<? super T> downstream) { return new SingleToObservableObserver<T>(downstream); } SingleToObservable(SingleSource<? extends T> source); @Override void subscribeActual(final Observer<? super T> s); @Experimental static SingleObserver<T> create(Observer<? super T> downstream); }
SingleToObservable extends Observable<T> { @Experimental public static <T> SingleObserver<T> create(Observer<? super T> downstream) { return new SingleToObservableObserver<T>(downstream); } SingleToObservable(SingleSource<? extends T> source); @Override void subscribeActual(final Observer<? super T> s); @Experimental static SingleObserver<T> create(Observer<? super T> downstream);  }