Tengo 2 observables que transmiten datos como resultado de una consulta de la base de datos, la cantidad de datos que emite cada uno es variable y puede ser diferente al otro. Estoy tratando de averiguar cómo puedo combinarlos para poder usar una sola suscripción y enviar los valores emitidos a dos matrices diferentes, por ejemplo.
let firstArray = []; let secondArray = []; const subscription = zip(firstObservable, secondObservable) .subscribe({ next([first, second]) { firstArray.push(first); secondArray.push(second); }, error(err) { console.log(err); }, complete() { console.log(firstArray); console.log(secondArray); } }); El problema con este ejemplo es que el uso de zip hace que solo capturen valores emitidos desde el observable más corto, por lo que si firstObservable emite 2 valores y secondObservable emite 10, al completar ambos arreglos tendrán una longitud de 2. Me disculpo si la pregunta es ambiguo en absoluto, soy bastante nuevo en el uso de observables y estoy luchando por comprenderlos por completo. Cualquier ayuda sería muy apreciada.
Puede usar toArray para recopilar todos los elementos emitidos en una matriz y forkJoin para esperar a que terminen ambos observables:
import { of, forkJoin } from 'rxjs'; import { toArray } from 'rxjs/operators'; const o1 = of(1,2,3,4,5); const o2 = of('a', 'b'); forkJoin([ o1.pipe(toArray()), o2.pipe(toArray()) ]).subscribe(console.log);