async_reddit.clj

(ns async-reddit
  (:require [reddit :refer [get-reddit-posts]]
            [clojure.core.async :as async]))

(defn get-post-link
  [post]
  (str "https://reddit.com" (:permalink post)))

(defn get-post-footer
  [post]
  (str (:score post) " | " (:num_comments post) " comments"))

(defn print-post
  [post]
  (doseq [display-fn [:title get-post-link get-post-footer]]
    (println (display-fn post)))
  (println "\n"))

(defn -main
  []
  (let [in-chan (async/chan)]
    (-> in-chan
        (async/pipe (async/chan 1 (map :data))) ;; each EDN post stores relevant data in :data key
        (async/take! print-post))
    (->> (get-reddit-posts "limit=5") ;; returns an EDN list of 5 EDN post objects
         (async/onto-chan in-chan))))
         
(-main)