pg.util.clj

(ns pg.util
  (:require [clojure.core.async :refer [>! <! >!! <!! alts! alts!! chan go go-loop put! take! thread timeout close!] :as async]))

;; synchronous; takes from channel argument if something is available, else returns nil
(def maybe-take!
  (let [closed-ch (doto (chan) (close!))]
    (fn [ch]
      (let [[x port] (alts!! [ch closed-ch] {:priority true})]
        (when (= port ch)
          x)))))