BFE.devAI解答 - JavaScript 代码题
72. 实现Observable interval()

解题思路：

题目要求我们实现一个 creation operator interval()，它会创建一个 Observable，每隔一定时间就会产生一个新的 value，然后把这个 value 发射给 Subscriber。

为了实现这个 operator，我们可以利用 Observable.create() 来创建一个 Observable，然后再利用 setInterval() 来定时产生 value。

具体实现：

function interval(period) {  return Observable.create(function(observer) {    let n = 0;    const intervalId = setInterval(() => {      observer.next(n++);    }, period);    return function() {      clearInterval(intervalId);    }  });}

我们通过 Observable.create() 创建一个 Observable，传入一个函数，这个函数会接收一个 observer 参数。

然后，我们在函数中利用 setInterval() 定时产生 value，并通过 observer.next() 发射给 Subscriber。

最后，我们还需要返回一个函数，它会在 Observable 被取消订阅时执行，我们可以利用 clearInterval() 来清理定时器。

完整代码如下：

function Observable(subscribe) {  this._subscribe = subscribe;}Observable.prototype.subscribe = function(observer) {  const subscription = new Subscription();  this._subscribe({    ...observer,    subscription  });  return subscription;}Observable.create = function(subscribe) {  return new Observable(subscribe);}function Subscription() {  this.unsubscribe = function() {}}Subscription.prototype.add = function(sub) {  const originalUnsubscribe = this.unsubscribe;  this.unsubscribe = function() {    sub.unsubscribe();    originalUnsubscribe.call(this);  }}Subscription.create = function(unsubscribe) {  const subscription = new Subscription();  subscription.unsubscribe = unsubscribe;  return subscription;}function interval(period) {  return Observable.create(function(observer) {    let n = 0;    const intervalId = setInterval(() => {      observer.next(n++);    }, period);    return function() {      clearInterval(intervalId);    }  });}

测试代码：

interval(1000).subscribe(console.log);

运行结果：

0
1
2
3
4
5
6
.....