Ошибки RxJava - как их исправить? - PullRequest
0 голосов
/ 01 декабря 2018

У меня есть Observable с некоторыми объектами внутри.Мне нужно обнаружить объект, где я получил ошибку.

Ниже вы можете увидеть мой код.

Observable.from(Ids)
        .map(integer -> {

            return HelperFactory.getInstance().getOrderRuntimeDao().queryForId(integer);

        })
        .flatMap(order -> {

            return new syncClient().observable();

        }, (order, document) -> {

            return new Pair(order, document);

        })
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(pair -> {

            if(pair != null){

                Document document = (Document)pair.second;

                Order order = (Order)pair.first;
                order.setOuterId(document.getId());
                order.setNumber(document.getNumber());

                HelperFactory.getInstance().getOrderRuntimeDao().update(order);
            }

        }, throwable -> {

            // HERE I NEED TO GET REF OF ORDER OBJECT. HOW I CAN DO IT?
        });

Я на самом деле не идея.Пожалуйста, помогите мне.

...