queues.janet

(def click-queue (ev/chan 4))

(defn ev/check
  [chan]
  (when (pos? (ev/count chan))
    (ev/take chan)))

(defn ev/push
  [chan v]
  (when (ev/full chan)
    (ev/take chan)) ## throw away old values
  (ev/give chan v))

(def dumb-queue @[])

(defn take
  [queue]
  (array/pop queue))

(defn push
  [queue v]
  (array/insert queue 0 v))


(varfn draw-frame
  [dt]
  (when (mouse-button-pressed? 0)
    (def pos (get-mouse-position))
    (ev/go (coro (ev/sleep 1)
             (ev/push click-queue
                      (fn [] (print "delayed!")
                        (pp pos)))
             (push dumb-queue
                      (fn [] (print "dumb delayed!")
                        (pp pos))))))


  (loop [f :iterate (take dumb-queue)]
    (f))

  (loop [f :iterate (ev/check click-queue)]
    (f)))