Added webflux methods.

leangen · Jan 4, 2019 · 4d88fe6 · 4d88fe6
1 parent 0ae4083
commit 4d88fe6
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 0 deletions.
diff --git a/spring-boot-starter-sample/pom.xml b/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>

diff --git a/...ng-boot-starter-sample/src/main/java/io/leangen/graphql/samples/service/IssueService.java b/...ng-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<Issue> issues(String projectCode, Status... statuses) {
         return repo.byProjectCodeAndStatus(projectCode, statuses);
     }
 
+    @GraphQLQuery
+    public Flux<Issue> 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<Issue> issueWebFlux(String code) {
+        return Mono.just(repo.byCode(code));
+    }
+
     @GraphQLSubscription
     public Publisher<Issue> issueStatusChanged(String code) {
         return Flux.create(fluxSink -> sinks.put(code, fluxSink));