我正在使用 RxViz 来模拟每 1 秒发生的不同动作。当我尝试时
Rx.Observable.create(obs => {
obs.next([1, 2, 3]); // or could be ['aaa', 'bbbb', 'ccc']
obs.complete();
}).delay(1000);
或者我自己使用 console.log
它一直同时显示三个数字1、2、3
有一篇关于同样问题的帖子，但没有一个答案对我有用。我正在使用 Rx 最新版本 6
How can I create an observable with a delay
[编辑] 数组可以包含任何东西，如数字、字符串或任何对象
【问题讨论】：
标签： rxjs
如果您想延迟每个值（例如延迟 1 秒），您可以执行以下操作：
Rx.Observable.create(obs => {
obs.next([1, 2, 3]);
obs.complete();
})
.pipe(
// make observable to emit each element of the array (not the whole array)
mergeMap((x: [any]) => from(x)),
// delay each element by 1 sec
concatMap(x => of(x).pipe(delay(1000)))
)
.subscribe(x => console.log(x));
}
这里我没有修改你创建的 observable 的内部结构。相反，我只是采用您的 observable 并应用适当的操作来实现您似乎期望的结果。
【讨论】：
concatMap。一旦事情发生，of 运算符不会获取数组并解构它。 from 运营商可以。之后，您需要应用第二个 concatMap 将数组中的每个值转换为 observable 并应用延迟
这个通过稍微修改@siva636的回答来工作
Rx.Observable.create(obs => {
obs.next(1);
obs.next(2);
obs.next(3);
obs.complete();
}.concatMap(x=>Rx.Observable.of(x) .delay(1000) )
【讨论】：
这是我的解决方案（非常干净）
const fakeData = [1,2,3]
loadData$() {
return from(fakeData).pipe(
concatMap(item => of(item).pipe(
delay(1000)
)),
);
}
【讨论】：
这是一种基于其他响应的简洁方式。
from([...Array(10).keys()]).pipe(
concatMap(x => of(x).pipe(delay(1000)))
).subscribe(y => console.log(y))
【讨论】：
在这里，您在一个可观察的发射中发射 all 数组。 [1,2,3]。
您只需将该发射延迟 1000 毫秒。但发射仍然是一。
即使我们单独发射每个值，延迟函数也只会应用于第一个发射。其他人会马上来：
Rx.Observable.create(obs => {
var arr = [1, 2, 3];
arr.forEach(item => obs.next(item));
obs.complete();
}).delay(1000);
create 构造函数没有魔法。如果我们希望每x 时间发送一次：
我们可以创建一个发出这些值的间隔（取自learnrxjs）
import { Observable } from 'rxjs/Observable';
/*
Increment value every 1s, emit even numbers.
*/
const evenNumbers = Observable.create(function(observer) {
let value = 0;
const interval = setInterval(() => {
observer.next(value);
value++;
}, 1000);
return () => clearInterval(interval);
});
【讨论】：