 ;################################################################################
 
 (defn ^Subscription subscribe
+  "Subscribe to the given observable.
+
+  on-X-action is a normal clojure function.
+
+  See:
+    rx.Observable/subscribe
+  "
 
   ([^Observable o on-next-action]
     (.subscribe o

; Operators

(defn synchronize
  ([^Observable xs]
  (.synchronize xs))
  ([lock ^Observable xs]

  (Subscriptions/create ^Action0 (iop/action* handler)))

(defn ^Observable$Operator operator*
  "Experimental, subject to change or deletion.

  Returns a new implementation of rx.Observable$Operator that calls the given
  function with a rx.Subscriber. The function should return a rx.Subscriber.

  See:
