简而言之,尝试将一个非常大的数组块分成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 here
observer.onNext(data)
observer.onCompleted();
}))
.subscribe(val => console.log('Buffered Values:',val));
只是尝试在5秒内做10个块,只能做一个初始延迟然后它发出其余的.
最佳答案
您的链只是立即发出一切,然后安排每个块同时开始等待5秒,所以在同一时刻所有块的延迟已经过去了.
原文链接：https://www.f2er.com/js/429123.html解决方案可以是使用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 here
observer.onNext(data);
observer.onCompleted();
}))
.subscribe(val => console.log('Buffered Values:',val));
