RxAndroid：调度程序上的UI更改。io（）线程

Question

我在IO线程上有一个简单的工作，它正在改变主屏幕壁纸，之后我试图在UI线程上运行一些动画：

     AppObservable.bindFragment(this, Observable.just(0))
       .observeOn(Schedulers.io())
       .subscribe(v -> setWallpaperOnSeparateThread());

private void setWallpaperOnSeparateThread() {
     WallpaperHelper.setBitmapAsWallpaper(photoViewAttacher.getVisibleRectangleBitmap(), getBaseActivity());

     AppObservable.bindFragment(this, Observable.just(0))
       .delay(500, TimeUnit.MILLISECONDS)
       .observeOn(AndroidSchedulers.mainThread())
       .subscribe(integer -> loadFinishAnimationAfterSetWallpaper());
}

但这种方法会导致错误：<代码>java。lang.IllegalStateException：观察者必须从主UI线程订阅，但它是线程[RxCachedThreadScheduler-1,5，main]

我尝试将第二个可观察更改为：

  AppObservable.bindFragment(this, Observable.just(0))
    .delay(2000, TimeUnit.MILLISECONDS)
    .observeOn(Schedulers.io())
    .subscribeOn(AndroidSchedulers.mainThread())
    .subscribe(integer -> loadFinishAnimationAfterSetWallpaper());

但这于事无补。

Answer 1

实际上观察是针对订阅者线程的，而订阅是针对可观察线程的。所以你应该反转它们

.observeOn(AndroidSchedulers.mainThread())
.subscribeOn(Schedulers.io())

Answer 2

<代码>可观察。bindFragment（这是可观察的。只有（0））抛出异常，因为它不是从主线程调用的

此代码没有在主线程中调用，因为您在调度程序上观察到。io在此代码中（参见下文），而不是后者调用AppObservable。bindFragment（这个，可观察的。只有（0））

AppObservable.bindFragment(this, Observable.just(0))
   .observeOn(Schedulers.io())
   .subscribe(v -> setWallpaperOnSeparateThread());

您希望在io线程中执行任务，然后在主线程中执行任务。要做到这一点，您可以使用一个可观察的链接调用。

AppObservable.bindFragment(this, Observable.just(0))
   .observeOn(Schedulers.io())
   .flatMap(v -> Observable.defer(() -> WallpaperHelper.setBitmapAsWallpaper(photoViewAttacher.getVisibleRectangleBitmap(), getBaseActivity())))
   .delay(500, TimeUnit.MILLISECONDS)
   .observeOn(AndroidSchedulers.mainThread())
   .subscribe(v -> loadFinishAnimationAfterSetWallpaper());

请注意，我使用“延迟”将异步任务表示为可观察的，但您可以用“下一步”调用替换“平面图”调用。

AppObservable.bindFragment(this, Observable.just(0))
   .observeOn(Schedulers.io())
   .doOnNext(v -> WallpaperHelper.setBitmapAsWallpaper(photoViewAttacher.getVisibleRectangleBitmap(), getBaseActivity()))
   .delay(500, TimeUnit.MILLISECONDS)
   .observeOn(AndroidSchedulers.mainThread())
   .subscribe(v -> loadFinishAnimationAfterSetWallpaper());