Infinite reddit post channel

reddit.clj

(defn get-posts
  [ch]
  (go-loop [a nil]
    (let [res   (get-posts-page a)
          posts (res :children)
          after (res :after)]
      (do
        (doseq [p posts]
          (>! ch p))
        (recur after)))))