   Example:
 
     (->> (rx/seq->o [1 2 3])
-    (rx/do println)
+         (rx/do println)
     ...)
 
   Will print 1, 2, 3.

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

(defn generator*
  "Creates an observable that calls (f observable & args) which should emit values
  with (rx/on-next observable value).

  Automatically calls on-completed on return, or on-error if any exception is thrown.


                   wrap-on-error)))

(defmacro generator
  "Create an observable that executes body which should emit values with
  (rx/on-next observer value) where observer comes from bindings.

  Automatically calls on-completed on return, or on-error if any exception is thrown.

