Angular / RxJS:如何生成延迟值序列？
Angular / RxJS:如何生成延迟值序列？
提问于 2018-06-05 03:32:17
我有一系列的消息。每隔N秒，我需要从Observable发出一条消息。
我尝试了下一个代码。第一条消息是延迟发出的，我在订阅者中得到了它，但按顺序生成其他消息已停止。如果我删除.delay()方法调用，我会得到所需的序列，订阅者会对每条消息做出反应，但没有消息之间的时间间隔。我怎么才能修复它？
import { Observable } from 'rxjs/Observable';
import { fromArray } from 'rxjs/observable/fromArray';
import 'rxjs/add/operator/delay';
@Injectable({
providedIn: 'root'
})
export class MessageService {
constructor() { }
getIncomingMessagesStream(): Observable<string> {
const messageTimeout = 2000;
const messages = ['Hi there!', 'How are you?', 'That is awesome :)'];
return fromArray(messages)
.delay(messageTimeout);
}
}订阅者示例：
messageService.getIncomingMessagesStream()
.subscribe(message => console.log('New incoming message ', message) );回答 1
Stack Overflow用户
回答已采纳
发布于 2018-06-05 03:38:24
您需要使链仅在前一项延迟后才发射下一项：
import { from, of } from 'rxjs';
import { delay, concatMap } from 'rxjs/operators';
...
return from(messages).pipe(
concatMap(item => of(item).pipe(delay(messageTimeout))),
);顺便说一句，你组合了RxJS <5.5和RxJS >= 5.5风格(管道式和原型风格的操作符)。最好只使用RxJS 5.5，避免使用import 'rxjs/add/operator/concatMap';。请参阅https://github.com/ReactiveX/rxjs/blob/master/doc/pipeable-operators.md
2019年7月:针对RxJS 6进行了更新。
查看现场演示：https://stackblitz.com/edit/rxjs5-hibr4m?file=index.ts
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/50687583
复制相关文章
相似问题