rxjs - 接收 : Force observable to take at least N seconds to complete

Question

我正在为我的应用程序制作启动画面。我希望它在进入主屏幕之前至少持续 N 秒。

我有一个 接收 变量 myObservable从服务器或我的本地缓存返回数据。如何强制myObservable完成于 至少 N 秒 ?

myObservable
// .doStuff to make it last at least N seconds
   .subscribe(...)

Answer 1

您可以使用 forkJoin等待两个 Observable 完成:

Observable.forkJoin(myObservable, Observable.timer(N), data => data)
  .subscribe(...);

对于没有弃用结果选择器函数的 RxJS 6:

forkJoin(myObservable, Observable.timer(N)).pipe(
  map(([data]) => data),
)
.subscribe(...);

编辑:如评论中所述， Observable.timer(N)只有一个参数会在发出一项后完成，所以不需要使用 take(1) .