d-core.core.stream.in-mem.logic — org.clojars.cinguilherme/d-core-async-messaging 0.2.1

append-entries-state clj

(append-entries-state state stream payloads now)

next-id clj

(next-id last-id now)

notify-waiters! clj

(notify-waiters! state-atom stream)

parse-id clj

(parse-id id)

query-entries clj

(query-entries entries {:keys [direction cursor limit]})

read-payloads-with-blocking clj

(read-payloads-with-blocking state-atom stream {:keys [timeout] :as opts})