This page is not created by, affiliated with, or supported by Slack Technologies, Inc.
2022-07-01
Channels
- # announcements (23)
- # babashka (66)
- # babashka-sci-dev (7)
- # beginners (24)
- # biff (2)
- # calva (19)
- # cider (10)
- # clj-kondo (12)
- # cljs-dev (3)
- # cljsrn (2)
- # clojure (37)
- # clojure-art (1)
- # clojure-europe (50)
- # clojure-gamedev (1)
- # clojure-nl (1)
- # clojure-norway (22)
- # clojure-uk (7)
- # clojurescript (6)
- # conjure (28)
- # cursive (19)
- # data-science (11)
- # fulcro (21)
- # holy-lambda (12)
- # honeysql (6)
- # hyperfiddle (2)
- # jobs (1)
- # lsp (5)
- # malli (4)
- # meander (3)
- # missionary (8)
- # nbb (5)
- # off-topic (39)
- # rdf (9)
- # reitit (1)
- # releases (1)
- # sci (21)
- # shadow-cljs (42)
- # specter (1)
- # xtdb (11)
Is there an interactive playground where people can play around with missionary?
Seeking contractor – this work involves using missionary
Once I created a flow with something like observe
how could I get a flow that contains the values from this flow but also additional ones that are triggered ad-hoc?
for context: I’m working with a messaging API where you can subscribe and send but messages sent by yourself will not be broadcast to subscribers. So now I’m trying to create a flow that has the events coming from subscribe as well as an event whenever you send a message.
(defn both "Merge two flows" [>x >y]
(m/ap (m/?> (m/amb= >x >y))))
(def send! (m/mbx))
(def cancel
((->> (m/observe (fn [!] (def sub !) #()))
(both (m/ap (m/? (m/?> (m/seed (repeat send!))))))
(m/reduce #(prn %2) nil))
prn prn))
(sub 1)
(send! :a)
(sub 2)
(send! :b)
👀 1
🙏 1
why is state (mbx) needed? or is that just repl machinery for the example