feed.clj

(def payment-codes-per-block 4096)

(defn create-payment-code-feed
  [db]
  (let [payment-code-feed (chan 10)]
    (go-loop []
             (let [block-id (allocate-block db)
                   block-start (* block-id payment-codes-per-block)]
               (-> (onto-chan payment-code-feed
                              (->>
                                (range block-start (+ block-start payment-codes-per-block))
                                (map sa/int->six-alpha))
                              ;; Don't close!
                              false)
                   ;; park here until all of that block has been consumed.
                   <!))
             ;; Loop forever.
             (recur))
    payment-code-feed))