RxWorker 中的多线程

我们提供 WorkManager 和 RxJava 之间的互操作性。要开始使用，请在您的 gradle 文件中包含work-rxjava3 依赖项以及 work-runtime。还有一个 work-rxjava2 依赖项支持 rxjava2。

然后，不要扩展 Worker，而应扩展 RxWorker。最后，覆盖 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() 时，订阅将被取消，因此您无需以任何特殊方式处理工作停止。