throttling with manifold

throttle-example.clj

(ns throttle-example
  (:require [manifold.stream :as s]))

;; should limit to 1 per sec ?
(def a (s/throttle 1 (s/stream)))

(dotimes [n 100]
  (s/put! a n))

(defn now []
  (new java.util.Date))

(dotimes [n 10]
  (println (str (now) " ~ " @(s/take! a))))


;; Wed Jun 17 22:34:52 PDT 2015 ~ 0
;; Wed Jun 17 22:34:52 PDT 2015 ~ 1
;; Wed Jun 17 22:34:52 PDT 2015 ~ 2
;; Wed Jun 17 22:34:52 PDT 2015 ~ 3
;; Wed Jun 17 22:34:52 PDT 2015 ~ 4
;; Wed Jun 17 22:34:52 PDT 2015 ~ 5
;; Wed Jun 17 22:34:52 PDT 2015 ~ 6
;; Wed Jun 17 22:34:52 PDT 2015 ~ 7
;; Wed Jun 17 22:34:52 PDT 2015 ~ 8
;; Wed Jun 17 22:34:52 PDT 2015 ~ 9

;; just prints out real fast like.

You need to put! into the stream you've throttled, not the stream which was returned by throttle. In most of the operators I make it impossible to put! into a derivative stream like this, it was an oversight on my part not to do the same here. Sorry for the confusion.