Преобразовать этот вариант использования из AsyncTask в RxJava - PullRequest
Новая
       11

Преобразовать этот вариант использования из AsyncTask в RxJava

0 голосов
/ 24 апреля 2019

Не уверен, как его искать, но это мой случай. Я хочу добиться этого в rxjava: // я внутри делать в фоновом режиме. Нет проблем с типом возврата элементов, потому что я могу вернуть Observable для всех данных там. С этим я справлюсь. Я не могу справиться с формированием этого нового массива после итерации другого. 

ArrayList<OrderRow> orderRowArrayList = bundlePackItemSelectionInteract.findAllBundlePackInsertedItemsNonObservable(FilterArgs.getOrderCode(), recipeNo);
            ArrayList<Item> itemArrayList = new ArrayList<>();
            double totalUnitPrice = 0.0;
            if (orderRowArrayList.size() > 0) {
                for (OrderRow orderRow : orderRowArrayList) {
                    itemArrayList.add(bundlePackItemSelectionInteract.loadItemNonObservable(orderRow.getItemCode()));
                }
                if (itemArrayList.size() > 0) {
                    for (Item item : itemArrayList) {
                        for (OrderRow iterator : orderRowArrayList) {
                            iterator.setEditMode(true); //ignore instructions
                            iterator.setBasePrice(Utils.parseDouble(Utils.round(item.getCustomerUnitPrice(customerUnitPrice))));
                            iterator.setSoldBasePrice(Utils.parseDouble(Utils.round(item.getCustomerUnitPrice(customerUnitPrice))));
                            bundlePackItemSelectionInteract.updateDocument(iterator);
                        }
                        totalUnitPrice += item.getCustomerUnitPrice(customerUnitPrice);
                    }
                }
            }
...