RxJs可观察到从拉动

Question

的支持，我很新的RxJs（而不是JS说好），并有一个很难找到我怎么能写的Rx相当于

var arr = []; 

var getData = function() { 
    $.get("/newlines", {}, function (data) { 
     data.push.apply(arr, data); 
     setTimeout(getData, 1000); 
     console.log(arr); 

    },'json'); 

}; 

setTimeout(getData, 1000); 

我在想什么是Observable，它会从异步回调中产生项目。

Answer 1

var arr = []; 
Rx.Observable.interval(1000) 
    .selectMany(Rx.Observable.fromPromise($.get("/newlines", {}))) 
    .subscribe(function(data) {   
     data.push.apply(arr, data); 
     console.log(arr); 
}); 

键入我的智能手机因此未经测试。