Liking cljdoc? Tell your friends :D
Clojure only.

eva.v2.messaging.node.local-simulation

This messaging implementation was forked from the local messaging node to provide a less restricted more-nondeterministic broker.

This messaging implementation was forked from
the local messaging node to provide a less
restricted more-nondeterministic broker.
raw docstring

*instance-id*clj

source

facade-messengerclj

(facade-messenger shared-messenger instance-id)
source

get-responderclj

(get-responder node addr)
source

get-subscribersclj

(get-subscribers node addr)
source

local-messengerclj

(local-messenger)
source

pub->sub!clj

(pub->sub! {:as subscriber :keys [f]} msg)
source

publish!clj

(publish! node publisher msg)
source

publish!*clj

(publish!* {:as publisher :keys [addr]} node msg)
source

publisherclj

(publisher addr opts)
source

requestorclj

(requestor addr opts)
source

respond!clj

(respond! {:as responder :keys [f]} {:as enveloped-msg :keys [msg reply-to]})
source

responderclj

(responder addr f opts)
source

response!clj

(response! {:as requestor :keys [promises]} id res)
source

send*clj

(send* msgr f & args)
source

send-request!clj

(send-request! node requestor msg)
source

send-request!*clj

(send-request!* {:as requestor :keys [addr promises]} node msg res)
source

subscriberclj

(subscriber id addr f opts)
source

with-instance-idcljmacro

(with-instance-id id & body)
source

cljdoc builds & hosts documentation for Clojure/Script libraries

Keyboard shortcuts
Ctrl+kJump to recent docs
←Move to previous article
→Move to next article
Ctrl+/Jump to the search field
Raise an issueBrowse cljdoc sourceChat on Slack
× close