angular – 如何创建具有延迟的observable

发布时间：2020-12-17 07:58:58 所属栏目：安全来源：网络整理

导读：题出于测试目的,我正在创建Observable对象来替换用Http实际http调用返回的observable. 我的observable是使用以下代码创建的： fakeObservable = Observable.create(obs = { obs.next([1,2,3]); obs.complete();}); 问题是,这种可观察性立即发出.有没有办法

题

出于测试目的,我正在创建Observable对象来替换用Http实际http调用返回的observable.

我的observable是使用以下代码创建的：

fakeObservable = Observable.create(obs => {
  obs.next([1,2,3]);
  obs.complete();
});

问题是,这种可观察性立即发出.有没有办法为其排放添加自定义延迟？

跟踪

我试过这个：

fakeObservable = Observable.create(obs => {
  setTimeout(() => {
    obs.next([1,3]);
    obs.complete();
  },100);
});

但它似乎没有用.

使用以下导入：

import {Observable} from 'rxjs/Observable';
import 'rxjs/add/observable/of';
import 'rxjs/add/operator/delay';

尝试这个：

let fakeResponse = [1,3];
let delayedObservable = Observable.of(fakeResponse).delay(5000);
delayedObservable.subscribe(data => console.log(data));

更新：RXJS 6

上述解决方案在较新版本的RXJS(例如角度)中不再起作用.

所以场景是我有一个项目数组要检查API. API只接受一个项目,我不想通过一次发送所有请求来终止API.所以我需要在Observable流上定时释放项目,两者之间有一点延迟.

使用以下导入：

import { from,of } from 'rxjs';
import { delay } from 'rxjs/internal/operators';
import { concatMap } from 'rxjs/internal/operators';

然后使用以下代码：

const myArray = [1,3,4];

from(myArray).pipe(
    concatMap( item => of(item.pipe ( delay( 1000 ) )) )
).subscribe ( timedItem => {
    console.log(timedItem)
});

它基本上为数组中的每个项创建一个新的“延迟”Observable.可能有很多其他的方法,但这对我来说很好,并符合’新’RXJS格式.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!