// FIXME: issue A:外面如果ObservableOn 其他线程,将会是异步操作,如果在实际的onNext调用之前,发生了onComplete或者onError,将会unsubscribe,导致onNext没有被调用
@Override
        public void onNext(T o) {
            if (debug) Log.i(TAG, "cache onNext o:" + o);
            observableWrapper.setData(o);
            logThread("");
            if (netLatch.getCount() > 0) {
                if (debug) Log.e(TAG, " check subscriber :" + subscriber + " isUnsubscribed:" + subscriber.isUnsubscribed());
                if (subscriber != null && !subscriber.isUnsubscribed()) {
                    subscriber.onNext(o);// FIXME: issue A:外面如果ObservableOn 其他线程,将会是异步操作,如果在实际的onNext调用之前,发生了onComplete或者onError,将会unsubscribe,导致onNext没有被调用
                }
            } else {
                if (debug) Log.e(TAG, "net result had been load,so cache is not need to load");
            }
        }
if (debug) Log.e(TAG, " check subscriber :" + subscriber + " isUnsubscribed:" + subscriber.isUnsubscribed());
if (subscriber != null && !subscriber.isUnsubscribed()) {
subscriber.onNext(o);// FIXME: issue A:外面如果ObservableOn 其他线程,将会是异步操作,如果在实际的onNext调用之前,发生了onComplete或者onError,将会unsubscribe,导致onNext没有被调用
}
} else {
@Override
public void onNext(T o) {
if (debug) Log.i(TAG, "cache onNext o:" + o);
observableWrapper.setData(o);
logThread("");
if (netLatch.getCount() > 0) {
if (debug) Log.e(TAG, " check subscriber :" + subscriber + " isUnsubscribed:" + subscriber.isUnsubscribed());
if (subscriber != null && !subscriber.isUnsubscribed()) {
subscriber.onNext(o);// FIXME: issue A:外面如果ObservableOn 其他线程,将会是异步操作,如果在实际的onNext调用之前,发生了onComplete或者onError,将会unsubscribe,导致onNext没有被调用
}
} else {
if (debug) Log.e(TAG, "net result had been load,so cache is not need to load");
}
}
@Override
public void onNext(T o) {
if (debug) Log.i(TAG, "cache onNext o:" + o);
observableWrapper.setData(o);
logThread("");
if (netLatch.getCount() > 0) {
if (debug) Log.e(TAG, " check subscriber :" + subscriber + " isUnsubscribed:" + subscriber.isUnsubscribed());
if (subscriber != null && !subscriber.isUnsubscribed()) {
subscriber.onNext(o);// FIXME: issue A:外面如果ObservableOn 其他线程,将会是异步操作,如果在实际的onNext调用之前,发生了onComplete或者onError,将会unsubscribe,导致onNext没有被调用
}
} else {
if (debug) Log.e(TAG, "net result had been load,so cache is not need to load");
}
}