java - 链接两个 Observable 以返回另一个 Observable

Question

我有两个名为 A<'ModelA'> 和 B<'ModelB'> 的可观察量。它们每个都对不同的 REST 服务执行请求，因此它们扩展了如上所述的不同模型。其中任何一个执行的请求都可能失败。现在，我需要能够链接它们并返回一个 ModelC 对象。因此，伪编码流将如下所示:

A<'ModelA'> 执行请求，如果失败则执行某些操作，如果失败，则将其结果 (responseModelA) 传递给 B<'ModelB'>，以便它可以执行另一个涉及使用部分 responseModelA 的 REST 请求。如果 B 失败，则发生某些事情，如果没有，则将其响应 (responseModelB) 与 responseModelA(手动设置 POJO 字段)组合在一起以创建 ModelC，这是订阅者应在其 call() 上作为参数接收的内容 方法。

可以使用 rxJava 远程编码吗？我对此很执着，所以我愿意接受任何建议。

谢谢。

Answer 1

这假设您已经创建了一个 REST 请求接口(interface)，该接口(interface)返回类似于以下内容的 Observables(使用 Retrofit 这非常简单):

interface RestApi {
    Observable<ModelA> getModelA();
    Observable<ModelB> getModelB(int modelBId);
}

class ModelA {
    int modelBId;
    Object fieldA;
}

class ModelB {
    Object fieldB;
}

class ModelC {
    Object fieldFromA;
    Object fieldFromB;

    public ModelC(Object fieldFromA, Object fieldFromB) {
        this.fieldFromA = fieldFromA;
        this.fieldFromB = fieldFromB;
    }
}

要使 ModelB 请求依赖于 ModelA 请求的结果，可以使用 .flatMap 将一个 Observable 的结果转换为另一个 Observable。

然后，创建ModelC，使用.map从ModelA和ModelB中选取所需的字段并返回结果。

RestApi restApi;

Observable<ModelC> observeModelC() {
    return restApi
            .getModelA()
            .flatMap(new Func1<ModelA, Observable<ModelC>>() {
                @Override
                public Observable<ModelC> call(final ModelA modelA) {
                    // Use the modelBId from modelA to get ModelB.
                    return restApi
                            .getModelB(modelA.modelBId)
                            // Combine A & B to create C
                            .map(new Func1<ModelB, ModelC>() {
                                @Override
                                public ModelC call(ModelB modelB) {
                                    return new ModelC(modelA.fieldA, modelB.fieldB);
                                }
                            });
                }
            });
}

您的订阅者将如下所示:

observeModelC()
        .subscribe(new Observer<ModelC>() {
            @Override
            public void onCompleted() {
                // All done.
            }

            @Override
            public void onError(Throwable e) {
                // All errors from any API request will end up here.
                // For Retrofit, cast e to RetrofitError for
                // detailed error info.
            }

            @Override
            public void onNext(ModelC modelC) {
                // Yeah! - Use modelC.
            }
        });