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

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

(defn ^Observable$Operator operator*
  "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:

(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]
