Replace VirtualThreadsRecorder method ref by supplier

quarkusio · Sep 22, 2023 · 166c9cb · 166c9cb
1 parent af4208a
commit 166c9cb
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/...e/src/main/java/io/quarkus/resteasy/reactive/server/runtime/ResteasyReactiveRecorder.java b/...e/src/main/java/io/quarkus/resteasy/reactive/server/runtime/ResteasyReactiveRecorder.java
@@ -77,6 +77,13 @@ public Executor get() {
         }
     };
 
+    public static final Supplier<Executor> VTHREAD_EXECUTOR_SUPPLIER = new Supplier<Executor>() {
+        @Override
+        public Executor get() {
+            return VirtualThreadsRecorder.getCurrent();
+        }
+    };
+
     static volatile Deployment currentDeployment;
 
     public static Deployment getCurrentDeployment() {
@@ -129,7 +136,7 @@ public ResteasyReactiveRequestContext createContext(Deployment deployment,
         }
 
         RuntimeDeploymentManager runtimeDeploymentManager = new RuntimeDeploymentManager(info, EXECUTOR_SUPPLIER,
-                VirtualThreadsRecorder::getCurrent,
+                VTHREAD_EXECUTOR_SUPPLIER,
                 closeTaskHandler, contextFactory, new ArcThreadSetupAction(beanContainer.requestContext()),
                 vertxConfig.rootPath);
         Deployment deployment = runtimeDeploymentManager.deploy();