RxJava01

RxJava

Describe

subscribeOn() 指定上游发送事件的线程, observeOn　指定的是下游接收事件的线程
多次指定上游的线程只有第一次指定的有效,就是subscribeOn()只有第一次有效,其余忽略
可以多次指定下游线程,每调用一次observeOn(),下游的线程就会切换一次

Demo在　AndroidDemo -> RXLeran->RX基础->Rx线程切换

链式调用

RetrofitFactory.create(ICommonApis.class)
              .imgUpServer(part)
              .subscribeOn(Schedulers.io())
              .observeOn(AndroidSchedulers.mainThread())
              .doOnNext(new Consumer<PictureUp>() {
                  @Override
                  public void accept(PictureUp pictureUp) throws Exception {
                      List<PictureUp.ModelListBean> picList = pictureUp.getModel_list();
                      if (picList != null && !picList.isEmpty()) {
                          String feet_id = picList.get(0).getFile_group_id();
                          //上传成功
                          if (!isEmpty(feet_id) && mvpView != null) {
                              mvpView.upFeetId(feet_id);
                          }
                      }
                  }
              })
              .observeOn(Schedulers.io())
              .flatMap(new Function<PictureUp, ObservableSource<BaseCount>>() {
                  @Override
                  public ObservableSource<BaseCount> apply(PictureUp pictureUp) throws Exception {
                      List<PictureUp.ModelListBean> picList = pictureUp.getModel_list();
                      if (picList != null && !picList.isEmpty()) {
                          String feet_id = picList.get(0).getFile_group_id();
                          //上传成功
                          if (!isEmpty(feet_id) && mvpView != null) {
                              mvpView.upFeetId(feet_id);
                          }else {
                              return  Observable.error(new Exception());
                          }
                      }
                      return RetrofitFactory.create(ICommonApis.class).offlineBoxInfo(requestBody);
                  }
              })
              .subscribe(new Consumer<BaseCount>() {
                  @Override
                  public void accept(BaseCount baseCount) throws Exception {
                      if (mvpView == null) {
                          return;
                      }
                      if (baseCount.getMeta().getStatusCode() == AUTH_FAILED) {
                          mvpView.unOfficeEquip(baseCount);
                      } else if (baseCount.getMeta().getStatusCode() == 0) {
                          mvpView.upSuccess();
                      } else {
                          if (baseCount.getMeta() != null && !isEmpty(baseCount.getMeta().getDescribe())) {
                              ToastUtil.showBiggerText(baseCount.getMeta().getDescribe());
                          }
                      }
                  }
              }, new Consumer<Throwable>() {
                  @Override
                  public void accept(Throwable throwable) throws Exception {
                      if (mvpView != null) {
                          mvpView.upUserInfoFailed();
                      }
                  }
              });

fun getImgScan() {
    val request = RetrofitWeChatFactory.create(IApiStore::class.java)
    request.get_access_token()
        .flatMap { request.getTicket(it.access_token, 2) }
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(object : Observer<WeChatSecond> {
            override fun onComplete() {
            }

            override fun onSubscribe(d: Disposable) {
            }

            override fun onNext(t: WeChatSecond) {
                val noncestr = LoginNewActivity.getRandomString(8)
                val timeStamp =
                    (System.currentTimeMillis() / 1000).toString()
                t.ticket?.let {
                    val string1 = String.format(
                        "appid=%s&noncestr=%s&sdk_ticket=%s&timestamp=%s",
                        WeChatAppID,
                        noncestr,
                        it,
                        timeStamp
                    )
                    val sha = EncryptUtils.getSHA(string1)

                    mvpView.sign(noncestr, timeStamp, sha)
                }
            }

            override fun onError(e: Throwable) {
            }

        })
}