tech.thomascothran.pavlov.bprogram.internal.state — tech.thomascothran/pavlov 1.0.69

assoc-events clj/s

(assoc-events state bthread bid request-type)

blocked clj/s

(blocked state)

bthreads-to-notify clj/s

(bthreads-to-notify state event)

Given an event, return the bthreads to notify

init clj/s

(init bthreads)

Initiate the state

is-blocked? clj/s

(is-blocked? blocked-events bid)

make-bid-map clj/s

(make-bid-map)

next-event clj/s

(next-event state)

The winning bid will request a new event

next-state clj/s

(next-state {:keys [state event]}
            {new-bthread->bid :bthread->bid
             new-waits :waits
             new-requests :requests
             new-blocks :blocks})

notify-bthreads! clj/s

(notify-bthreads! state event)

Notify the bthreads, returning a map of the

• bthread->bid: only the new bids. The caller has to merge this into the bthreads to bids
• requests: the new requests
• waits: the new waits
• blocks: the new blocks

step clj/s

(step state event)

Return the next state based on the event