This page is not created by, affiliated with, or supported by Slack Technologies, Inc.
2019-08-29
Channels
- # aleph (5)
- # announcements (2)
- # bangalore-clj (2)
- # beginners (52)
- # cider (10)
- # cljsrn (1)
- # clojure (160)
- # clojure-dev (24)
- # clojure-europe (3)
- # clojure-france (1)
- # clojure-india (1)
- # clojure-italy (3)
- # clojure-nl (6)
- # clojure-spec (13)
- # clojure-uk (51)
- # clojurescript (45)
- # code-reviews (1)
- # core-async (41)
- # cursive (41)
- # datomic (17)
- # emacs (37)
- # fulcro (42)
- # graphql (7)
- # joker (4)
- # music (1)
- # nrepl (2)
- # off-topic (21)
- # pathom (19)
- # pedestal (12)
- # re-frame (48)
- # reitit (6)
- # rewrite-clj (8)
- # shadow-cljs (41)
- # specter (6)
- # sql (21)
- # tools-deps (8)
- # vim (7)
- # xtdb (27)
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!