Updated to have a Mono property

bbakerman · bbakerman · commit ed39788f730c · 2024-04-21T19:58:45.000+10:00
diff --git a/src/test/java/reproductions/SubscriptionReproduction.java b/src/test/java/reproductions/SubscriptionReproduction.java
@@ -11,6 +11,8 @@
 import org.reactivestreams.Subscriber;
 import org.reactivestreams.Subscription;
 import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+import reactor.core.scheduler.Schedulers;
 
 import javax.annotation.Nonnull;
 import java.util.Map;
@@ -39,6 +41,7 @@ private void run() {
                 "  searchVideo {\n" +
                 "    id\n" +
                 "    name\n" +
+                "    lastEpisode\n" +
                 "    isFavorite\n" +
                 "  }\n" +
                 "}";
@@ -57,6 +60,7 @@ private GraphQL mkGraphQl() {
                 "type VideoSearch {" +
                 "       id : ID" +
                 "       name : String" +
+                "       lastEpisode : String" +
                 "       isFavorite : Boolean" +
                 "}";
         RuntimeWiring runtimeWiring = newRuntimeWiring()
@@ -66,6 +70,7 @@ private GraphQL mkGraphQl() {
                 .type(newTypeWiring("VideoSearch")
                         .dataFetcher("name", this::nameDF)
                         .dataFetcher("isFavorite", this::isFavoriteDF)
+                        .dataFetcher("lastEpisode", this::lastEpisode)
                 )
                 .build();
 
@@ -95,6 +100,16 @@ private Object isFavoriteDF(DataFetchingEnvironment env) {
         });
     }
 
+    private Object lastEpisode(DataFetchingEnvironment env) {
+        // Mono-based async property that uses CF as the interface
+        return Mono.fromCallable(() -> {
+                    Integer counter = getCounter(env.getSource());
+                    return "episode-" + Thread.currentThread().getName() + "for" + counter;
+                })
+                .publishOn(Schedulers.boundedElastic())
+                .toFuture();
+    }
+
     private Object nameDF(DataFetchingEnvironment env) {
         // async deliver of the isFavorite property with random delay
         return CompletableFuture.supplyAsync(() -> {
