Skip to content

Commit

Permalink
use pre-1.12 compatible interop syntax
Browse files Browse the repository at this point in the history
  • Loading branch information
puredanger committed Jan 17, 2025
1 parent 17b0538 commit 6d9fc5a
Showing 1 changed file with 6 additions and 7 deletions.
13 changes: 6 additions & 7 deletions src/main/clojure/clojure/core/async/flow/impl.clj
Original file line number Diff line number Diff line change
Expand Up @@ -34,13 +34,12 @@

(defn futurize ^Future [f {:keys [exec]}]
(fn [& args]
(^[Callable] ExecutorService/.submit
(case exec
:compute compute-exec
:io io-exec
:mixed mixed-exec
exec)
#(apply f args))))
(let [^ExecutorService exec (case exec
:compute compute-exec
:io io-exec
:mixed mixed-exec
exec)]
(.submit exec ^Callable #(apply f args)))))

(defn prep-proc [ret pid {:keys [proc, args, chan-opts] :or {chan-opts {}}}]
(let [{:keys [ins outs]} (spi/describe proc)
Expand Down

0 comments on commit 6d9fc5a

Please sign in to comment.