 ; Operators
 
 (defn synchronize
+  "Synchronize execution.
+
+  See:
+    rx.Observable/synchronize
+  "
   ([^Observable xs]
   (.synchronize xs))
   ([lock ^Observable xs]

(declare unsubscribed?)

(defn ^Subscriber subscriber
  ""
  ([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
  "Subscribe to the given observable.

  on-X-action is a normal clojure function.

  See:
    rx.Observable/subscribe
  "

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