P.S. причина простая, "подписчик" (не думаю, что важно, но наверно нужен пример) висит в цикле пока подписка не отменена, и цикл нужно буквально прибить... что то в таком роде думаю будет очевидно:
[syntax=java5]
Observable<String> query = Observable.create(
(Subscriber<? super String> subscriber) -> {
while (!subscriber.isUnsubscribed()){
String result = doAnyKindOfHeavyTask();
subscriber.onNext(result);
}
});
Subscription subscription = query.subscribe(str -> log(s));
[/syntax]
и вот собственно хотелось бы subscription.unsubscribe() вызвать в onDestroy.... но он же собака через раз меня игнорирует... или я опять что -то забыл.
