3

Вот есть такой метод который я использую для того, чтоб при получении ответа с сервера сделать парс сразу в енам

@JsonCreator
    public static eTaxCode getTaxCodeByIdOrDefault(int iTaxCode)
    {
        eTaxCode result = DEFAULT;

        for (eTaxCode tmp : eTaxCode.values())
        {
            if (tmp.getTaxCodeId() == iTaxCode)
            {
                result = tmp;
                break;
            }
        }

        return result;
    }

Все просто я беру значения енама прохожу по каждому и если есть совпадение, то возвращаю это значение если нет, то возвращаю дефолтное значение.

Теперь хочу сделать тоже самое с помощью RxJava2 (знаю, что возможно это не тот случай и что стандартный подход очень крутой, но интересно понять как это сделать)

Я пробовал сделать как то так(на таком же примере)

@JsonCreator
    public static eSingDetails getSingDetails(int iSignDtls)
    {
        eSingDetails result = DEFAULT;

        Observable.fromArray(eSingDetails.values())//
                  .filter(iValue -> iValue.getSignDtls() == iSignDtls)//
                  .isEmpty()//
                  .subscribe(iIsEmpty ->
                  {
                      if (iIsEmpty)
                      {

                      }
                      else
                      {

                      }
                  });

        return result;
    }

Но все равно не то, что то получается...

Как это правильно сделать?

3
  • 2
    Rx тут совсем не подходит, поэтому у вас и не получается. Это больше задача для stream api.
    – eugeneek
    1 фев 2018 в 13:55
  • 1
    @eugeneek Я несколько раз слышал, что есть разработчики которые пишут полностью реактивную апплекацию(правда еще не встречал таких апплекаций) и вот мне интересно как был бы написан этот метод если использовать полностью реактивный подход
    – Sirop4ik
    1 фев 2018 в 14:18
  • Ну если просто ради интереса, то метод может возвращать не сразу eSingDetails, а обсервабл, который обёрнут вокруг него: Observable<eSingDetails> (либо Flowable, Single и т.д. в зависимости от задачи), чтобы можно было использовать дальше в цепочке Rx, либо просто подписаться в нужном месте. Но я бы так делать не стал. Любая технология - это лишь инструмент, и пользоваться им нужно в предназначенных для него местах. А гвозди, как известно, можно и микроскопом забивать.
    – eugeneek
    2 фев 2018 в 8:59

1 ответ 1

1

Сама функция может выглядеть так:

public static Single<eTaxCode> getTaxCodeByIdOrDefault(int iTaxCode)
{
   return Flowable.fromIterable(eTaxCode.values())
                  .takeUntil(value -> {
                     return value.getTaxCodeId() == iTaxCode;
                  })
                  .filter(value -> value.getTaxCodeId() == iTaxCode)
                  .single(DEFAULT);
}

А вызов соответственно так:

getTaxCodeByIdOrDefault(taxCodeId)
   .subscribe(taxCode -> {
      // что-то делаем
   });

Документация по оператору takeUntil

Документация по Single

4
  • Я так понимаю, что оператор takeUntil здесь нужен только для того, чтоб остановить выполнение если нужный элемент будет найден, верно?
    – Sirop4ik
    17 апр 2018 в 10:04
  • @AlekseyTimoshchenko, именно
    – A. Shakhov
    17 апр 2018 в 10:07
  • Да, но как вернуть не Single а обьект? Так как в моем коде Rx не везде и удобнее если будет возвращатся обьект , а не Single
    – Sirop4ik
    17 апр 2018 в 10:09
  • @AlekseyTimoshchenko, использование Rx подразумевается то, что сущности в обёртках в виде потоков, на получение которых нужно подписываться. Я думаю, что если вам нужно получить результат синхронно, то реактивный подход применять не нужно
    – A. Shakhov
    17 апр 2018 в 10:19

Ваш ответ

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

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