rxJavaは、退会時に観測を停止します

Question

私は計算スケジューラに登録したときに多くのアイテムを生成し、より重い作業を行う別のoに送信するオブザーバブルを冷やしています。

問題は、私がそれを退会したときに観測可能なチェーンをすべて停止したいということです。

そのための演算子はありますか？私はサスペンションを持っているかどうかをチェックしようとしましたが、現時点ではほとんどのアイテムが放出されています。

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