通过上一章的代码,理解了RxJs的基本工作机制。这次学习一下,RxJs如何不断的产生数据。
const onSubscribe = observer => {
let number = 1;
const handle = setInterval( ()=>{
// number就是发布者提供给订阅者的数据
observer.next(number++);
},1000);
};
通过上一章的代码,理解了RxJs的基本工作机制。这次学习一下,RxJs如何不断的产生数据。
const onSubscribe = observer => {
let number = 1;
const handle = setInterval( ()=>{
// number就是发布者提供给订阅者的数据
observer.next(number++);
},1000);
};