doOnTerminateとdoOnUnsubscribeのどちらを使用するのですか？

Question

私が観察可能なものを購読したときに通知を受ける必要があります。私はまた、私の観察可能性がエラーを起こしたか完了したという通知を受ける必要があります。だから私は、私はdoOnSubscribeを実装する必要があります考えた：

観察者が 観察可能

とdoOnTerminateに加入したときに実行するアクションを登録します。

たときに観察可能に実行するアクションを登録します完了しました 成功またはエラーあり

は、その後、私はdoOnUnsubscribeを見た：

観察可能

からときオブザーバーの登録解除を実行するアクションを登録し、doOnSubscribe/doOnUnsubscribeの対称性が良いだろうと思いました。

doOnUnsubscribeの前には、常にdoOnTerminateが呼び出されますか？物事が「完了」していることを知りたいのであれば、それは本当に重要なのですか？

Answer 1

あなたのリアクティブフローでの購読解除の方法によって、doOnUnsubscribeまたはdoOnTerminateのいずれかが使用されます。以下は、ケースとすることができる：

観測完了/エラーがdoOnTerminateとdoOnUnsubscribe両方がdoOnTerminateが最初に呼び出されると呼び出されるようなシナリオでは
解除をトリガします。

以下の例では、はで終了し、は非公開の両方を出力します。観察可能なだけdoOnUnsubscribeが呼び出されるようなシナリオで
を完了する前に退会する

Subscription subscribe = Observable.empty() // source terminates immediately 
    .subscribeOn(Schedulers.newThread()) 
    .doOnTerminate(() -> System.out.println("terminated")) 
    .doOnUnsubscribe(() -> System.out.println("unsubscribed")) 
    .subscribe(); 

TimeUnit.SECONDS.sleep(1); 
subscribe.unsubscribe(); // by this time already unsubscribe would have happened 

プログラムによるコール。無限に実行されるソースや、ユーザーのクリックに対して観測可能なようなソースがある場合、この問題の可能性はより一般的です。

以下の例では、のサブスクライブされていないのみが出力されます。

Subscription subscribe = Observable.never() // source never terminates 
    .subscribeOn(Schedulers.newThread()) 
    .doOnTerminate(() -> System.out.println("terminated")) 
    .doOnUnsubscribe(() -> System.out.println("unsubscribed")) 
    .subscribe(); 

TimeUnit.SECONDS.sleep(1); 
subscribe.unsubscribe(); // this will trigger unsubscribe