~subsetpark/bagatto

f2e3380f4637cb48526d40fea65f0887a7c2ad49 — Zach Smith 2 months ago ea5658a v0.6.4
Remove threads test
1 files changed, 0 insertions(+), 16 deletions(-)

M test/threads.janet
M test/threads.janet => test/threads.janet +0 -16
@@ 12,20 12,4 @@
    (is (== @{0 true 2 true 1 true 3 true 5 true
              6 true 4 true 8 true 7 true 9 true} out))))

(defn worker-initial-state [] ())

(def- work-chan (ev/thread-chan 10))

(defn do-work
  [n _state]
  (ev/give work-chan n))


(deftest pipeline
  (threads/side-effects-pipeline (range 0 10)
                                 worker-initial-state
                                 do-work)
  (ev/sleep 1)
  (is (= (ev/count work-chan) 10)))

(run-tests!)