ketu.async.source

Liking cljdoc? Tell your friends :D

Clojure only.

(default-consumer-supplier opts)

(default-opts)

(done-chan state)

(finalize-apache-config opts)

Returns opts with final :ketu.apache.consumer/config entry

Returns opts with final :ketu.apache.consumer/config entry

(source ch opts)

Starts consuming into a channel. Returns a state map including out-chan. Pass it to the stop! function when done.

Starts consuming into a channel.
Returns a state map including out-chan. Pass it to the `stop!` function when done.

(stop! state)

cljdoc is a website building & hosting documentation for Clojure/Script libraries