search

clojure-quant / quanta-market

0 stars 0 forks source link

import java.util.concurrent.locks.ReentrantLock #1

Closed awb99 closed 3 months ago

awb99 commented 3 months ago

(defn poll-task "derive discrete flow from succession of polled values from a task (or mbox)" [task]

_(m/ap (m/? (m/?> (m/seed (repeat mbox)))))

(m/ap (loop [v (m/? task)] (m/amb v (recur (m/? task))))))