嵌套 zip 导致 Observable 的返回值不合适

Question

我是响应式编程的新手，并且有这种无法编译的方法，我无法正确使用，

public Observable<Data> findData(long templateId) {
    ..
    ..

    return Observable.zip(templateObs, dataObs, (templateObj, dataObj) -> {

        try {

            switch(model) {

                case SINGLE: {
                        ..
                        ..

                        return new Data();
                }


                case TOURNAMENT: {

                        // compilation error on the entire .zip block :
                        // Type mismatch: cannot convert from Observable<Object> to Observable<Data>

                        return Observable.zip(obs1, obs2, obs3, obs4, (data, data2, data3, data4) -> { 
                            ..
                            ..

                            return new Data(data1,data2,data3,data4);
                        }).flatMap(results -> results);
                }
            }

        }catch(DataException e) {
            log.error(e);
        }

        return null;
    });
}

由于某种原因，内部返回 .zip 返回 Observable 而不是 Observable - 这会导致编译错误...

如果我从内部 .zip 中删除“返回”，那么它会编译。

Answer 1

zip 需要一个返回 Object 的 lambda，在你的情况下是 Data，这就是你在 SINGLE 情况下所做的。

在 TOURNAMENT 中，您返回一个不是 Data 对象的 Observable。

根据您的情况，如果您想返回 Data，则必须使用 toBlocking 方法阻止您需要的 zip 运算符。

case TOURNAMENT: 
        return Observable.zip(obs1, obs2, obs3, obs4, 
                             (data, data2, data3, data4) -> 
                                   { return new Data(data1,data2,data3,data4); }
                             ).toBlocking().single();

否则，您可以返回 Observable<Data> 来代替 Data 对象。在这种情况下，只需更改您的 SINGLE 案例以返回一个 Observable ，它只会发出您的 Data 对象。

 case SINGLE:  return Observable.just(new Data());