Search code examples
spring-data-r2dbcr2dbc

How do understand r2dbc save

i want konw r2dbc principle, so i debug the code, but i find it work weird.

        Flux.range(1, 10)
                .flatMap(id -> repository.save(new Student(id, "lxp")))
                .doOnNext(System.out::println)
                .subscribe();

why it run all save before run doOnNext? In my understanding, it run save then doOnNext one by one.

it hard.hope someone can help me.thanks.

Solution

  • Answer is partially here

    https://stackoverflow.com/a/57208219/182393

    In addition, flatMap is emitting events (saves) in an asynchronous way. So, you have range of events, that are handled in flatMap asynchronously (all at the same time) and then they go to doOnNext, and finally to subscribe.

    Your code is not sequential (and this is why reactive programming causes madness).