run-process.janet

(def chan (ev/thread-chan))

(defn run-process
  [args]
  (ev/spawn-thread
    (def p (os/spawn args :p {:in :pipe :out :pipe}))
    (ev/give chan (:read (p :out) :all))
    (:wait p)))

(run-process ["ls"])

(print "...blocking")
(pp (ev/take chan))

(run-process ["ls"])

(ev/spawn-thread
  (print "not blocking, different thread")
  (pp (ev/take chan)))

(run-process ["ls"])

(defn then
  ``
Will run each event loop cycle until chan has something to take.
Note, if another thread takes from chan, this might start blocking.
``
  [chan f]
  (ev/spawn
    (if (pos? (ev/count chan))
      (do (print "taking")
        (f (ev/take chan)))
      (then chan f))))

(then chan
      (fn [v]
        (print "not blocking, same thread")
        (pp v)))