diff --git a/spring-boot-starter-sample/pom.xml b/spring-boot-starter-sample/pom.xml
index fd4ecda..2e05c11 100644
--- a/spring-boot-starter-sample/pom.xml
+++ b/spring-boot-starter-sample/pom.xml
@@ -41,6 +41,10 @@
org.springframework.boot
spring-boot-starter-web
+
+ org.springframework.boot
+ spring-boot-starter-webflux
+
org.springframework.boot
spring-boot-starter-websocket
diff --git a/spring-boot-starter-sample/src/main/java/io/leangen/graphql/samples/service/IssueService.java b/spring-boot-starter-sample/src/main/java/io/leangen/graphql/samples/service/IssueService.java
index 9eb7ca4..3a80baa 100644
--- a/spring-boot-starter-sample/src/main/java/io/leangen/graphql/samples/service/IssueService.java
+++ b/spring-boot-starter-sample/src/main/java/io/leangen/graphql/samples/service/IssueService.java
@@ -13,6 +13,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;
import java.util.Map;
@@ -52,11 +53,21 @@ public Collection issues(String projectCode, Status... statuses) {
return repo.byProjectCodeAndStatus(projectCode, statuses);
}
+ @GraphQLQuery
+ public Flux issuesWebflux(String projectCode, Status... statuses) {
+ return Flux.fromIterable( repo.byProjectCodeAndStatus(projectCode, statuses));
+ }
+
@GraphQLQuery
public Issue issue(String code) {
return repo.byCode(code);
}
+ @GraphQLQuery
+ public Mono issueWebFlux(String code) {
+ return Mono.just(repo.byCode(code));
+ }
+
@GraphQLSubscription
public Publisher issueStatusChanged(String code) {
return Flux.create(fluxSink -> sinks.put(code, fluxSink));