Slurp the contents of your Onyx log into memory

onyx.clj

(defn slurp-log
  ([peer-client-config] (slurp-log peer-client-config 2000))
  ([peer-client-config wait]
   (let [chan (clojure.core.async/chan)
         sub (onyx.api/subscribe-to-log peer-client-config chan)
         timeout (clojure.core.async/timeout wait)
         xs (clojure.core.async/<!!
             (clojure.core.async/go-loop [xs []]
               (let [[val ch] (clojure.core.async/alts! [chan timeout])]
                 (if (= ch timeout)
                   xs
                   (recur (conj xs val))))))]
     (-> sub :env onyx.api/shutdown-env)
     xs)))