rx-java - 使用 RxJava2 下载带有进程的文件

Question

正如标题所说，我想使用 RxJava2 和 okhttp 下载文件。而且还需要过程。

在我看来，数据流是String url -> Response -> 乘 Float process .

所以首先我需要一个 Single发出 Response .

Single.create((SingleOnSubscribe<Response>) emitter -> {
    emitter.onSuccess(xx);// or throw error
});

接下来我需要 Flowable对？因为我想向观察者发出乘法进程信息。

那么在这里我该怎么办？提前致谢。

编辑

我试图转换 Single至 Flowable .

Single.create((SingleOnSubscribe<Response>) emitter -> {
    emitter.onSuccess(xxx);// or throw error
}).toFlowable()
        .flatMap((Function<Response, Publisher<Float>>) response -> Flowable.create(xxx))
        .subscribe(process -> {});

}

但我不知道这样做是否合适。

编辑

我不关心 okhttp 的细节，我只关心与 RxJava 相关的事情如 Single和 Flowable .

Answer 1

如果你使用改造，你可以试试这个 https://github.com/imfms/retrofit-rxjava-request-with-progress

如果不适应基础类之一:

CallEnqueueWithProgressObservable

CallExecuteWithProgressObservable

首先使用okhttp async api。
其次使用 rx 调度程序进行异步。