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