java - 为什么onNext没有效果

Question

这个问题已经有答案了:

delay and interval operators do not work properly (1 个回答)

已关闭 4 年前。

如下图，我正在学习如何使用rxjava。我想知道如何使用映射运算符来显示每个列表中有多少个 Person 对象。问题是，当我运行来自可观察对象的 onNext 代码时，永远不会调用。

注意:下面发布的 person 类包含可选属性。

请让我如何使用 map 运算符显示每个列表中有多少个 Person 对象。

提前致谢

代码:

public class Main {

public static void main(String[] args) {
    Observable<List<Person>> observables = Observable.create(e-> {
        for(List<Person> p : Main.getPersons()) {
            e.onNext(p);
        }
        e.onComplete();
    });
     observables
    .map(p->p.size())
    .observeOn(Schedulers.io())
    .subscribe(new Observer() {
        @Override
        public void onComplete() {
            // TODO Auto-generated method stub
            System.out.println("onCompleted");
        }

        @Override
        public void onError(Throwable arg0) {
            // TODO Auto-generated method stub

        }

        @Override
        public void onNext(Object arg0) {
            // TODO Auto-generated method stub
            System.out.println("onNextFromObserver: " + arg0);
        }

        @Override
        public void onSubscribe(Disposable arg0) {
            // TODO Auto-generated method stub
        }
    });
}

private static <T> Observable<T> toObservable(T s) {
    return Observable.just(s);
}
private static List<List<Person>> getPersons() {
    return Arrays.asList(
            Arrays.asList(new Person("Sanna1", 59, "EGY"), new Person(null, 59, "EGY"), new Person("Sanna3", 59, null)),
            Arrays.asList(new Person("Mohamed1", 59, "EGY"), new Person(null, 59, "EGY")),
            Arrays.asList(new Person("Ahmed1", 44, "QTR"), new Person("Ahmed2", 44, "QTR"), new Person(null, null, "QTR")),
                    Arrays.asList(new Person("Fatma", 29, "KSA")),
                    Arrays.asList(new Person("Lobna", 24, "EGY")));
}
}

人

public class Person {
private String name = null;
private String address = null;
private int age;

private Optional<String> optName= null;
private Optional<Integer> optAge= null;
private Optional<String> optAddress = null;

public Person(String name, Integer age, String address) {
    this.optName = Optional.ofNullable(name);
    this.optAge = Optional.ofNullable(age);
    this.optAddress = Optional.ofNullable(address);
}

public Optional<String> getName() {
    return optName;
}

public void setName(String name) {
    this.optName = Optional.ofNullable(name);
}

public Optional<String> getAddress() {
    return this.optAddress;
}

public void setAddress(String address) {
    this.optAddress = Optional.ofNullable(address);
}

public Optional<Integer> getAge() {
    return this.optAge;
}

public void setAge(int age) {
    this.optAge = Optional.ofNullable(age);
}
}

Answer 1

onNext 未执行的原因与 Schedulers.io() 使用守护线程有关。这意味着如果没有其他线程处于 Activity 状态，它们不会保持 JVM 运行。

简单地说，因为您的 main 函数结束了，唯一运行的代码是 IO 调度程序，它将在将来调用 onNext 。由于没有非守护线程处于 Activity 状态，因此 JVM 会在实际发生之前退出。使用 blockingSubscribe 阻塞主线程，直到 observable 完成，您将看到您期望的输出。