New exciting stuff, polishing, name changes, fixes, efficiency, clarifications: that's the result of an extended feedback and an active stream of improvements from Reactive Streams Commons.
TBC:
Breaking from M3 :
ComputationsandTimerfactories are now used throughSchedulersComputations#concurrent->Schedulers#elasticComputations#parallel->Schedulers#parallelorSchedulers#computationif pure non blocking tasks
- Mono.any -> first
- Mono.get -> block
- Mono.toCompletableFuture -> toFuture,
- Mono.fromCompletableFuture -> fromFuture
- Flux.amb -> firstEmitting
- Flux.toXx -> collectXxx
- Flux.exists -> any
- Flux.stream() -> toStream()
- Flux.partition -> parallel
- Mono and Flux after -> then
- Mono and Flux consume -> subscribe
Removed :
- ExecutorUtils
- UUIDUtils moved to reactor-io/reactor-ipc
- yield