@Override
        public void onNext(T o) {
            if (debug) Log.i(TAG, "net onNext o:" + o);
            observableWrapper.setData(o);
            logThread("");
            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没有被调用
            }
        }
@Override
        public void onNext(T o) {
            if (debug) Log.i(TAG, "net onNext o:" + o);
            observableWrapper.setData(o);
            logThread("");
            if (debug) Log.e(TAG, " check subscriber :" + subscriber + " isUnsubscribed:" + subscriber.isUnsubscribed());
            if (subscriber != null && !subscriber.isUnsubscribed()) {
                subscriber.onNext(o)
@override public void onnext(t o) { if (debug) log.i(tag, "net onnext o:" + o); observablewrapper.setdata(o); logthread(""); if (debug) log.e(tag, " check subscriber :" + subscriber + " isunsubscribed:" + subscriber.isunsubscribed()); if (subscriber != null && !subscriber.isunsubscribed()) { subscriber.onnext(o)