@Alexzatey

Выходит сообщение над subscribe «Result of subscribe is ignored». На консоль не выводятся сообщения с doOnNext и subscribe .Как это исправить?

Observable <Integer> observable = Observable.just(1, 2, 3, 4, 5, 6);

               observable .doOnNext(integer -> println("Emitting item " + integer + " on: " + currentThread().getName()))
                .map(integer -> integer * 3)
                .filter(integer -> integer % 2 == 0)
                .subscribeOn(Schedulers.computation())
                .subscribe(integer -> println("Consuming item " + integer + " on: " + currentThread().getName()));
  • Вопрос задан
  • 139 просмотров
Пригласить эксперта
Ваш ответ на вопрос

Войдите, чтобы написать ответ

Похожие вопросы