我们提供 WorkManager 与 RxJava 之间的互操作性。要开始使用,请在 gradle 文件中添加 除 work-runtime
之外的 work-rxjava3
依赖项。此外还有一个 work-rxjava2
依赖项,用于支持 rxjava2。
然后,您应该继承 RxWorker
,而不是继承 Worker
。最后,重写 RxWorker.createWork()
方法以返回一个 Single<Result>
,表示您的执行 Result
,如下所示:
Kotlin
class RxDownloadWorker( context: Context, params: WorkerParameters ) : RxWorker(context, params) { override fun createWork(): Single<Result> { return Observable.range(0, 100) .flatMap { download("https://www.example.com") } .toList() .map { Result.success() } } }
Java
public class RxDownloadWorker extends RxWorker { public RxDownloadWorker(Context context, WorkerParameters params) { super(context, params); } @NonNull @Override public Single<Result> createWork() { return Observable.range(0, 100) .flatMap { download("https://www.example.com") } .toList() .map { Result.success() }; } }
请注意,RxWorker.createWork()
默认在主线程上调用,但返回值在后台线程上订阅。您可以重写 RxWorker.getBackgroundScheduler()
来更改订阅线程。
当 RxWorker
处于 onStopped()
状态时,订阅将被处理,因此您无需以任何特殊方式处理工作停止。