RxJava 2でonComplete（）の直前にコードを実行しますか？

Question

RxLifecycleを廃棄する前に、観測可能な状態でソケット接続を閉じる必要があります。どうやってやるの？

Answer 1

あなたはちょうどあなたが演算子を使用することができ、観察から加入者退会する前に、後にすべてのアクションを行いたい場合はdoOnUnsubscribe

@Test 
public void testDoOnUnsubscribe() { 
    Integer[] numbers = {0, 1, 2, 3, 4}; 
    Observable.from(numbers) 
      .doOnUnsubscribe(() -> System.out.println("Last action must be done here")) 
      .subscribe(number -> System.out.println("number:" + number), 
        System.out::println, 
        () -> System.out.println("End of pipeline")); 
} 

それはこの順番で印刷する必要があります

number:0 
number:1 
number:2 
number:3 
number:4 
End of pipeline 
Last action must be done here 

Answer 2

あなたはdoFinally

がonCompletedまたは下流で配置されますかのonErrorこの観測信号の後に指定されたアクションを呼び出します使用して試みることができます。

http://reactivex.io/RxJava/javadoc/io/reactivex/Observable.html#doFinally-io.reactivex.functions.Action-

Answer 3

あなたがオブジェクトを繰り返し使用している場合は、これを試すこともできますg結果を結合するためのフィルターとマップ。

.doOnTerminate(() -> Log.d(LOGGER, "terminated"))