 (declare unsubscribed?)
 
 (defn ^Subscriber subscriber
-  ""
+  "Experimental, subject to change or deletion."
   ([o on-next-action] (subscriber o on-next-action nil nil))
   ([o on-next-action on-error-action] (subscriber o on-next-action on-error-action nil))
   ([^Subscriber o on-next-action on-error-action on-completed-action]

;################################################################################

(defn ^Subscription subscribe

  ([^Observable o on-next-action]
    (.subscribe o

; Operators

(defn synchronize
  "Synchronize execution.

  See:
    rx.Observable/synchronize
  "
  ([^Observable xs]
  (.synchronize xs))
  ([lock ^Observable xs]
