Advanced usage

Examples

xsub-xpub

(let [xsub (socket :xsub "@tcp://*:*")
        xpub (doto (socket :xpub "@tcp://*:*") (proxy! xsub))
        pubs (vec (for [_ (range 5)]
                    (doto (socket :pub) (connect! xsub))))
        subs (vec (for [_ (range 10)]
                    (doto (socket :sub)
                      (connect! xpub)
                      (subscribe! ""))))]
    (doseq [[i s] (map-indexed vector pubs)] (send! s (str i)))
    (Thread/sleep 100) ; give enough time for messages to pass
    (let [msgs-s1 (vec (map #(String. %) (recv-all-messages! (first subs))))]
      (doseq [s (rest subs)]
        (assert (= (vec (map #(String. %) (recv-all-messages! s)))
                   msgs-s1)))))

proxy! here emulates ZMQ_PROXY functionality using a pair of core.async pipes.

More examples

Please have a look at the tests. There are plenty of interesting examples, some of which are slightly advanced.