Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 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));
- 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));
Add Comment
Please, Sign In to add comment