简而言之,尝试将一个非常大的数组块分成10个块并等待5秒,然后发出下一个10.
这是我现在拥有的
Rx.Observable.from(hugeArray).bufferCount(10).delay(5000) //want to wait 5 secs.flatMap(e => e) // this needs to go after to flatten the array,buffer spits out arrays of entries.flatMap( (data,index) => Rx.Observable.create(observer => {// going to render stuff hereobserver.onNext(data)observer.onCompleted();})).subscribe(val => console.log('Buffered Values:',val));
只是尝试在5秒内做10个块,只能做一个初始延迟然后它发出其余的.
最佳答案
您的链只是立即发出一切,然后安排每个块同时开始等待5秒,所以在同一时刻所有块的延迟已经过去了.
解决方案可以是使用concatMap()逐个订阅每个Observable.
Rx.Observable.from(hugeArray).bufferCount(10).concatMap(data => Rx.Observable.of(data).delay(5000)).flatMap(e => e) // or mergeAll() or concatAll().flatMap( (data,index) => Rx.Observable.create(observer => {// going to render stuff hereobserver.onNext(data);observer.onCompleted();})).subscribe(val => console.log('Buffered Values:',val));
