MergeOperator.java

package rxjava.combining;

import java.util.concurrent.TimeUnit;

import io.reactivex.Observable;
import io.reactivex.functions.Consumer;
import util.ThreadUtil;

/**
 * Author:  andy.xwt
 * Date:    2019-02-08 14:07
 * Description: 组合多个被观察者，将多个被观察者发送的事件，按照时间线进行组合并发送
 */

public class MergeOperator {

    /**
     * 第一个被观察者发送：1|2|3|4|5
     * 第二个被观察着发送： |5| |6| |7|8|9
     * 合并为：1 25(52) 3 46(64) 5 7 8 9
     */
    static void testMerge() {
        Observable.merge(
                Observable.intervalRange(1, 5, 0, 1, TimeUnit.SECONDS),
                Observable.intervalRange(5, 5, 1, 2, TimeUnit.SECONDS))
                .subscribe(new Consumer<Long>() {
                    @Override
                    public void accept(Long aLong) throws Exception {
                        System.out.println(aLong);
                    }
                });
    }

    public static void main(String[] args) throws InterruptedException {
        testMerge();
        ThreadUtil.sleep();;//这里保证虚拟机不停止运行，
    }
}