Rxjs与观察到的

问题描述：

大赤贫元素的数组后端环路我创建简单的数字排列，并使用rxjs管理UI和后端环路下面是我的代码：Rxjs与观察到的

var array100 = new Array(9703) 
    .fill('x') 
    .map((v, i) => i); 

Rx.Observable.from(array100) 
    .delayWhen(function(v){return Rx.Observable.timer(v*50)}) 
    .buffer(Rx.Observable.timer(250, 250)) 
    .subscribe(chunk => { 
    console.log('chunk ', chunk); 
    });

创建我试过这个示例应用程序后，把这个带到我的应用程序中，用一些大的abject元素数组来处理UI和后端循环。但是当我尝试使用它时，该数组可以被观察到，但它不会分块数组。它通过没有分块的方法。我也无法调试它..

这是如何在RxJS中实现的？

答

我建议你看看提供的运营商。您尝试创建的许多功能已经可用。

，用于延迟从阵列元件的发射可以使用： .flatMap(val => Rx.Observable.just(val).delay(50)/*ms*/)

对于分块您的阵列可以使用计数（如果定时不是问题）.bufferWithCount(50)/*elements per chunk */，定时.bufferWithTime(250/*ms*/)或两者组合（.bufferWithTimeOrCount(250 /*ms*/, 50 /*elements */)

Rxjs与观察到的

相关推荐