如何在不使用Observable.create（）時檢查訂閱狀態？

Question

假設你有一些長期運行的任務由觀察到的包裹：

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

有沒有什麼辦法來檢查是否可觀察已取消訂閱，以確定我們是否應該取消工作，並擺脫困境？

更具體地說，是否可以在使用Observable.defer()或Observable.fromCallable()時檢查訂閱的狀態（例如isUnsubscribed()）？

我知道您在使用Observable.create()時可以檢查subscriber.isUnsubscribed()，但是，由於建議不要使用Observable.create()，對於其他操作員該如何處理？

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