This page is not created by, affiliated with, or supported by Slack Technologies, Inc.
2018-08-13
Channels
- # aleph (6)
- # architecture (29)
- # beginners (175)
- # cider (22)
- # clara (5)
- # cljdoc (5)
- # cljs-dev (28)
- # cljsrn (6)
- # clojure (62)
- # clojure-finland (7)
- # clojure-italy (7)
- # clojure-nl (2)
- # clojure-spec (23)
- # clojure-uk (194)
- # clojurescript (90)
- # core-async (2)
- # cursive (23)
- # datomic (41)
- # defnpodcast (2)
- # editors (4)
- # emacs (1)
- # figwheel-main (41)
- # fulcro (53)
- # hoplon (15)
- # hyperfiddle (4)
- # immutant (1)
- # jobs (7)
- # jobs-discuss (103)
- # lein-figwheel (9)
- # off-topic (34)
- # onyx (3)
- # parinfer (1)
- # portkey (1)
- # re-frame (7)
- # reagent (2)
- # remote-jobs (2)
- # rum (1)
- # shadow-cljs (148)
- # sql (54)
- # tools-deps (3)
- # vim (7)
Hi, smb use manifold (https://github.com/ztellman/manifold), i can't find how create something like core.async go-loop only for manifold stream? (and smb known if use manifold.deffered/loop & recur, thread are parked or it alway take message from source)
@fantomofdoom what exactly do you want to do ? lots of stream ops can be done with stream/map
and stream/reduce
. occasionally you need some finer control and then deferred/loop
and deferred/recur
may be useful e.g. https://github.com/ztellman/manifold/blob/master/src/manifold/stream.clj#L232
i haven't yet come across any stream solution i couldn't express with some combination of those ops
@mccraigmccraig Hi, i need smth like this >in core.async
(go-loop []
SOME WORK
(>! out-ch processed-msg)
(recur))
i need infinity loop that get msg from channel process and push forward@fantomofdoom that's a stream/map
... if you look at the impl you can see it uses the lower-level connect
primitives to do pretty much what you are doing in your go
loop - https://github.com/ztellman/manifold/blob/master/src/manifold/stream.clj#L614