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);  }
@Test public void dispose() { TestHelper.checkDisposed(PublishSubject.create().singleOrError().toObservable()); }