なぜ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

RxJavaのどのバージョンをお使いですか？ RxJava2（io.reactivex.rxjava2）：

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

Answer 2

おそらくReactive Stream契約のためです。

Reactive Stream README

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

Publisherのインタフェースは、定義されたリターン無効です。 RxJava Flowableは、そのインタフェースを実装しています。そしてRxJava Observableもその契約に従います。

したがって、無効の代わりにDisposableを返すようにsubscribeWith()を提供しています。または、これらの過負荷メソッドを使用して、使い捨てのものを返すこともできます。subscribe(consumer<T>,consumer<Throwable>,action)

PS：これは私の推測以上です。私はそれが分からない。

Answer 3

RxJava2では、DisposableオブジェクトがObserverのonSubscribeコールバックメソッドに渡されます。 onSubscribeコールバックメソッドからDisposableオブジェクトを保持し、それを使用してオブザーバをオブザーバブルにサブスクライブした後の時点でサブスクリプションを破棄できます。