rxJava停止观察取消订阅

Question

我有冷观察，当计算调度程序订阅时产生大量的项目，并发送给另一个谁做了更重的工作。

问题是我想停止所有可观察链，当我退订它。

这有什么经营者？我试图检查是否有订户，但此时我的大部分物品都已排出。

Answer 1

创建一个可观察的，做繁重的工作，并可以查看订阅：

obs //emits stuff fast 
    .flatMap(x -> 
    Observable.create(
     sub -> { 
      //frequently check subscription status 
      while (!sub.isUnsubscribed()) { 
      // do some work 
      if (finished) break; 
      } 
      if (!sub.isUnsubscribed()) { 
      sub.onNext(result); 
      sub.onCompleted(); 
      } 
     })) 
     //ensure backpressure compliant 
     .onBackpressureBuffer() 
    ).subscribe(subscriber);