merge和concat區別

Rxjs中merge和concat區別：

1、相同點：

都是將多個可觀察輸入對象合並為一個可觀測輸出對象，通過訂閱獲取輸入客觀擦對象的彈出的值；

 concat中只要有一個輸入可觀察對象發生錯誤，其后面的輸入可觀察對象無法彈出其值，即訂閱終止；merge存在競爭關系，有一個輸入可觀察對象發生錯誤，也會 終止訂閱。

2、不同點：

merge是並聯，同步發生，存在競爭關系；concat是串聯，按照輸入順序，第一個可觀測對象的值彈出完全后，接着開始彈出第二個可觀察對象，依次輸出。

3、事實上，concat相當於將並發參數設置為1的merge操作符，即 concat（inputObv1,inputObv2, inputObv3, ....） === merge(inputObv1,inputObv2, inputObv3, ...., 1)

　　

const o1 = new Observable<string>(observer => {
      timer(200).subscribe(() => {
        observer.next('2s');
        observer.error('error 第一個輸入可觀擦對象報錯，后續可觀擦對象終止訂閱');
        observer.complete();
      });
    });
  
    const o2 = new Observable<string>(observer => {
      timer(1000).subscribe(() => {
        observer.next('1s');
        observer.complete();
      });
    });
    
    concat(o1, o2).subscribe({
      next(value) {
        console.log('value: ', value);
      },
      error(reason) {
        console.log('reason:', reason);
      },
      complete() {
        console.log('complete');
      }
    });
    
    merge(o1, o2, 1).subscribe({
      next(value) {
        console.log('value: ', value);
      },
      error(reason) {
        console.log('reason:', reason);
      },
      complete() {
        console.log('complete');
      }
    });
  }