一、描述

使用Pattern和Plan作为中介，将两个或多个Observable发射的数据集合并到一起。

And/Then/When操作符组合的行为类似于zip，但是它们使用一个中间数据结构。接受两个或多个Observable，一次一个将它们的发射物合并到Pattern对象，然后操作那个Pattern对象，变换为一个Plan。随后将这些Plan变换为Observable的发射物。

它们属于rxjava-joins模块，不是核心RxJava包的一部分。

二、示意图

and/then/when

三、示例代码

由于start操作符是属于可选的rxjava-joins模块的，所以需要加入下面的依赖：

1	compile 'io.reactivex:rxjava-joins:0.22.0'

Observable just1 = Observable.just("A", "B");
Observable just2 = Observable.just(1, 2, 3);

Pattern2<String, Integer> pattern = JoinObservable.from(just1).and(just2);
Plan0 plan = pattern.then(new Func2<String, Integer, String>() {
    @Override
    public String call(String s, Integer integer) {
        return s + integer;
    }
});

JoinObservable.when(plan)
    .toObservable()
    .subscribe(new Subscriber<String>() {
        @Override
        public void onCompleted() {
            System.out.println("onCompleted.");
        }

        @Override
        public void onError(Throwable e) {
            System.out.println("onError: " + e.getMessage());
        }

        @Override
        public void onNext(String s) {
            System.out.println("onNext: " + s);
        }
    });