(ns rivershy
  (:require [clojure.core.async :as a]))

(def c1 (a/chan 10))
(def c2 (a/chan 10))
(def cr (a/chan 10))

(a/onto-chan c1 ["a" "1" "c" "d" "q"])
(a/onto-chan c2 ["a" "b" "c" "d" "e"])

(defn eq-chans [chans r]
  (a/go-loop []
    (let [val (fn [x] (a/<! x))
          vals (map val chans)]
      (when (apply = vals)
        (a/>! r (first vals))
        (recur)
        )
      )
    )
  )

(defn consumer []
  (a/take! cr (fn [x] (println (str "received" x)) (consumer name))))

(eq-chans []c1 c2] cr)

(consumer)