(->TimeoutQueueEntry channel timestamp)
Positional factory function for class clojure.core.async.impl.timers.TimeoutQueueEntry.
Source
(deftype TimeoutQueueEntry [channel ^long timestamp]
Delayed
(getDelay [this time-unit]
(.convert time-unit
(- timestamp (System/currentTimeMillis))
TimeUnit/MILLISECONDS))
(compareTo
[this other]
(let [ostamp (.timestamp ^TimeoutQueueEntry other)]
(if (< timestamp ostamp)
-1
(if (= timestamp ostamp)
0
1))))
impl/Channel
(close! [this]
(impl/close! channel)))