Correctly forward var bindings on structured scope submit methods

funcool · Oct 21, 2023 · 52a37f9 · 52a37f9
1 parent c3e5483
commit 52a37f9
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/src/promesa/exec.cljc b/src/promesa/exec.cljc
@@ -853,12 +853,15 @@
 
        pt/IExecutor
        (-exec! [it task]
-         (.fork ^java.util.concurrent.StructuredTaskScope it ^Callable task)
-         nil)
+         (let [task (wrap-bindings task)]
+           (.fork ^java.util.concurrent.StructuredTaskScope it ^Callable task)
+           nil))
        (-run! [it task]
-         (.fork ^java.util.concurrent.StructuredTaskScope it ^Callable task))
+         (let [task (wrap-bindings task)]
+           (.fork ^java.util.concurrent.StructuredTaskScope it ^Callable task)))
        (-submit! [it task]
-         (.fork ^java.util.concurrent.StructuredTaskScope it ^Callable task)))))
+         (let [task (wrap-bindings task)]
+           (.fork ^java.util.concurrent.StructuredTaskScope it ^Callable task))))))
 
 ;; #?(:clj
 ;;    (defn managed-blocker