creates a executor that takes in an atom queue

creates an atom with a vec as queue

processes

(def +state+ (atom []))

(aq:process (fn elems(swap! +state+ conj elems)) (atom 1 2 3 4 5) 3)

@+state+ => [1 2 3 4 5]

submission function for one or multiple entries to aq

creates a hub state

adds entries to the hub

(hub:add-entries (hub:new) 1 2 3 4 5) => (contains f/future? 0 5)

creates a hub based executor

(def -exe- (hub:executor nil {:handler (fn & args args) :interval 50 :max-batch 1000}))

(do (def -res- ((:submit -exe-) 1 2 3 4 5 6)) @(first -res-)) => ’(nil (1 2 3 4 5 6))

(hub:wait (:queue -exe-)) => nil

creates a trackable atom queue

like aq:process but with a hub

(def +state+ (atom []))

(hub:process (fn elems(swap! +state+ conj elems)) (hub:new 1 2 3 4 5) 3)

@+state+ => [1 2 3 4 5]

submission function for the hub

waits for the hub executor to be ready