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