rxJava stop наблюдаемый при отмене подписки

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