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); 
}); 

鍵入我的智能手機因此未經測試。