Liking cljdoc? Tell your friends :D

clj-nats-async.core


create-natsclj

(create-nats & urls)

creates a Nats connection, returning a Nats object

  • urls : nats server urls, either a seq or comma separated
creates a Nats connection, returning a Nats object
- urls : nats server urls, either a seq or comma separated
sourceraw docstring

INatsMessagecljprotocol

msg-bodyclj

(msg-body _)
source

publishclj

(publish nats subject-or-fn)
(publish nats subject-or-fn body)
(publish nats subject-or-fn body {:keys [reply] :as opts})

publish a message

  • subject-or-fn : either a string specifying a fixed subject or a (fn [item] ...) which extracts a subject from an item
publish a message
- subject-or-fn : either a string specifying a fixed subject or a
                   (fn [item] ...) which extracts a subject from an item
sourceraw docstring

publisherclj

(publisher nats subject-or-fn)

returns a Manifold sink-only stream which publishes items put on the stream to NATS

returns a Manifold sink-only stream which publishes items put on the stream
to NATS
sourceraw docstring

pubsubclj

(pubsub nats subject)
(pubsub nats subject opts)

returns a Manifold source+sink stream for a single NATS subject. the source returns INatsMessages, while the sink accepts strings

returns a Manifold source+sink stream for a single NATS subject.
the source returns INatsMessages, while the sink accepts
strings
sourceraw docstring

subscribeclj

(subscribe nats subject)
(subscribe nats subject opts)

returns a a Manifold source-only stream of INatsMessages from a NATS subject. close the stream to dispose of the subscription

returns a a Manifold source-only stream of INatsMessages from a NATS subject.
close the stream to dispose of the subscription
sourceraw docstring

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close