Java Magazine, Jan/Feb 2018
ORACLE COM JAVAMAGAZINE JANUARY FEBRUARY 2018 43 reactive programming 12 01 03128 RxSingleScheduler 1 INFO samples RxThreading 10 12 01 03128 RxComputationThreadPool 1 INFO samples RxThreading map 30 12 01 03128 RxSingleScheduler 1 INFO samples RxThreading 20 12 01 03128 RxComputationThreadPool 1 INFO samples RxThreading map 40 12 01 03128 RxSingleScheduler 1 INFO samples RxThreading 30 12 01 03128 RxSingleScheduler 1 INFO samples RxThreading 40 12 01 03128 RxComputationThreadPool 1 INFO samples RxThreading map 50 12 01 03128 RxSingleScheduler 1 INFO samples RxThreading 50 12 01 04127 main INFO samples RxThreading Combining observables RxJava offers many ways to combine streams Well illustrate that with the merge and zip operations Merging streams provides a single stream that mixes elements from the various sources as the following example shows package samples import io reactivex Flowable import io reactivex schedulers Schedulers import org slf4j Logger import org slf4j LoggerFactory
You must have JavaScript enabled to view digital editions.