javascript - RxJs Observable 从支持拉动

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

在我的智能手机上输入，因此未经测试。