добавить подписчика в единое наблюдаемое значение

Question

Я хотел бы знать, как добавить подписчика для одного, как показано ниже в коде.когда я пытаюсь добавить .subscribe () или .blockingsubscribe () автозаполнение в eclise не показывает их

код :

Single<List<List<Person>>> singles = Single.just(Main.getPersons());
    singles
    .observeOn(Schedulers.io())
    .map(x->System.out.println(x.size()))

Answer 1

Вы используете неправильную лямбду, и это сбрасывает вашу IDE. Попробуйте это:

Single<List<List<Person>>> singles = Single.just(Main.getPersons());
singles
.observeOn(Schedulers.io())
.doOnSuccess(x -> System.out.println(x.size()))
.  // <---------------------------------------- now it should bring up the autocomplete

Answer 2

Ваша функция карты должна возвращать то, на что вы хотите подписаться:

.map(x -> {
    System.out.println(x.size());
    return ???;
 });