search

clj-commons / manifold

A compatibility layer for event-driven abstractions
1.02k stars 106 forks source link

`s/transform` has bug with xform `cat` #115

Closed gfZeng closed 7 years ago

gfZeng commented 7 years ago 
(def s (s/stream))
(future
   (->> s
           (s/transform (comp cat (map prn))) 
           s/stream->seq dorun))
(s/put! s (range 10)) ;; first time will be success
(s/put! s (range 10)) ;; second time will lead dead lock, `s/stream->seq parked`
dm3 commented 7 years ago

What version are you running? I can't reproduce with the latest 0.1.6-alpha4.

gfZeng commented 7 years ago

@dm3 I use the version of 0.1.4 via [aleph "0.4.1"]