如何与承诺一起使用 withLatestFrom？

Question

为什么不能将promise 转换为observable，然后将其与withLatestFrom 一起使用。我不清楚，为什么这不能解决。

of('')
  .pipe(
    withLatestFrom(from(myPromise)),
    map((res) => {
      console.log('does not resolve', res);
    })
  )
  .subscribe();

Answer 1

WithLatestFrom 仅在其源 Observable 发出时发出，因为of('') 在源到 withLatestFrom 之前发出，所以您的 withLatestFrom 永远不会被触发。

以下代码将不起作用：

of('1 + 1')
  .pipe(
    withLatestFrom(new Promise(x => x("== 2"))),
    map(([res1,res2]) => console.log(res1, res2))
  )
  .subscribe();

但这会：

of('1 + 1')
  .pipe(
    delay(100), // <= delay source execution
    withLatestFrom(new Promise(x => x("== 2"))),
    map(([res1,res2]) => console.log(res1, res2))
  )
  .subscribe();

Answer 2

这是withLatestFrom 的预期行为。源 observable 在 Promise 解析之前同步完成（异步）。 withLatestFrom 仅在两个 observable 都至少发出一次后才发出，然后仅在源 observable 发出时才发出。

在您的情况下，源 observable 在 promise 解决之前就已完成。

of('').pipe(
  delay(100),
  withLatestFrom(from(myPromise)),
  tap(res =>
    console.log('should resolve', res)
  )
).subscribe();

更新 #1：没有delay 的解决方案

如果两个源 observable 都发出一次并完成，那么forkJoin 是最好的

forkJoin({
  addition: of(1 + 1),
  promise: from(myPromise)
}).pipe(
  map(({addition, promise}) => {return /* something */})
)

combineLatest 类似于forkJoin，但它更适用于持续发射值的长寿命流。它等待其内部流全部开始发射，然后发射所有最新值。

combineLatest(
  of(1 + 1),
  from(myPromise)
).pipe(
  map(([addition, promise]) => {return /* something */})
)

或者，如果您想使用 withLatestFrom 并且您对时间限制感到满意。

from(myPromise).pipe(
  withLatestFrom(of(1+1)),
  map(([promise, addition]) => {return /* something */})
)

应该可以。