 ;################################################################################;
 
 (defn generator*
-  "Creates an observable that calls (f observable & args) which should emit values
-  with (rx/on-next observable value).
+  "Creates an observable that calls (f observer & args) which should emit values
+  with (rx/on-next observer 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 a sequence. bindings
  should be a single [observer] argument.

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


  Example:

    (->> (rx/seq->o [1 2 3])
         (rx/do println)
    ...)

  Will print 1, 2, 3.
