kkiss.core — net.clojars.luchiniatwork/kkiss 0.3.0

consumer clj

(consumer streams handle-fn)

(consumer streams
          handle-fn
          {:keys [continuation failed-event-stream failed-exception-stream]
           :or {continuation :stop-on-failure}
           :as opts})

engine clj

(engine {:keys [config] :as opts})

send! clj

(send! stream k v)

start! clj

(start! consumer)

stop! clj

(stop! consumer)

stream clj

(stream opts)