agrupador-observables

Servicio para Angular >6 que permite agrupar varios observables en un único observable, que emite cuando todos sus observables agrupados han emitido o han lanzado un error. A diferencia de soluciones como forkJoin() o Promise.all(), un error en un observable no cancela las suscripciones a los demás.

Instalación

npm install agrupador-observables

Uso en Angular

Primero se debe importar el módulo en un módulo de la aplicación:

...
import { AgrupadorObservablesModule } from 'agrupador-observables';
...

@NgModule(
  imports: [
    ...
    AgrupadorObservablesModule
  ]
)

Para usar el servicio, hay que inyectarlo en un constructor:

...
import { AgrupadorObservablesService } from 'agrupador-observables';
...

constructor(private agrupadorObs: AgrupadorObservablesService) { }

Y suscribirse al método allPeticiones() pasándole un array de observables:

this.agrupadorObs.allPeticiones([obs1, obs2, obs3]).subscribe(
  mensaje => console.log(mensaje),
  err => console.error(err)
)

El mensaje que emite por defecto el observable es la cadena 'cargado'. Para configurar el mensaje:

this.agrupadorObs.configMensaje({ subject: 'api', msj: 'api-cargada' });