2

Этот код:

Observable.just(1, 2, 3, 4, 5)
          .map(x -> x * 2)
          .subscribeOn(Schedulers.newThread())
          .observeOn(AndroidSchedulers.mainThread())
          .subscribe(observer);

Выводит в лог 2, 4, 6, 8, 10 (т.е. onNext отрабатывает 5 раз). Если же применить map(x -> 123)

Observable.just(1, 2, 3, 4, 5)
          .map(x -> 123)
          .subscribeOn(Schedulers.newThread())
          .observeOn(AndroidSchedulers.mainThread())
          .subscribe(observer);

то в логи 123 пишется только два раза. Почему так?

upd.:Выключение из цепочки потоков на ситуацию не влияет.

9
  • 1
    Должно работать одинаково для 1 и второго варианта. Возможно у вас InstantRun сбоит. Попробуйте его отключить
    – ЮрийСПб
    26 фев 2019 в 8:32
  • после выполнения данного кода, приложение случаем не закрывается? Может он просто не успевает вывести?
    – Komdosh
    26 фев 2019 в 8:38
  • Догадывался, что так быть не должно. InstantRun отключен. 26 фев 2019 в 8:39
  • @Komdosh, нет, приложение не закрывается. 26 фев 2019 в 8:40
  • ну отписки тоже не происходят?
    – Komdosh
    26 фев 2019 в 8:45

1 ответ 1

3

Логгер скрывает одинаковые строки, поэтому вывод выглядит следующим образом:

123
(com.example.app) identical 3 lines
123
1
  • OMG, даже стыдно стало :/ Просто на лог стоит TAG и строки identical не видно. Благодарю! 26 фев 2019 в 9:29

Ваш ответ

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

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