我怎么能在RxJS中使用Conconat运算符，但忽略第一个可观察到的所有排放

Question

假设我们有两个观察对象。

const obs1=计时器（1000）；常数obs2=of（1,2,3）

如果我想等到obs1完成，我显然可以使用concat操作符。

表1。管道（混凝土（obs2））。订阅（console.log）；

或

concat（obs1、obs2）。订阅（console.log）；

它可以正常工作（保留顺序），但从第一个obs发出的“0”仍将被记录。有没有一种方法可以强制某些订阅的顺序，但忽略给定可观测数据的发射？（例如，只能看到“链”中最后一个可见值）。

在这种情况下，我知道预期会有多少值，所以我可以简单地使用skip/akeLast，但是我正在寻找一个通用的解决方案，它不需要我知道从可观察对象发出的元素的数量。

Answer 1

您可以SwitchMap或仅记录第二个可观察到的管道中的值：

const obs1 = timer(1000);
const obs2 = of(1, 2, 3);

obs1.pipe(
  concat(obs2.pipe(tap(val => console.log(val))))
).subscribe();

obs1.pipe(
    switchMap(_ => obs2)
).subscribe(console.log);

Answer 2

使用CombineTest：

例子：

    import { timer, combineLatest } from 'rxjs';
   const timerOne$ = timer(1000, 4000);
   const timerTwo$ = timer(2000, 4000);
   const timerThree$ = timer(3000, 4000);
   combineLatest(timerOne$, timerTwo$, timerThree$).subscribe(
  ([timerValOne, timerValTwo, timerValThree]) => {

    console.log(Timer Three Latest: ${timerValThree}`
    );
  }
);

或者

import { timer, combineLatest } from 'rxjs';

const timerOne$ = timer(1000, 4000);
const timerTwo$ = timer(2000, 4000);
const timerThree$ = timer(3000, 4000);

combineLatest(
  timerOne$,
  timerTwo$,
  timerThree$,
  // combineLatest also takes an optional projection function
  (one, two, three) => {
    return `${three}`;
  }
).subscribe(console.log);

Answer 3

您可以只使用ignoreElements（）。

concat(obs1.pipe(ignoreElements()), obs2).subscribe(...)

不管obs1是否发出任何下一个通知。