实现订阅状态

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