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

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 params)

run!! clj

(run!! {:keys [params get-items-fn items-in-runner items-in-process parser]
        :as engine}
       paging-states)

run-from-queue! clj

(run-from-queue! {:keys [async-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.

swap-xf! clj

(swap-xf! atom* f)

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

update-existing-ps clj

(update-existing-ps {:keys [parser]} result page-states)

Updates an existing pagestate map with results.