function | since v0.0-1503 | Edit |
(set-connection conn)
Given a new available connection, poll the promise queue for and deliver the connection. Otherwise put the connection into a FIFO queue.
(defn set-connection
[conn]
(locking lock
(if-let [p (.poll promiseq)]
(deliver p conn)
(.offer connq conn))))