Объясните поведение Observable RxJava

Этот код:

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.:Выключение из цепочки потоков на ситуацию не влияет.