std.concurrent.relay

*bus*

dynamic

+control-ops+

+init+

+read-ops+

attach-interactive

added in 4.0

(attach-interactive istream)(attach-interactive {:keys [bus], :as istream} id)

attaches a bus process to an input stream

attach-read-passive

added in 4.0

(attach-read-passive {:keys [raw return result final], :as istream} {:keys [op handler], :as message})

attaches a passive process to an input stream

get-bus

added in 3.0

(get-bus)

gets the common stream bus

make-instance

added in 4.0

(make-instance obj)(make-instance obj id options)

creates an instance

make-process-instance

added in 4.0

(make-process-instance process id options)

creates a process instance

make-socket-instance

added in 4.0

(make-socket-instance socket id options)

creates a socket instance

relay

added in 3.0

(relay {:keys [type], :as m})

creates and starts a relay

relay-start

added in 4.0

(relay-start {:keys [id type instance options hooks attached], :as relay})

starts the relay

relay-stop

added in 4.0

(relay-stop {:keys [type hooks instance], :as relay})

stops the relay

relay-stream

added in 4.0

(relay-stream id type raw options)

creates a relay stream

relay-stream?

added in 4.0

(relay-stream? obj)

checks if object is a relay stream

relay:create

added in 4.0

(relay:create {:keys [id type], :as m})

creates a relay

send

added in 3.0

(send {:keys [instance], :as relay} msg)

sends command to relay

with:bus

macro

added in 4.0

(with:bus [bus] & body)

sets the default relay bus