android - 如何使用 RxJava 将嵌套的 double 值列表转换为 Java 类？

Question

在我的 Android 客户端中，我从后端收到此 JSON 数据:

[
    [
        1427378400000,
        553
    ],
    [
        1427382000000,
        553
    ]
]

这是实际加载数据的例程。我正在使用 RxAndroid和 Retrofit在这里。

private void getProductLevels() {
    Observable<List<List<Double>>> responseObservable =
        mProductService.readProductLevels();
    AppObservable.bindFragment(this, responseObservable)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        // TODO: Transform List<List<Double>> into List<ProductLevel>
        .subscribe(new Subscriber<List<List<Double>>>() {
            @Override
            public void onCompleted() {}

            @Override
            public void onError(Throwable e) {}

            @Override
            public void onNext(List<List<Double>> response) {}
        });

}

如何映射内部 List<Double>到特定的 Java 类，例如 ProductLevel使用 RxJava 运算符？

public class ProductLevel {

    public Double mTimeStamp;
    public Double mLevel;

    public ProductLevel(Double timeStamp, Double level) {
        mTimeStamp = timeStamp;
        mLevel = level;
    }

}

最后，我想收到这个:List<ProductLevel> .

Answer 1

根据您的数据，您会收到一对列表(时间戳、级别)。这对由仅包含 2 个值的列表表示。

因此，您想要发出每一对，并将每一对转换为ProductLevel。

为此，您必须 flatMap 您的配对列表以发出每一对。然后将每一对映射到一个ProductLevel。最后，只需构建一个包含所有已发出项目的 list。

(java8风格)

AppObservable.bindFragment(this, responseObservable)
             .subscribeOn(Schedulers.io())
             .observeOn(AndroidSchedulers.mainThread())
             .flatMapIterable(listOfList -> listOfList) // or flatMap(l -> Observable.from(l))
             .map(pair -> new ProductLevel(pair.get(0),pair.get(1))) // build ProductLevel for each pair
             .toList() // build a list with all ProductLevel
             .subscribe(listOfProductLevel -> /** ... **/);