(create-nats & urls)
creates a Nats connection, returning a Nats object
creates a Nats connection, returning a Nats object - urls : nats server urls, either a seq or comma separated
(publish nats subject-or-fn)
(publish nats subject-or-fn body)
(publish nats subject-or-fn body {:keys [reply] :as opts})
publish a message
publish a message - subject-or-fn : either a string specifying a fixed subject or a (fn [item] ...) which extracts a subject from an item
(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
(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
(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