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$的排放应该推迟到somesourceemits$发出新的值。

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

如果我只使用行为主题，emitWhen某物源发射的第一次发射将与某物源定时。但是emitWhen某物源发射的第二次发射将使用行为值并以任何方式发射。

为了克服这个问题，我一直在对xSubject轻触一个未定义的，以便emitWhenSomeSourceEmits的下一个发射等待来自someSource的新值。

有没有更好的非黑客方式？

Answer 1

邮政编码操作符(https://rxjs-dev.firebaseapp.com/api/index/function/zip)听起来很适合这样做，所以只需压缩（someSource$，emitWhenSomeSourceEmits$）。