File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed
language-adaptors/rxjava-clojure/src/main/clojure/rx/lang/clojure Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change 432
432
Example:
433
433
434
434
(->> (rx/seq->o [1 2 3])
435
- (rx/do println)
435
+ (rx/do println)
436
436
...)
437
437
438
438
Will print 1, 2, 3.
884
884
; ################################################################################;
885
885
886
886
(defn generator*
887
- " Creates an observable that calls (f observable & args) which should emit values
888
- with (rx/on-next observable value).
887
+ " Creates an observable that calls (f observer & args) which should emit values
888
+ with (rx/on-next observer value).
889
889
890
890
Automatically calls on-completed on return, or on-error if any exception is thrown.
891
891
902
902
wrap-on-error)))
903
903
904
904
(defmacro generator
905
- " Create an observable that executes body which should emit a sequence. bindings
906
- should be a single [ observer] argument .
905
+ " Create an observable that executes body which should emit values with
906
+ (rx/on-next observer value) where observer comes from bindings .
907
907
908
908
Automatically calls on-completed on return, or on-error if any exception is thrown.
909
909
You can’t perform that action at this time.
0 commit comments