Observable.create（）を使用しない場合のサブスクリプションステータスを確認する方法は？

Question

は、あなたが観測可能で包まれたいくつかの長い実行中のタスクがあるとしましょう：

Observable.fromCallable(new Callable<String>() { 
    @Override 
    public String call() throws Exception { 
     return longRunningTask(); 
    } 
} 

は、観察は、我々は仕事をキャンセルして、救済すべきかどうかを判断するために退会されたかどうかを確認する方法はありますか？

具体的には、Observable.defer()またはObservable.fromCallable()を使用している場合、サブスクリプションのステータス（例：isUnsubscribed()）を確認できますか？

私はあなたがObservable.create()を使用した場合、しかし、それはObservable.create()を使用する無分別なので、どのようにこれは他の演算子で行うことができますか？subscriber.isUnsubscribed()を確認することができますことを承知していますか

Answer 1

Observable.doOnSubscribe(Action0)とObservable.doOnUnsubscribe(Action0)の場合はどうですか？サブスクリプションはカウントできます。サブスクリプションがない場合は、ジョブを停止できます。

挨拶、 マーティン

Answer 2

fromCallableは、消費者に公開しません。このためには、次のような体でcreateが必要になります。

final SingleDelayedProducer<T> singleDelayedProducer = 
    new SingleDelayedProducer<T>(subscriber); 

subscriber.setProducer(singleDelayedProducer); 

try { 
    T result; 

    // computation 

    if (subscriber.isUnsubscribed()) { 
     return; 
    } 

    // more computation 

    result = ... 

    singleDelayedProducer.setValue(result); 
} catch (Throwable t) { 
    Exceptions.throwOrReport(t, subscriber); 
}