rx.lang.clojure.chunk
chunkclj
(chunk chunk-size observable-source)(chunk chunk-size options observable-source)EXTREMELY EXPERIMENTAL AND SUBJECT TO CHANGE OR DELETION
TODO RxJava's much bigger since this was written. Is there something built in?
Same as rx.Observable.merge(Observable<Observable<T>>) but the input Observables are "chunked" so that at most chunk-size of them are "in flight" at any given time.
The order of the input Observables is not preserved.
The main purpose here is to allow a large number of Hystrix observables to be processed in a controlled way so that the Hystrix execution queues aren't overwhelmed.
Example:
(->> users (rx/map #(-> (GetUserCommand. %) .toObservable)) (chunk 10))
See: http://netflix.github.io/RxJava/javadoc/rx/Observable.html#merge(rx.Observable) http://netflix.github.io/RxJava/javadoc/rx/Observable.html#mergeDelayError(rx.Observable)
EXTREMELY EXPERIMENTAL AND SUBJECT TO CHANGE OR DELETION
TODO RxJava's much bigger since this was written. Is there something built in?
Same as rx.Observable.merge(Observable<Observable<T>>) but the input Observables
are "chunked" so that at most chunk-size of them are "in flight" at any given
time.
The order of the input Observables is not preserved.
The main purpose here is to allow a large number of Hystrix observables to
be processed in a controlled way so that the Hystrix execution queues aren't
overwhelmed.
Example:
(->> users
(rx/map #(-> (GetUserCommand. %) .toObservable))
(chunk 10))
See:
http://netflix.github.io/RxJava/javadoc/rx/Observable.html#merge(rx.Observable)
http://netflix.github.io/RxJava/javadoc/rx/Observable.html#mergeDelayError(rx.Observable)
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close