 ;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
 
 (defn- chan->subscription
+  "Coerce a core.async channel to an instance
+  of subscription interface."
   [subscriber source xform]
   (let [completed (atomic/boolean false)
         requests (async/chan)

          (.onComplete subscriber))))))

(defn- subscribe-once
  [^Publisher p callback]
  (let [subscription (atomic/ref nil)
        completed (atomic/boolean false)

          (async/close! requests))))))

(defn- promise->subscription
  "Coerce a promise instance to an instance
  of subscription interface."
  [subscriber source]
  (let [canceled (atomic/boolean false)
        completed (atomic/boolean false)]
