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

clean-stack-trace clj

(clean-stack-trace ee)

Return executionexception stacktrace with stack cleaned at the top

deferred? clj

(deferred? x)

empty-state clj

extra-props clj

(extra-props p)

finalize-result clj

(finalize-result result
                 {:org.clojars.roklenarcic.paginator.impl/keys
                    [batcher futs counters results pages?]})

Act on operation result, sending items to their respective queues.

instr-batch clj

(instr-batch items emit-pages?)

Add :add-page function to all items.

merge-to-ps clj

(merge-to-ps ps x)

page-loop clj

(page-loop {:org.clojars.roklenarcic.paginator.impl/keys [run-fn batcher futs
                                                          input results pages?]
            :as options}
           out-cnt)

Dual queue synchronous page-loop. Input is a volatile containing items and is lazily read when queue is empty.

Tries to finish one of the tasks that moves the engine along. If task returns a map, even an empty one, it is considered to have done something and the next tasks are not tried. The list of finished items is pushed into a priority queue based on :idx of PagingState. This enables that we can emit results in order of inputs if desired.

PagingStates are tagged with increasing idx.

page-loop-solo clj

(page-loop-solo input run-fn pages?)

paging-state-props clj

poll-futures clj

(poll-futures futs)

Iterates the futures Queue, finds any finished futures, processes the return, returning processed items map or nil if no future has been resolved.

process-ret clj

(process-ret ret)

Process a return, returning a processed items map.

read-input clj

(read-input input)

Tries to gather an item from input returns processed items map, if able.

realized clj

(realized res block?)

Returns realized result or nil

spare-concurrency? clj

(spare-concurrency? run-fn options)

Returns true if there seems to be concurrency to spare. Always true if user didn't specify concurrency limit and it wasn't measured.

unwrap clj

(unwrap p)

validate-extra-props clj

(validate-extra-props p)

vol++ clj

(vol++ v)