qbits.tape.async — cc.qbits/tape 0.3.0-beta4

Experimental core.async interface

appender-chan clj

(appender-chan queue)

(appender-chan queue
               {:as opts
                :keys [ch error-ch]
                :or {ch (async/chan)
                     error-ch (async/chan (async/dropping-buffer 50))}})

tailer-chan clj

(tailer-chan queue)

(tailer-chan queue
             {:keys [ch poll-interval meta?]
              :or {ch (async/chan) poll-interval 50 meta? true}
              :as opts})