Skip to content

Instantly share code, notes, and snippets.

What would you like to do?
Testing the filter macro
(deftest defspout []
(is ((streamit/filter test-spout [] [[] -> [:double]]
(init [max 1000])
(work {:push 1}
(let [rand-double (* max (rand))]
(Thread/sleep 10)
(streamit/push [rand-double]))))))
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.