Worker（来自WorkManager组件）中的同步或异步Rxjava，什么是正确的选择？

穆罕默德·易卜拉欣

我是新架构组件WorkManager的新手，我通过Retrofit和RxJava进行API调用。

我的用例是从后端获取新帖子，然后显示通知并更新小部件。

因此，Worker类的doWork（）方法中的代码可能看起来像这样。

@NonNull
  @Override
  public Result doWork() {
    AppDependencies appDependencies = new AppDependencies((Application) getApplicationContext());
    Repository repository = appDependencies.getRepository();

    repository.getNewPosts()
        .flatMap(newPosts -> repository.inserPosts(newPosts).toObservable())
        .doOnError(Timber::e)
        //if success - > return  Result.SUCCESS,
        // -> show notification
        // -> update widget
        // error-> return Result.Failure
        .dontKnowWhatBestNextThing; //blocking or subscribing

    //if we reached here then Retry
    return Result.RETRY;
  }

我的问题是在Worker类中使用RxJava代码的正确方法是什么，因为doWork（）方法具有返回值，所以我必须使Rx代码同步。

如果我使用非阻塞Rx方法，如何返回值（成功-失败-重试）

语义器

从WorkManager版本开始，1.0.0-alpha12他们添加了一个名为的新工件work-rxjava2，RxWorker正是为此目的包括了类。这是ListenableWorker期望的特例Single<Result>。

要实现它，首先要确保在您的产品中包含正确的工件build.gradle：

dependencies {
   ...
   implementation "android.arch.work:work-runtime-ktx:$work_version"
   implementation "android.arch.work:work-rxjava2:$work_version"
}

并实现您的RxWorker：

class MyRxWorker(context : Context, params : WorkerParameters) : RxWorker(context, params) {

    val remoteService = RemoteService()

    override fun createWork(): Single<Result> {
        return remoteService.getMySingleResponse()
                .doOnSuccess { /* process result somehow */ }
                .map { Result.success() }
                .onErrorReturn { Result.failure() }
    }
}

本文收集自互联网，转载请注明来源。

如有侵权，请联系 [email protected] 删除。