Rationalize the Reactor autoconfig

It didn't make sense not to do anything at all if a Reactor @Bean
was detected, so now we only back off creating the rootReactor if
one is present.

spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/reactor/ReactorAutoConfiguration.java

@@ -35,11 +35,11 @@ import reactor.spring.context.config.EnableReactor;
  */
 @Configuration
 @ConditionalOnClass(EnableReactor.class)
-@ConditionalOnMissingBean(Reactor.class)
 @AutoConfigureAfter(WebMvcAutoConfiguration.class)
 public class ReactorAutoConfiguration {
 
 	@Bean
+	@ConditionalOnMissingBean(Reactor.class)
 	public Reactor rootReactor(Environment environment) {
 		return environment.getRootReactor();
 	}

spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/reactor/ReactorAutoConfigurationTests.java

@@ -16,12 +16,16 @@
 
 package org.springframework.boot.autoconfigure.reactor;
 
+import static org.junit.Assert.assertNotNull;
+
 import org.junit.Test;
 import org.springframework.context.annotation.AnnotationConfigApplicationContext;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
 
+import reactor.core.Environment;
 import reactor.core.Reactor;
-
+import reactor.core.spec.Reactors;
-import static org.junit.Assert.assertNotNull;
 
 /**
  * @author Dave Syer
@@ -38,4 +42,21 @@ public class ReactorAutoConfigurationTests {
 		this.context.close();
 	}
 
+	@Test
+	public void customReactor() {
+		this.context.register(TestConfiguration.class, ReactorAutoConfiguration.class);
+		this.context.refresh();
+		assertNotNull(this.context.getBean(Reactor.class));
+		this.context.close();
+	}
+
+	@Configuration
+	protected static class TestConfiguration {
+
+		@Bean
+		public Reactor reactor(Environment env) {
+			return Reactors.reactor().env(env).dispatcher(Environment.RING_BUFFER).get();
+		}
+	}
+
 }

spring-boot-cli/src/main/java/org/springframework/boot/cli/compiler/autoconfigure/ReactorCompilerAutoConfiguration.java

@@ -31,7 +31,8 @@ public class ReactorCompilerAutoConfiguration extends CompilerAutoConfiguration
 
 	@Override
 	public boolean matches(ClassNode classNode) {
-		return AstUtils.hasAtLeastOneAnnotation(classNode, "EnableReactor") || AstUtils.hasAtLeastOneFieldOrMethod(classNode, "Reactor");
+		return AstUtils.hasAtLeastOneAnnotation(classNode, "EnableReactor")
+				|| AstUtils.hasAtLeastOneFieldOrMethod(classNode, "Reactor");
 	}
 
 	@Override
@@ -43,15 +44,16 @@ public class ReactorCompilerAutoConfiguration extends CompilerAutoConfiguration
 
 	@Override
 	public void applyImports(ImportCustomizer imports) {
-		imports.addImports("reactor.core.Reactor", "reactor.event.Event",
+		imports.addImports("reactor.core.Reactor", "reactor.core.spec.Reactors",
-				"reactor.function.Consumer", "reactor.function.Functions",
+				"reactor.core.Observable", "reactor.event.Event",
-				"reactor.event.selector.Selectors",
+				"reactor.function.Functions", "reactor.function.Predicates", 
+				"reactor.function.Suppliers",
 				"reactor.spring.context.annotation.Consumer",
 				"reactor.spring.context.annotation.Selector",
 				"reactor.spring.context.annotation.SelectorType",
 				"reactor.spring.context.annotation.ReplyTo",
 				"reactor.spring.context.config.EnableReactor")
-				.addStarImports("reactor.event.Selectors")
+				.addStarImports("reactor.event.selector.Selectors")
 				.addImport("ReactorEnvironment", "reactor.core.Environment");
 	}