Extract reactor specific code to an inner class to protect against ClassNotFound exceptions if reactor is not in use. Also add support for `Flux`. See gh-18339
Extract reactor specific code to an inner class to protect against ClassNotFound exceptions if reactor is not in use. Also add support for `Flux`. See gh-18339