aleph

mccraigmccraig 2019-08-29T10:11:26.002300Z

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

thomascothran 2019-08-29T18:13:44.006900Z

@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.

mccraigmccraig 2019-08-29T18:15:45.007900Z

@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

mccraigmccraig 2019-08-29T18:16:45.008700Z

using manifold.stream/transform should be fine

thomascothran 2019-08-29T18:17:00.008900Z

Ah, got it. Thanks!