У меня есть холодное наблюдаемое, которое производит много элементов при подписке на планировщик вычислений и отправляет другому, кто выполняет более тяжелую работу над ними.
Проблема в том, что я хочу остановить всю наблюдаемую цепочку, когда отписываюсь от нее.
Есть какой-нибудь оператор для этого? Я попытался проверить, есть ли у меня подписчик, но на данный момент большинство моих предметов было отправлено.
Создайте наблюдаемый объект, который выполняет тяжелую работу и может проверять подписку:
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);
subscriber.unsubscribe()отменит подписку на всю цепочку. У вас одна цепочка? Вы можете показать код? - person Dave Moten schedule 22.07.2016flatmapфункция продолжает работать с элементами, сгенерированными до вызова enunsubscribe. - person Guilherme Torres Castro schedule 22.07.2016