简而言之,尝试将一个非常大的数组块分成10个块并等待5秒,然后发出下一个10.
这是我现在拥有的
@H_404_8@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 here observer.onNext(data) observer.onCompleted(); })) .subscribe(val => console.log('Buffered Values:',val));
只是尝试在5秒内做10个块,只能做一个初始延迟然后它发出其余的.
最佳答案
您的链只是立即发出一切,然后安排每个块同时开始等待5秒,所以在同一时刻所有块的延迟已经过去了.
解决方案可以是使用concatMap()逐个订阅每个Observable.
@H_404_8@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 here observer.onNext(data); observer.onCompleted(); })) .subscribe(val => console.log('Buffered Values:',val));
