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

前端之家收集整理的这篇文章主要介绍了angular – 如何创建具有延迟的observable前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

出于测试目的,我正在创建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格式.

猜你在找的Angularjs相关文章