diff --git a/babashka.pods b/babashka.pods index 98d4f814..3e5637b3 160000 --- a/babashka.pods +++ b/babashka.pods @@ -1 +1 @@ -Subproject commit 98d4f814323c50c3ea5427896c0eba6c40224bdc +Subproject commit 3e5637b33fa22aa4a50c22d078e2031b34e8bd5a diff --git a/src/babashka/impl/pods.clj b/src/babashka/impl/pods.clj index 386ca2d4..28911127 100644 --- a/src/babashka/impl/pods.clj +++ b/src/babashka/impl/pods.clj @@ -6,4 +6,5 @@ (def pods-namespace {'load-pod (with-meta pods/load-pod {:sci.impl/op :needs-ctx}) - 'invoke pods/invoke}) + 'invoke pods/invoke + 'unload-pod pods/unload-pod}) diff --git a/test-resources/pod.clj b/test-resources/pod.clj index c92e0b79..d6294a94 100644 --- a/test-resources/pod.clj +++ b/test-resources/pod.clj @@ -56,7 +56,7 @@ "code" " (defn range-stream [val-cb done-cb & args] (babashka.pods/invoke \"pod.test-pod\" 'pod.test-pod/range-stream* args - {:handlers {:success #(val-cb (:value %)) :done (fn [m] (done-cb m))}}) + {:handlers {:success val-cb :done done-cb}}) nil)"} {"name" "assoc"} {"name" "error"} @@ -135,7 +135,7 @@ (debug "Running async range test") (let [prom (promise)] ((resolve 'pod.test-pod/range-stream) - prn (fn [_] (deliver prom :ok)) 1 10) + prn (fn [] (deliver prom :ok)) 1 10) @prom) (debug "Running exception test") (prn (try ((resolve 'pod.test-pod/error) 1 2 3)