Can't assign mbx in consumer

leonoel / missionary

A functional effect and streaming system for Clojure/Script

Eclipse Public License 2.0

630 stars 26 forks source link

Can't assign mbx in consumer #9

Closed lgrapenthin closed 5 years ago

lgrapenthin commented 5 years ago

(def task
  (let [mbx  (m/mbx)]
    ((m/sp
      (dotimes [n 4]
        (mbx n)
        (let [cur (m/? mbx)
              ]
          (println cur)
          (m/? (m/sleep 1000)))))
     (fn [success] (println 'success success))
     (fn [fail] (println 'fail fail)))))

Prints

nil nil nil nil success nil