@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)"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)"net result had been load,so cache is not need to load"); } }