Reactive support

spring-boot-sample/src/main/java/io/leangen/spqr/samples/demo/configuration/DemoApplication.java

@@ -2,7 +2,7 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.web.support.SpringBootServletInitializer;
+import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.ComponentScan;
 import org.springframework.web.servlet.config.annotation.ViewControllerRegistry;

spring-boot-starter-sample/pom.xml

@@ -41,6 +41,10 @@
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-web</artifactId>
 		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-webflux</artifactId>
+		</dependency>
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-websocket</artifactId>

spring-boot-starter-sample/src/main/java/io/leangen/graphql/samples/service/TaskService.java

@@ -15,6 +15,7 @@
 import org.springframework.stereotype.Service;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.FluxSink;
+import reactor.core.publisher.Mono;
 
 import java.util.Collection;
 
@@ -51,11 +52,21 @@ public Collection<Task> tasks(String projectCode, Status... statuses) {
         return repo.byProjectCodeAndStatus(projectCode, statuses);
     }
 
+    @GraphQLQuery
+    public Flux<Task> tasksWebflux(String projectCode, Status... statuses) {
+        return Flux.fromIterable(repo.byProjectCodeAndStatus(projectCode, statuses));
+    }
+
     @GraphQLQuery
     public Task task(String code) {
         return repo.byCode(code);
     }
 
+    @GraphQLQuery
+    public Mono<Task> taskWebflux(String code) {
+        return Mono.just(repo.byCode(code));
+    }
+
     @GraphQLSubscription
     public Publisher<Task> taskStatusChanged(String code) {
         return Flux.create(subscriber -> subscribers.add(code, subscriber.onDispose(() -> subscribers.remove(code, subscriber))), FluxSink.OverflowStrategy.LATEST);