Flash Message queue

flash-message.cljs

(ns kitasato.components.flash-message
  (:require-macros [cljs.core.async.macros :refer [alt! go-loop]])
  (:require [reagent.core :as r]
            [cljs.core.async :refer [close! chan <! timeout put!]]))

(defonce bus (chan))

(defonce current (r/atom [nil nil]))

(defonce main-loop
  (go-loop [[item make-control] (<! bus)]
    (if item
      (let [control (make-control)]
        (reset! current [item (fn []
                                (close! control))])
        (<! control)
        (let [tim (timeout 100)]
          (alt! bus ([message] (recur message))
                tim (recur [nil nil]))))
      (do (reset! current [nil nil])
          (recur (<! bus))))))

(defn add [message]
  (put! bus [message #(timeout 4000)]))

(defn show []
  (let [[message cancel] @current]
    (when message
      [:div.FlashMessage (:title message)
       [:span {:on-click #(cancel)} "fechar"]])))