Convertir solicitudes paginadas en una secuencia Observable con RxJs
Tengo un servicio que devuelve datos en páginas. La respuesta a una página contiene detalles sobre cómo consultar la página siguiente.
Mi enfoque es devolver los datos de respuesta y luego concat inmediatamente una llamada diferida a la misma secuencia observable si hay más páginas disponibles.
function getPageFromServer(index) {
// return dummy data for testcase
return {nextpage:index+1, data:[1,2,3]};
}
function getPagedItems(index) {
return Observable.return(getPageFromServer(index))
.flatMap(function(response) {
if (response.nextpage !== null) {
return Observable.fromArray(response.data)
.concat(Observable.defer(function() {return getPagedItems(response.nextpage);}));
}
return Observable.fromArray(response.data);
});
}
getPagedItems(0).subscribe(
function(item) {
console.log(new Date(), item);
},
function(error) {
console.log(error);
}
)
Este debe ser el enfoque incorrecto, porque en 2 segundos obtienes:
throw e;
^
RangeError: Maximum call stack size exceeded
at CompositeDisposablePrototype.dispose (/Users/me/node_modules/rx/dist/rx.all.js:654:51)
¿Cuál es el enfoque correcto para la paginación?