Liking cljdoc? Tell your friends :D
clj-nats-async.core
create-natsclj
(create-nats & opts)Creates a Nats connection, returning a Nats object. Opts is a map containing
the :urls and possible other values. For backwards compatibility, this can
also be a list of urls, or a comma separated url string.
Creates a Nats connection, returning a Nats object. Opts is a map containing the `:urls` and possible other values. For backwards compatibility, this can also be a list of urls, or a comma separated url string.
make-optionsclj
(make-options [m :as conf])Creates a Nats options object using the given configuration
Creates a Nats options object using the given configuration
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 itempublisherclj
(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
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
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
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close