實現訂閱狀態

Question

RxJava中是否有任何操作員實現了訂閱狀態？我想在可觀察訂閱和取消訂閱時收到通知。

我只知道創建PublishSubject並使用doOnSubscribe和doOnUnsubscribe運算符向主體發送事件。

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); 
}