我有一系列的消息。每隔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) );
https://stackoverflow.com/questions/50687583
复制相似问题