サブスクリプションステータスを具体化する

Question

RxJavaにサブスクリプションステータスを実現する演算子がありますか？観察可能なサブスクライブとサブスクライブ解除が行われたときに通知を受けたい。

私が知っているのは、doOnSubscribeとdoOnUnsubscribe演算子を使用してPublishSubjectを作成し、件名にイベントを送信することだけです。

Answer 1

サブスクライバを取得して、サブスクライバがサブスクリプションを解除するまで待つか、現在の状態を知ることができるTestSubscriberを使用できます。

 @Test 
public void testIntervalObservable() { 
    Subscription subscription = Observable.interval(50, TimeUnit.MILLISECONDS) 
              .map(time -> "item emitted\n") 
              .subscribe(System.out::print); 
    new TestSubscriber((Observer) subscription).awaitTerminalEvent(200, TimeUnit.MILLISECONDS); 
}