Как преобразовать вложенный список двойных значений в класс Java с помощью RxJava?

В моем клиенте Android я получаю эти данные JSON из бэкэнда:

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

Вот процедура, которая фактически загружает данные. Я использую RxAndroid и Модернизируйте здесь.

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>.


android observable retrofit rx-java rx-android
person JJD    schedule 29.04.2015    source источник

Ответы (3)


arrow_upward
2
arrow_downward

По вашим данным вы получаете список пар (timestamp, level). Эта пара представлена ​​списком, который содержит только 2 значения.

Итак, вы хотите испустить каждую пару и преобразовать каждую пару в ProductLevel.

Для этого вам нужно будет flatMap составить список пар, чтобы испустить каждую пару. Затем map каждую пару в 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 -> /** ... **/);
person dwursteisen    schedule 30.04.2015

arrow_upward
0
arrow_downward 

List<ProductLevel> productLevels = new ArrayList<>();
for(List<Double> p: list) {
    productLevels.add(new ProductLevel(p.get(0),p.get(1)));
}

Я думаю, это должно сработать.

person hkN    schedule 29.04.2015
comment
Да, но я хочу использовать операторы RxJava. - person JJD; 29.04.2015

arrow_upward
0
arrow_downward

Если вы измените readProductLevels, чтобы выдавать каждый элемент списка по одному, вы можете реагировать на них по одному:

В mProductService:

private Observable<List<Double>> readProductLevels() {
        return Observable.create(
                new Observable.OnSubscribe<List<Double>>() {
                    @Override
                    public void call(Subscriber<? super List<Double>> subscriber) {
                        List<List<Double>> items = new ArrayList<List<Double>>();
                        List<Double> list1 = new ArrayList<Double>() {{
                            add(1D);
                            add(2D);
                        }};
                        items.add(list1);
                        List<Double> list2 = new ArrayList<Double>() {{
                            add(10D);
                            add(12D);
                        }};
                        items.add(list2);
                        List<Double> list3 = new ArrayList<Double>() {{
                            add(21D);
                            add(22D);
                        }};
                        items.add(list3);

                       // Imagine the list creation above is your Json parsing


                        for (List<Double> list : items) {
                            subscriber.onNext(list);
                        }

                        subscriber.onCompleted();
                    }
                });
    }

Позволяет подписаться на каждый элемент в вашем суперсписке:

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

                            @Override
                            public void onError(Throwable e) {
                            }

                            @Override
                            public void onNext(List<Double> response) {
                                new ProductLevel(response.get(0), response.get(1));
                            }
                        });

    }
person Blundell    schedule 29.04.2015