RxJava中的組合操作符怎么用

RxJava中的組合操作符用于將多個Observable對象組合在一起，以便根據特定的規則發出新的數據項或事件。以下是一些常用的組合操作符及其用法：

1. zip

zip操作符將多個Observable對象按順序組合在一起，只有當所有Observable都發出一個數據項時，才會發出一個新的數據項。

Observable.just(1, 2, 3)
    .zip(Observable.just("a", "b", "c"), (number, letter) -> number + letter)
    .subscribe(System.out::println); // 輸出: 1a, 2b, 3c

2. combineLatest

combineLatest操作符將多個Observable對象組合在一起，每當任何一個Observable發出一個新數據項時，都會發出一個新的數據項，包含所有Observable的最新數據項。

Observable<Integer> observable1 = Observable.just(1, 2, 3);
Observable<String> observable2 = Observable.just("a", "b");

Observable.combineLatest(observable1, observable2, (number, letter) -> number + letter)
    .subscribe(System.out::println); // 輸出: 1a, 2b, 3a

3. merge

merge操作符將多個Observable對象合并成一個Observable對象，按順序發出所有Observable的數據項。

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

Observable.merge(observable1, observable2)
    .subscribe(System.out::println); // 輸出: 1, 2, 3, 4, 5, 6

4. concat

concat操作符將多個Observable對象按順序連接起來，只有當一個Observable完成時，才會開始下一個Observable。

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

Observable.concat(observable1, observable2)
    .subscribe(System.out::println); // 輸出: 1, 2, 3, 4, 5, 6

5. flatMap

flatMap操作符將一個Observable對象發出的每個數據項轉換為另一個Observable對象，并將這些Observable對象合并成一個Observable對象。

Observable.just(1, 2, 3)
    .flatMap(number -> Observable.just(number, number * 10))
    .subscribe(System.out::println); // 輸出: 1, 10, 2, 20, 3, 30

6. switchMap

switchMap操作符類似于flatMap，但它只保留最新的Observable對象發出的數據項，并取消之前的Observable對象。

Observable.just(1, 2, 3)
    .switchMap(number -> Observable.just(number, number * 10))
    .subscribe(System.out::println); // 輸出: 3, 30

7. concatMap

concatMap操作符類似于flatMap，但它按順序處理每個Observable對象，并等待前一個Observable對象完成后才開始下一個。

Observable.just(1, 2, 3)
    .concatMap(number -> Observable.just(number, number * 10))
    .subscribe(System.out::println); // 輸出: 1, 10, 2, 20, 3, 30

8. mergeMap

mergeMap操作符類似于flatMap，但它將所有Observable對象合并成一個Observable對象，并按順序發出數據項。

Observable.just(1, 2, 3)
    .mergeMap(number -> Observable.just(number, number * 10))
    .subscribe(System.out::println); // 輸出: 1, 10, 2, 20, 3, 30

這些組合操作符可以幫助你根據不同的需求組合和處理多個Observable對象。在使用時，請確保理解每個操作符的行為和適用場景。