reactor/reactor-core v2.5.0.M3

on GitHub

• Introducing Scheduler/Worker contract from Reactive Streams Commons

Breaking from M2 :

• SchedulerGroup is now Computations and io -> concurrent, async -> parallel
• publishOn() is now subscribeOn()
• dispatchOn() is now publishOn()
• connect() and similar interruptible API now return Cancellation instead of Runnable
• Timer API changes
• startEmitter() is now connectEmitter()

Additions :

• scheduling support for plain ExecutorService
• Flux#concatMapIterable/flatMapIterable
• User experience improvements on Mono
• Mono#when now properly completes when all input are complete.
• + Mono#fromSupplier and Mono#whenDelayError
• + Flux#collect(java.util.stream.Collector)
• Minor fixes
• Performance tweaks (yes we still can !) especially for Mono !