Use latest SR/CP

Fixes #40852 (cherry picked from commit 0dc312b)
quarkusio · Jun 11, 2024 · b37b2c6 · b37b2c6
1 parent 84e2402
commit b37b2c6
Show file tree

Hide file tree

Showing 3 changed files with 25 additions and 1 deletion.
diff --git a/bom/application/pom.xml b/bom/application/pom.xml
@@ -58,7 +58,7 @@
         <smallrye-graphql.version>2.8.4</smallrye-graphql.version>
         <smallrye-fault-tolerance.version>6.3.0</smallrye-fault-tolerance.version>
         <smallrye-jwt.version>4.5.2</smallrye-jwt.version>
-        <smallrye-context-propagation.version>2.1.0</smallrye-context-propagation.version>
+        <smallrye-context-propagation.version>2.1.2</smallrye-context-propagation.version>
         <smallrye-reactive-streams-operators.version>1.0.13</smallrye-reactive-streams-operators.version>
         <smallrye-reactive-types-converter.version>3.0.1</smallrye-reactive-types-converter.version>
         <smallrye-mutiny-vertx-binding.version>3.12.0</smallrye-mutiny-vertx-binding.version>

diff --git a/...ntext-propagation/src/test/java/io/quarkus/context/test/mutiny/MutinyContextEndpoint.java b/...ntext-propagation/src/test/java/io/quarkus/context/test/mutiny/MutinyContextEndpoint.java
@@ -1,6 +1,7 @@
 package io.quarkus.context.test.mutiny;
 
 import java.net.MalformedURLException;
+import java.time.Duration;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
@@ -461,4 +462,21 @@ public Flow.Publisher<String> transactionPropagationWithMulti2() {
         Assertions.assertEquals(2, Person.deleteAll());
         return ret;
     }
+
+    @GET
+    @Path("/bug40852")
+    public String bug40852() {
+        var futureW = Uni
+                .createFrom()
+                .item("item")
+                .onItem()
+                .delayIt()
+                .by(Duration.ofMillis(100))
+                .subscribeAsCompletionStage();
+
+        futureW.whenComplete((result, error) -> {
+            Assertions.assertEquals(true, futureW.isDone());
+        }).join();
+        return "OK";
+    }
 }
diff --git a/...ropagation/src/test/java/io/quarkus/context/test/mutiny/MutinyContextPropagationTest.java b/...ropagation/src/test/java/io/quarkus/context/test/mutiny/MutinyContextPropagationTest.java
@@ -156,6 +156,12 @@ public void testTransactionContextPropagationMulti() {
                 .statusCode(Response.Status.OK.getStatusCode()));
     }
 
+    @Test
+    public void testContextPropagationBug40852() {
+        RestAssured.when().get("/mutiny-context/bug40852").then()
+                .statusCode(Response.Status.OK.getStatusCode());
+    }
+
     private void awaitState(ThrowingRunnable task) {
         Awaitility.await().atMost(5, TimeUnit.SECONDS)
                 .pollInterval(100, TimeUnit.MILLISECONDS)