Observable.create（）subscribeOn和observeOn不工作

Question

在我的Android應用我用Rxjava2，但有些奇怪的形勢出現了。

在我Disposable我打印記錄當前線程的名稱：

//1 
    Observable 
      .create((ObservableOnSubscribe<UserModel>) e -> { 
       //mock io 
       if (phoneNumber.equals("HolyHigh") && password.equals("111111")) { 
        e.onNext(new UserModel()); 
        e.onComplete(); 
       } else { 
        e.onError(new RuntimeException("Error.")); 
       } 
      }) 
      .subscribeOn(Schedulers.io()) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .delay(1, TimeUnit.SECONDS) 
      .subscribe(
        r -> { 
         view.onLoginSuccess(new UserModel()); 
         //test 
         String name = Thread.currentThread().getName(); 
         Log.e("Thread Name", " Success Current Thread Name: " + name); 
        } 
        , e -> { 
         e.printStackTrace(); 
         view.onLoginFailed(e.getMessage()); 
         //test 
         String name = Thread.currentThread().getName(); 
         Log.e("Thread Name", " Error Current Thread Name: " + name); 
        } 
      ); 

然後登錄：

Thread Name: Error Current Thread Name: RxComputationThreadPool-3

它看起來像observeOn和subscribeOn不工作... 爲什麼不主線程？

不過，我寫了一些簡單的...

//2 
    Single.timer(1, TimeUnit.SECONDS) 
      .subscribeOn(Schedulers.io()) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .subscribe(r -> { 
       Log.e("Single Thread Name", "Single Thread Name: " + Thread.currentThread().getName()); 
       CommonUtil.showToast(r + "~"); 
      }); 

這個記錄：

Single Thread Name: Single Thread Name: main

哪裏是我的錯......

Answer 1

delay()操作默認操作？在計算調度器上，所以它改變了上游事件以獲得在計算線程上的通知。

您只需在訂閱之前更改它，只需在delay()操作員之後移動observeOn .observeOn(AndroidSchedulers.mainThread())即可。

BTW，delay()還具有重載，獲取Scheduler PARAM，讓您更改默認Scheduler。