doOnNext 中使用 subscribe() 难道不会阻塞吗？

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

For Existing Member Sign In

• 请不要在回答技术问题时复制粘贴 AI 生成的内容

This topic created in 1780 days ago, the information mentioned may be changed or developed.

代码如下：

public Flux<Student> doSomething() {
    return this.rtpl.findAll(Student.class).doOnNext(student -> {
        Record rec = new Record();
        rec.setRecord(String.format("学生第 %s 次查成绩", count.addAndGet(1)));
        this.rtpl.insert(rec).subscribe();
    });
}

在使用 subscribe 的地方，idea 并没有阻塞的警告，是真的不会阻塞吗？

No Comments Yet

subscribe 阻塞 rec doonnext