reactors.core — com.vodori/reactors 0.1.0

all-subscribers-removed clj

(all-subscribers-removed k r o n)

attach-channel-cleanup clj

(attach-channel-cleanup chan f)

changed? clj

(changed? key old-state new-state)

(changed? key old-state new-state default)

crashed clj

(crashed agent error)

create-reactor clj

(create-reactor)

(create-reactor {:keys [backoff emitter reducer initializer] :as opts})

current-reactor clj

(current-reactor)

get-added clj

(get-added key o n)

get-removed clj

(get-removed key o n)

implode! clj

(implode! {:keys [subscribers publishers destructors]})

publishers-on-change clj

(publishers-on-change k r o {:keys [reducer] :as n})

publishers-on-start clj

(publishers-on-start k r o {:keys [reducer publishers] :as n})

quietly clj macro

(quietly & body)

Reactor clj protocol

remove-subscribers! clj

(remove-subscribers! this publishers)

Removes subscribers by their idents. A removed subscriber is closed.

get-agent clj

(get-agent this)

Returns the agent that is used to implement the reactor.

remove-destructors! clj

(remove-destructors! this destructors)

Removes destructors by their idents.

await! clj

(await! this)

Blocks the thread until the message queue for the reactor is empty.

start! clj

(start! this)

Starts the reactor. This emits the initial state to any subscribers.

set-initializer! clj

(set-initializer! this initializer)

Sets the function for populating the initial state of the reactor, also used to repopulate after a crash.

add-subscribers! clj

(add-subscribers! this subscribers)

Adds subscribers (a map of idents to core.async channels listening for changes).

add-destructors! clj

(add-destructors! this destructors)

Adds destructors (a map of idents to functions to call when the reactor is destroyed).

get-publishers clj

(get-publishers this)

Returns the idents of the publishers feeding to the reactor.

get-state clj

(get-state this)

Returns the current state of the reactor.

set-emitter! clj

(set-emitter! this emitter)

Sets the function for emitting events based on changes in the reactor state.

add-publishers! clj

(add-publishers! this publishers)

Adds publishers (a map of idents to core.async channels delivering changes).

remove-publishers! clj

(remove-publishers! this publishers)

Removes publishers by their idents. A removed publisher is closed.

update-blocking! clj

(update-blocking! this f)

Change the state independently of a publisher with a function that may block.

set-reducer! clj

(set-reducer! this reducer)

Sets the function for performing reductions of change into the reactor state.

get-subscribers clj

(get-subscribers this)

Returns the idents of the subscribers watching the reactor.

update! clj

(update! this f)

Change the state independently of a publisher.

set-backoff! clj

(set-backoff! this backoff)

Backoff policy represented by a sequence (potentially infinite) of milliseconds to wait between reboots. Once empty, the reactor will implode.

reboot! clj

(reboot! this)

Crashes the reactor so that it reboots itself. Counts against the backoff policy.

reboot-agent! clj

(reboot-agent! agent)

recursive-await clj

(recursive-await a)

Like await, except it waits on actions dispatched by actions.

running? clj

(running? o n)

send-messages clj

(send-messages messages subscribers)

started? clj

(started? o n)

state-changed clj

(state-changed k r o {:keys [emitter subscribers] :as n})

subscribers-on-change clj

(subscribers-on-change k r o {:keys [emitter] :as n})

subscribers-on-start clj

(subscribers-on-start k r o {:keys [emitter subscribers] :as n})