ripley.live.async — io.github.tatut/ripley 2023-09-16.262

core.async source and pub sub

ch->source clj

(ch->source ch)

(ch->source ch immediate?)

Create source from channel for single listener.

publish clj

(publish event-or-topic)

subscribe-source clj

(subscribe-source topics event-value-fn)

Source that subscribes to the given topic and runs function to produce results. Optionally immediately processes an event.