me.lomin.chatda.search — me.lomin/chatda 0.1.0

async-worker clj

(async-worker xform problem-bus empty-heap parallel? problem)

AsyncSearchable clj protocol

xform-async clj

(xform-async self)

chan-xform clj

(chan-xform init)

Combinable clj protocol

combine clj

(combine this other)

combine-async clj

(combine-async this other)

combine->offer->recur clj macro

(combine->offer->recur problem heap chan parallel?)

depth-first-comparator clj

ExhaustiveSearch clj protocol

stop clj

(stop this)

next-channel-value clj

(next-channel-value worker-pool control-chans parallelism time-left?)

parallel-depth-first-search clj

(parallel-depth-first-search
  {:keys [compare] :or {compare depth-first-comparator} :as init}
  {:keys [chan-size parallelism timeout] :or {chan-size 10 parallelism 4}})

(parallel-depth-first-search init chan-size parallelism)

Prioritizable clj protocol

priority clj

(priority self)

priority-comparator clj

(priority-comparator compare)

priority-queue clj

(priority-queue n compare)

(priority-queue n compare init)

priority-xf clj

rec:parallel-depth-first-search clj

(rec:parallel-depth-first-search root-problem
                                 [problem-bus :as control-chans]
                                 parallelism
                                 time-left?
                                 solve-async)

remove-worker-from clj

(remove-worker-from worker-pool worker)

Searchable clj protocol

children clj

(children self)

xform clj

(xform self)

time-left-fn clj

(time-left-fn timeout-future)

timeout-exception clj

timeout-xf clj

(timeout-xf $future)

transduce-1 clj

(transduce-1 xform x)

apply a transducer on a single value