creates and starts a bus

returns all registered ids

(bus:with-temp bus (bus:all-ids bus)) => (contains #{string?})

returns all registered threads

(bus:with-temp bus (= (first (vals (bus:all-threads bus))) (Thread/currentThread))) => true

bus:closes all bus:opened loops

(bus:with-temp bus (let [{:keys stopped id} @(bus:open bus (fn m (update m :value inc)))] (Thread/sleep 10) (bus:close bus id) @stopped (bus:get-count bus))) => (contains-in {:exit :normal, :id string? :unprocessed empty? :start number? :end number?} 1)

stops all thread loops

creates a bus

deregisters from the bus

returns the number of threads registered

gets registered id given thread

(bus:with-temp bus (bus:get-id bus)) => string?

gets the message queue associated with the thread

(bus:with-temp bus (vec (bus:get-queue bus))) => []

gets thread given an id

(bus:with-temp bus (->> (bus:get-id bus) (bus:get-thread bus))) => (cc/thread:current)

checks that the bus has a given id

bus:closes all bus:opened loops

stops all thread loops

bus:opens a new handler loop given function

(bus:with-temp bus (let [{:keys id} @(bus:open bus (fn m (update m :value inc)))] (Thread/sleep 100) @(bus:send bus id {:value 1}))) => (contains {:value 2, :id string?})

registers a thread to the bus

resets the counters for a bus

sends a message to the given thread

bus:sends message to all thread queues

bus:waits on the message queue for message

(bus:with-temp bus (bus:send bus (bus:get-id bus) {:op :hello :message “world”}) (bus:wait bus)) => (contains {:op :hello, :message “world”, :id string?})

(bus:with-temp bus (bus:wait bus {:timeout 100}))

checks if object is instance of Bus

checks if object is instance of Bus

creates a thread loop for given message handler

returns info about the bus

creates a new message return loop

creates main message return handler

runs the handler in a thread loop

starts the bus

checks if bus is running

(bus:with-temp bus (Thread/sleep 10) (started?-bus bus)) => true

stops the bus