i don't know about assembling the JSON fragments @thomas559 , but be aware the manifold.stream/stream->seq
may cause blocking - if your app is non-blocking then you will probably want to use a combination of manifold.stream/map
and manifold.stream/reduce
instead
@mccraigmccraig - does it become blocking any time the stream is converted to a lazy seq, or is that specific to the stream->seq
function? I was exploring either using lazy-seq
to assemble the pieces, or else manifold.stream/transform
.
@thomas559 it's because stream->seq
does a deref
internally, and deref
is blocking - https://github.com/ztellman/manifold/blob/master/src/manifold/stream.clj#L552
using manifold.stream/transform
should be fine
Ah, got it. Thanks!