org.clojars.roklenarcic.paginator.impl — org.clojars.roklenarcic/paginator 0.3.13

add-to-batch clj

(add-to-batch engine it)

Adds item to batch, adds batch to queue if max-items was reached.

finished? clj

(finished? engine)

force-enqueue clj

(force-enqueue engine)

Forces a batch to queue if queue is empty and the runner state allows for more tasks

has-capacity? clj

(has-capacity? engine)

init-engine clj

(init-engine engine get-pages-fn)

mark-invalid-state clj

(mark-invalid-state s)

If state is invalid, mark it with an exception

merge-ps clj

(merge-ps result paging-state)

Updates an existing pagestate map with results. It will specially handle :pages, :items, :page-cursor, the rest of it is merged into paging-state as is.

paging-state? clj

(paging-state? s)

Returns true if the map looks like a paging state with cursor.

run!! clj

(run!! {:keys [get-pages-fn items-in-runner items-in-process]} paging-states)

run-from-queue! clj

(run-from-queue! {:keys [runner-fn ch-result] :as engine})

Enqueues a batch with the runner if there is one in the queue and the runner has capacity. Returns new engine state.

runner-fn clj

(runner-fn f ch-result)

swap-xf! clj

(swap-xf! atom* f)

A transducer that runs f on atom* for each item seen.