小编Luc*_*ile的帖子

我正在使用Rx,并希望每隔1分钟定期执行一项任务.

我的任务是从一组URL中异步获取Feeds并且它正常工作:

var rssLinks = ["http://host1/rss.xml", "http://host2/rss.xml", "http://host3/rss.xml"];

// My Task
var task = Rx.Observable.from(rssLinks)
.flatMap(functions.fetchFeeds);

task.subscribe(function(feed) {
    console.log("\nFeed " + feed.title + ", " + feed.link);
});

所以.我已经阅读过Scheduler及其schedulePeriodic方法,但我不能定期执行我的任务.

var disposable = Rx.Scheduler.timeout.schedulePeriodic(
 60000, /* 1 minute */
 function () {
      // Execute My Task...        
 });

有任何想法吗？

提前致谢!