rx.lang.clojure.blocking
Blocking operators and functions. These should never be used in production code except at the end of an async chain to convert from rx land back to sync land. For example, to produce a servlet response.
If you use these, you're a bad person.
Blocking operators and functions. These should never be used in production code except at the end of an async chain to convert from rx land back to sync land. For example, to produce a servlet response. If you use these, you're a bad person.
->blockingclj
(->blocking o)Convert an Observable to a BlockingObservable.
If o is already a BlockingObservable it's returned unchanged.
Convert an Observable to a BlockingObservable. If o is already a BlockingObservable it's returned unchanged.
doseqcljmacro
(doseq bindings & body)Like clojure.core/doseq except iterates over an observable in a blocking manner.
Unlike clojure.core/doseq, only supports a single binding
Returns nil.
Example:
(rx-blocking/doseq [{:keys [name]} users-observable] (println "User:" name))
See: doseq* clojure.core/doseq
Like clojure.core/doseq except iterates over an observable in a blocking manner.
Unlike clojure.core/doseq, only supports a single binding
Returns nil.
Example:
(rx-blocking/doseq [{:keys [name]} users-observable]
(println "User:" name))
See:
doseq*
clojure.core/doseq
doseq*clj
(doseq* xs f)Blocks and executes (f x) for each x emitted by xs
Returns nil.
See: doseq clojure.core/doseq
*Blocks* and executes (f x) for each x emitted by xs Returns nil. See: doseq clojure.core/doseq
firstclj
(first observable)Blocks and waits for the first value emitted by the given observable.
If the Observable is empty, returns nil
If an error is produced it is thrown.
See: clojure.core/first rx/first rx.observables.BlockingObservable/first
*Blocks* and waits for the first value emitted by the given observable. If the Observable is empty, returns nil If an error is produced it is thrown. See: clojure.core/first rx/first rx.observables.BlockingObservable/first
intoclj
(into to from-observable)Blocks and pours the elements emitted by the given observables into to.
If an error is produced it is thrown.
See: clojure.core/into rx/into
*Blocks* and pours the elements emitted by the given observables into to. If an error is produced it is thrown. See: clojure.core/into rx/into
lastclj
(last observable)Blocks and waits for the last value emitted by the given observable.
If the Observable is empty, returns nil
If an error is produced it is thrown.
See: clojure.core/last rx/last rx.observable.BlockingObservable/last
*Blocks* and waits for the last value emitted by the given observable. If the Observable is empty, returns nil If an error is produced it is thrown. See: clojure.core/last rx/last rx.observable.BlockingObservable/last
o->seqclj
(o->seq o)Returns a lazy sequence of the items emitted by o
See: rx.observables.BlockingObservable/getIterator rx.lang.clojure.core/seq->o
Returns a lazy sequence of the items emitted by o See: rx.observables.BlockingObservable/getIterator rx.lang.clojure.core/seq->o
singleclj
(single observable)Blocks and waits for the first value emitted by the given observable.
An error is thrown if zero or more then one value is produced.
*Blocks* and waits for the first value emitted by the given observable. An error is thrown if zero or more then one value is produced.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close