java - 将订阅者添加到单个观察值

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

您的 map 函数应该返回您想要订阅的内容:

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