feat: tapestry.core/send

Introduce a function for working with agents using a virtual executor

Author: rschmukler

src/tapestry/core.clj

@@ -5,7 +5,8 @@
            [java.lang VirtualThread]
            [java.time Duration])
   (:require [manifold.stream :as s]
-            [manifold.deferred :as d]))
+            [manifold.deferred :as d])
+  (:refer-clojure :exclude [send]))
 
 (def ^{:dynamic true
        :no-doc  true} *local-semaphore*
@@ -330,3 +331,10 @@
        true (s/buffer n)
        true (s/realize-each)
        seq? (s/stream->seq)))))
+
+(defn send
+  "A version of `send` that uses a loom fiber for the execution of the function `f`.
+
+  See `clojure.core/send` for details"
+  [a f & args]
+  (apply send-via -static-executor a f args))

test/tapestry/core_test.clj

@@ -188,3 +188,20 @@
     (let [success? (atom false)]
       @(d/chain' (sut/fiber true) (partial reset! success?))
       (is @success?))))
+
+(deftest send-test
+  (let [a (agent 0)]
+    (testing "without arguments"
+      (sut/send a inc)
+      (await a)
+      (is (= 1 @a)))
+    (testing "with argument"
+      (sut/send a (constantly 0))
+      (sut/send a + 2 3)
+      (await a)
+      (is (= 5 @a)))
+    (testing "with multiple arguments"
+      (sut/send a (constantly 0))
+      (sut/send a + 1 2 3 4)
+      (await a)
+      (is (= 10 @a)))))