java – 如何调用依赖于rx网络调用的非rx网络调用

我有一个返回Observable的网络调用,我有另一个网络调用,它不是rx依赖于第一个Observable,我需要以某种方式将它全部转换为Rx.

Observable<Response> responseObservable = apiclient.executeRequest(request);

执行后我需要做另一个不返回Observable的http调用：

responseObservable.map(response - > execute the no rx network call using the response.id) 

noRxClient.getInformation(response.id, new Action1<Information>() {
    @Override
    public void call(Information information) {
        //Need to return information with page response
    }
});

之后我需要调用此方法来呈现响应

renderResponse(response, information);

如何将非rx调用与rx连接,然后使用RxJava调用渲染响应？

解决方法:

您可以使用Observable.fromEmitter(RxJava1)或Observable.create(RxJava2)和Observable.fromCallable(用于非异步调用)将异步非rx调用包装到Observable中：

private Observable<Information> wrapGetInformation(String responseId) {
    return Observable.create(emitter -> {
        noRxClient.getInformation(responseId, new Action1<Information>() {
            @Override
            public void call(Information information) {
                emitter.onNext(information);
                emitter.onComplete();
                //also wrap exceptions into emitter.onError(Throwable)
            }
        });
    });
}

private Observalbe<RenderedResponse> wrapRenderResponse(Response response, Information information) {
    return Observable.fromCallable(() -> {
        return renderResponse(response, information);
        //exceptions automatically wrapped
    });
}

并使用overloaded flatMap运算符组合结果：

apiclient.executeRequest(request)
    .flatMap(response -> wrapGetInformation(response.id), 
            (response, information) -> wrapRenderResponse(response, information))
    )
    //apply Schedulers
    .subscribe(...)

标签：java,android,rx-java,rx-android,rx-binding
来源： https://codeday.me/bug/20190701/1351090.html