Reactive programming newbie. I have a sequence of calls in my Flux and I need to ensure they're done in order. Eg
Flux<Thing> flux = ...
.doOnNext(this::sendThing)
.doOnNext(this::persistThing)
.doOnError(error -> log.error("", error))
.blockLast();
I need to ensure that sendThing
completes before persistThing
. I'm unclear, being a reactive newbie, if this is guaranteed.