spring-webflux - 在 Reactor 中，doOnNext 插入数据是否使用 subscribe() 不阻塞？

Question

我想在查询后插入一些数据，如下所示：

private AtomicInteger count = new AtomicInteger(0);                             
....                                                                            
public Flux<Student> doSomething() {
    return this.rtpl.findAll(Student.class).doOnNext(student -> {
        Record rec = new Record();
        rec.setRecord(String.format("student operate %s times", count.addAndGet(1)));
        this.rtpl.insert(rec).subscribe();
    });
}

在 map 或 flatMap 操作中，idea 会提醒我它在非阻塞范围内。使用doOnNext时，idea不会提醒。

为什么？我不明白。

标签： spring-webfluxreactor