javascript - RxJS 中有publishOnce 类型的运算符吗？

Question

const xSubject = new BehaviorSubject(undefined);
someSource$.subscribe(xSubject);
emitWhenSomeSourceEmits$.pipe(
  concatMap(
    (emission) => of(emission)
        .pipe(
          delayWhen(
            () => someSource$.pipe(
              filter(val => !!val),
              ...
              tap(() => xSubject.next(undefined)),
            ),
        );
  ),
);

预期:emitWhenSomeSourceEmits$ 的发射应该延迟，直到 someSource$ 发出新值。

如果我不使用BehaviorSubject，那么如果 someSource$ 在 emmitWhenSomeSourceEmits$ 之前发出，那么后者的发出会被错误地延迟到下一次发出。

如果我只使用BehaviorSubject，则emitWhenSomeSourceEmits的第一次发射将与someSource一起计时。但是，emitWhenSomeSourceEmits 的第二次发射将使用 Behaved 值并无论如何发射。

为了克服这个问题，我一直在 xSubject 上点击一个 undefined ，以便 emmitWhenSomeSourceEmits 的下一次发射等待 someSource 的新值。

是否有更好且非hacky的方法来做到这一点？

Answer 1

zip 运算符 ( https://rxjs-dev.firebaseapp.com/api/index/function/zip ) 听起来非常适合此操作，因此只需 zip(someSource$, emmitWhenSomeSourceEmits$)。