代码如下:
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 并没有阻塞的警告,是真的不会阻塞吗?