首先看一個小例子：

  Observable.create(new ObservableOnSubscribe<String>() {
            @Override
            public void subscribe(ObservableEmitter<String> e) throws Exception {
//                e.onNext("1024");
//                e.onComplete();
            }
        }).map(new Function<String, Integer>() {
            @Override
            public Integer apply(String s) throws Exception {
                return Integer.parseInt(s);
            }
        }).map(new Function<Integer, Float>() {
            @Override
            public Float apply(Integer integer) throws Exception {
                return Float.parseFloat(String.valueOf(integer));
            }
        }).subscribe(new Observer<Float>() {
            @Override
            public void onSubscribe(Disposable d) {
                Log.e(TAG, "onSubscribe: =============ddddd" );
            }

            @Override
            public void onNext(Float integer) {
                Log.e(TAG, "onNext: ======>>"+integer );
            }

            @Override
            public void onError(Throwable e) {

            }

            @Override
            public void onComplete() {


            }
        });
 

Observable.create->獲得ObservableCreate(將ObservableOnSubscribe傳進來賦值給source)物件
 ->map(獲得ObservableMap物件(把ObservableCreate物件穿進來，賦值給當前ObservableMap 的source) 我們暫且叫該物件為map1)
 ->map(獲得ObservableMap物件(把bservableMap物件穿進來，賦值給當前ObservableMap 的source),我們暫且叫該物件為map2)
 ->subscribe()
 ->map2物件的subscribe,（ObservableMap中 subscribe方法是層層往上呼叫的  source.subscribe(new MapObserver<T, U>(t, function));
 同時將素MainActivity subscribe 中new 的Observer 賦值給MapObserver這樣層層往上賦值，最終，ObservableCreate中的Observer 是從map1中new的MapObserver穿進來的
-> map1物件的subscribe
-> ObservableCreate物件的 subscribe方法，
->上游事件開始層層往下呼叫，最後最上游的 Observable 肯定會呼叫 onNext 方法，這樣遞迴往下游就會來到包裹好的 MapObserver 中的 onNext 方法，
 在這裡我們看到了 function.apply(item) 進行轉換處理，然後接著往下傳遞，最終就會來到 Observer 的 onNext 方法。