Merge pull request #25191 from geoand/#25189

Ensure that RESTEasy Reactive Links works with async return types
quarkusio · Apr 28, 2022 · ed30ee1 · ed30ee1
2 parents 42b6730 + 3b6136b
commit ed30ee1
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/.../deployment/src/test/java/io/quarkus/resteasy/reactive/links/deployment/TestResource.java b/.../deployment/src/test/java/io/quarkus/resteasy/reactive/links/deployment/TestResource.java
@@ -1,5 +1,6 @@
 package io.quarkus.resteasy.reactive.links.deployment;
 
+import java.time.Duration;
 import java.util.Arrays;
 import java.util.LinkedList;
 import java.util.List;
@@ -15,6 +16,7 @@
 import io.quarkus.resteasy.reactive.links.InjectRestLinks;
 import io.quarkus.resteasy.reactive.links.RestLink;
 import io.quarkus.resteasy.reactive.links.RestLinkType;
+import io.smallrye.mutiny.Uni;
 
 @Path("/records")
 public class TestResource {
@@ -29,8 +31,8 @@ public class TestResource {
     @Produces(MediaType.APPLICATION_JSON)
     @RestLink(entityType = TestRecord.class, rel = "list")
     @InjectRestLinks
-    public List<TestRecord> getAll() {
-        return RECORDS;
+    public Uni<List<TestRecord>> getAll() {
+        return Uni.createFrom().item(RECORDS).onItem().delayIt().by(Duration.ofMillis(100));
     }
 
     @GET

diff --git a/...tive-links/runtime/src/main/java/io/quarkus/resteasy/reactive/links/RestLinksHandler.java b/...tive-links/runtime/src/main/java/io/quarkus/resteasy/reactive/links/RestLinksHandler.java
@@ -24,6 +24,7 @@ public void setRestLinkData(RestLinkData restLinkData) {
 
     @Override
     public void handle(ResteasyReactiveRequestContext context) {
+        context.requireCDIRequestScope();
         Response response = context.getResponse().get();
         for (Link link : getLinks(response)) {
             response.getHeaders().add("Link", link);