工程需要依賴(lài)的包

compile 'com.jakewharton.rxbinding:rxbinding:0.4.0'
compile 'io.reactivex:rxjava:1.2.7'
compile 'io.reactivex:rxandroid:1.2.1'

代碼

private class LoginInfo {
    private String token;
}

private class UserInfo {
    private String userInfoJson;
}


Observable.just(1).flatMap(new Func1<Integer, Observable<LoginInfo>>() {
      @Override
      public Observable<LoginInfo> call(Integer integer) {
           // 從網(wǎng)絡(luò)獲取數(shù)據(jù)
           LoginInfo loginInfo = new LoginInfo();
           return Observable.just(loginInfo);
       }
   }).flatMap(new Func1<LoginInfo, Observable<UserInfo>>() {
       @Override
       public Observable<UserInfo> call(LoginInfo loginInfo) {
           // 從網(wǎng)絡(luò)獲取用戶(hù)信息，帶入token 啥的。。
           UserInfo userInfo = new UserInfo();
           return Observable.just(userInfo);
       }
   }).observeOn(AndroidSchedulers.mainThread()) // 線(xiàn)程切換
           .subscribeOn(Schedulers.io())
           .subscribe(new Subscriber<UserInfo>() {
       @Override
       public void onCompleted() {
       }

       @Override
       public void onError(Throwable e) {
       }
       @Override
       public void onNext(UserInfo o) {
           // 從網(wǎng)絡(luò)獲取到用戶(hù)數(shù)據(jù)，本地保存，然后 do something
       }
   });