Tengo un método getFolders() que devuelve un Observable .
function getFolders() { const data = [ { name: "Photos", files: of(2) // observable }, { name: "Document", files: of(5) // observable }, { name: "Videos", files: of(2) // observable } ]; return of(data); } Necesito obtener el recuento total de archivos con 9 ( 2+5+2 ). Escribí una función para hacer el trabajo con el siguiente uso,
getFileCount.subscribe( totalCount => console.log(totalCount) ); // expects to log 9La implementación es,
function getFileCount() { return getFolders() .pipe( switchMap( folderData => folderData.map( data => data.files ) ), // Above switchMap returns [ Observable, Observable, Observable ] // Now I need to complete all Observable and get flatten result like [2,5,2] mergeAll(), // I though the mergeAll will resolve all Observables and return the value switchMap( countArray => { // expecting all values in a single array [2,5,2] // but it executes for each value like // 2 // 5 // 2 console.log(countArray); return countArray.reduce(function(a, b) { return a + b; }, 0); }) ); }Use forkJoin para envolver la matriz observable y eliminar mergeAll() , ejecutará cada observable dentro
switchMap( folderData => forkJoin(folderData.map( data => data.files ) )),