0

Есть 2 фрагмента: первый отвечает за отображение списка товаров, второй показывает детали товара. У второго фрагмента также есть кнопка "Купить", которая уменьшает количество товара в наличии на 1. При нажатии на эту кнопку обновляется запись в БД. Теперь проблема. Мне нужно сымитировать долгую запись в БД, условно 3 секунды. Во втором фрагменте данные обновляются после заданного времени, а в первом фрагменте моментально при переходе от второго. Нужно, чтобы RecyclerView из первого фрагмента обновился после долгой записи в БД в другом потоке, вызванном из второго фрагмента. БД - room, также использую RxJava для упрощения работы с потоками (только начал изучать RxJava)

Первый фрагмент:

public class StoreFragment extends Fragment {

    private static final String TAG = StoreFragment.class.getSimpleName();
    private RecyclerView recyclerView;
    private CompositeDisposable mDisposable = new CompositeDisposable();
    private DataAdapter dataAdapter = new DataAdapter(App.getProductDAO());

    @Override
    public void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
    }

    @Nullable
    @Override
    public View onCreateView(@NonNull LayoutInflater inflater, @Nullable ViewGroup container, @Nullable Bundle savedInstanceState) {
        return inflater.inflate(R.layout.fragment_store, container, false);
    }

    @Override
    public void onViewCreated(@NonNull View view, @Nullable Bundle savedInstanceState) {

        Toolbar toolbar = view.findViewById(R.id.fragment_store_toolbar);
        toolbar.setTitle(getString(R.string.shop));
        recyclerView = view.findViewById(R.id.fragment_store_recycler_view);
        LinearLayoutManager linearLayoutManager = new LinearLayoutManager(view.getContext());
        recyclerView.setLayoutManager(linearLayoutManager);

        getProducts();
    }

    @Override
    public void onDestroy() {
        super.onDestroy();

        mDisposable.clear();
    }

    private void setAdapter(List<Product> productList){
        StoreFragmentRecyclerAdapter adapter = new StoreFragmentRecyclerAdapter(this.getContext(), new ArrayList<>(productList), false);
        recyclerView.setAdapter(adapter);
    }

    private void getProducts(){
        mDisposable.add(dataAdapter.getProducts()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .toFlowable()
                .flatMap(Flowable::fromIterable)
                .filter(products -> products.getCount() > 0)
                .toList()
                .subscribe(this::setAdapter, throwable -> Log.e(TAG, "Unable to get products", throwable)));
    }
}

Второй фрагмент:

public class DetailItemFragment extends Fragment {

    private static final String TAG = DetailItemFragment.class.getSimpleName();
    private Product mProduct;
    private CompositeDisposable mDisposable = new CompositeDisposable();
    private DataAdapter dataAdapter = new DataAdapter(App.getProductDAO());


    public DetailItemFragment(Product product) {
        this.mProduct = product;
    }

    @Nullable
    @Override
    public View onCreateView(@NonNull LayoutInflater inflater, @Nullable ViewGroup container, @Nullable Bundle savedInstanceState) {
        return inflater.inflate(R.layout.fragment_detail_item, container, false);
    }

    @Override
    public void onViewCreated(@NonNull View view, @Nullable Bundle savedInstanceState) {
        super.onViewCreated(view, savedInstanceState);

        TextView nameTextView = view.findViewById(R.id.fragment_detail_item_text_view_name_good);
        TextView priceTextView = view.findViewById(R.id.fragment_detail_item_text_view_price_good);
        TextView countTextView = view.findViewById(R.id.fragment_detail_item_text_view_count_good);

        nameTextView.setText(mProduct.getName());
        priceTextView.setText(String.format("%.2f руб.", mProduct.getPrice()));
        countTextView.setText(String.format("%d шт.", mProduct.getCount()));

        Button buyButton = view.findViewById(R.id.fragment_detail_item_button_buy);
        buyButton.setOnClickListener(v -> {
            mProduct.buyProduct();
            mDisposable.add(dataAdapter.update(mProduct)
                    .subscribeOn(Schedulers.io())
                    .delay(3000, TimeUnit.MILLISECONDS)
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribe(() -> countTextView.setText(String.format("%d шт.", mProduct.getCount())),
                            throwable -> Log.e(TAG, "Unable to update products", throwable)));
        });
    }
}

Как лучше всего реализовать данную задачу? Желательно силами RxJava

6
  • Нужно глянуть куда то в сторону LiveData 15 янв 2020 в 9:21
  • Там у вас нет никакой имитации задержки записи в бд, у вас запись идёт сразу, а задержка на получение результата.
    – IR42
    15 янв 2020 в 11:18
  • Да, это я уже понял. Вот я и не могу понять, как сделать эту задержку в записи, а не в получении результата
    – Coder96848
    15 янв 2020 в 11:51
  • У вас задержка сейчас стоит при переходе в UI поток, что бы сделать задержку перед записью переместите .delay(3000, TimeUnit.MILLISECONDS) перед subscribeOn(). Так же, так как будет задержка и при быстром переходе обратно на 1 фрагмент, если время не истечет, то будет утечка памяти. Если переход будет быстрым(как вы сказали, данные у вас обновляются сразу), то метод загрузит не обновленные данные. Можно реализовать Observable который хранит определенное количество данных, например последний список, а потом подписаться на него или сделать Observable, который при каждом изменении БД автообвлятся
    – AlexGin
    16 янв 2020 в 1:31
  • Если не решили еще данную задачу, отпишитесь
    – AlexGin
    16 янв 2020 в 1:32

1 ответ 1

0

Так происходит из-за того, что оператор delay(3000, TimeUnit.MILLISECONDS) во втором фрагменте стоит после Observable dataAdapter.update(mProduct), это означает что продукт в БД обновляется почти сразу, а потом происходит задержка 3 секунды прежде чем выполнится subscribe. Но в первом фрагменте Observable работает без задержки и обновляет данные сразу же как только они обновились в БД. В вашем случае поможет поставить задержку перед запуском Observable с обновлением, это можно сделать например через Observable.timer:

mDisposable.add(Observable.timer(3000, TimeUnit.MILLISECONDS)
                    .observeOn(Schedulers.io())
                    .map(t->dataAdapter.update(mProduct))
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribe(() -> countTextView.setText(String.format("%d шт.", mProduct.getCount())),
                            throwable -> Log.e(TAG, "Unable to update products", throwable)));

Так как Observable.timer сразу подписывается на Schedulers.computation(), чтобы поменять в операции с БД шедулер на io нужно перед map поставить observeOn(Schedulers.io())

4
  • Среда ругается на `() -> countTextView.setText(String.format("%d шт.", mProduct.getCount()). Пишет ошибку "cannot infer functional interface type". Как вылечить?
    – Coder96848
    16 янв 2020 в 17:14
  • В общем, да, так запуск откладывается, но запись в саму БД происходит через раз, причем от чего зависит я не могу уловить
    – Coder96848
    16 янв 2020 в 18:07
  • попробуйте посмотреть в Logcat на предмет стектрейса ошибок (можно отфильтровать по Unable to update products - это текст, который посылается у вас в коде) 16 янв 2020 в 18:23
  • В логи ошибок не выводит
    – Coder96848
    16 янв 2020 в 19:22

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.