0

Вот есть был такой метод

public List<String> search(String iQuery)
{
            try
            {
                Thread.sleep(700);
            }
            catch (InterruptedException iE)
            {
                iE.printStackTrace();
            }

            List<String> result = new ArrayList<>();

            for (String iStr : mSettlementList)
            {
                if (iStr.toLowerCase().contains(iQuery.toLowerCase()))
                {
                    result.add(iStr);
                }
            }

            return result;
}

Тут стоит задержка для того, чтоб когда выполняется поиск прогрес бар успел сделать работу а не сразу судорожно появлялся и исчезал. Ну и потом сортировка и возврат результата

Теперь точно это же я хочу сделать с помощью Rx2

Вот, что получилось

public List<String> search(String iQuery)
{
    return Observable.fromIterable(mSettlementList)//
                     .subscribeOn(AndroidSchedulers.mainThread())//
                     .observeOn(AndroidSchedulers.mainThread())//
                     .filter(iStr -> iStr.toLowerCase().contains(iQuery.toLowerCase()))//
                     .toList()//
                     .blockingGet();
}

Вроде все работает, но вот только задержки нет...

Как ее сюда добавить?

1 ответ 1

3

Используйте оператор delay :

Observable.fromIterable(mSettlementList)
                 .delay(700, TimeUnit.MILLISECONDS)
                 .subscribeOn(AndroidSchedulers.mainThread())
                 .observeOn(AndroidSchedulers.mainThread())
                 .filter(iStr -> iStr.toLowerCase().contains(iQuery.toLowerCase()))
                 .toList()
                 .blockingGet();

Ваш ответ

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

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