为什么 rxjava Observable.subscribe(observer) 返回 void？

Question

当我使用 Observable.subscribe() 通常返回 Disposable。

但是 Observable.subscribe(Observer) 返回 void。

所以我不能处理 Observable.subscribe(Observer)。

根据 introtorx.com Observable.subscribe(Obeserver) 返回 Disposable。

为什么 rx 和 rxjava 不同？

++++++++++++++

我在 Android Studio 中使用compile 'io.reactivex.rxjava2:rxandroid:2.0.1'。

github.com/ReactiveX/RxJava/blob/2.x/src/main/java/io/reactivex/Observable.java#L10831

public final void subscribe(Observer<? super T> observer) {
  ... 
}

[[1]：https://i.stack.imgur.com/0owg1.png][1]

[[2]：https://i.stack.imgur.com/7H4av.jpg][2]

Answer 1

可能是因为 Reactive Stream 合约​​。

Reactive Stream README

public interface Publisher<T> {
    public void subscribe(Subscriber<? super T> s);
}

Publisher的接口定义为return void。 RxJava Flowable 实现了该接口。并且 RxJava Observable 也遵循该合同。

所以他们提供了一个subscribeWith() 来返回一个Disposable 而不是void。或者你可以使用那些可以给你一个一次性的重载方法例如：subscribe(consumer<T>,consumer<Throwable>,action)

PS：以上是我的猜测。我不确定。

Answer 2

在 RxJava2 中，Disposable 对象被传递给 Observer 的 onSubscribe 回调方法。您可以从 onSubscribe 回调方法中获取 Disposable 对象，并在将观察者订阅到 observable 后使用它来处理订阅。

Answer 3

您使用哪个版本的RxJava？使用 RxJava2 (io.reactivex.rxjava2)：

public abstract class Observable<T> implements ObservableSource<T> {
  ...
  public final Disposable subscribe() {...}
  ...
}