Rxjava2合并多个操作

import io.reactivex.Observable;
import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;

public class RxJava2MergeExample {
    public static void main(String[] args) {
        Observable<Integer> observable1 = Observable.just(1, 2, 3);
        Observable<Integer> observable2 = Observable.just(4, 5, 6);

        Observable<Integer> mergedObservable = Observable.merge(observable1, observable2);

        mergedObservable.subscribe(new Observer<Integer>() {
            @Override
            public void onSubscribe(Disposable d) {
                System.out.println("Subscribed");
            }

            @Override
            public void onNext(Integer integer) {
                System.out.println("Received: " + integer);
            }

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

            @Override
            public void onComplete() {
                System.out.println("Completed");
            }
        });
    }
}

Observable<Integer> mergedObservable = Observable.concat(observable1, observable2);

Observable<String> observable1 = Observable.just("1", "2", "3");
Observable<String> observable2 = Observable.just("4", "5", "6");

Observable<String> mergedObservable = Observable.merge(observable1, observable2);