I like to drain a stream into a vector without blocking. core.async has into
which returns a channel. I look for a stream into
which returns a deferred. stream->seq
will block if I need the whole seq.
@akiel (stream/reduce conj [] <stream>)
should do it
oh there is a reduce
- thanks!
there is transducer support too @akiel with stream/transform
... make sure you use a recent version though - there was a bug which bit me before 0.1.7-alpha6
I use still 0.1.6
what was the problem?
it doesn't affect reduce
... just transform
with transducers with state
ok thanks