digamos que tienes 2 observables:
const obs1$: Observable<string[]> = this.getObs1$(); const obs2$: Observable<string[]> = this.getObs2$();quiero combinar estos 2 para que en la suscripción (o mapa rxjs) sepa cuál emitió los valores. No puedo usar combineLatest porque para el otro observable solo obtengo el último valor que emitió en algún momento.
No parece haber una solución puramente RxJS para esto (¡pero espero que alguien pueda demostrar que estoy equivocado al respecto!)
Podría usar una variable en el alcance externo para rastrear la emisión observable como solución alternativa
let trigger: TriggerEnum; const obs1$: Observable<string[]> = this.getObs1$() .pipe(tap(() => trigger = TriggerEnum.One)); const obs2$: Observable<string[]> = this.getObs2$() .pipe(tap(() => trigger = TriggerEnum.Two));; combineLatest(....).subscribe( // check trigger value );De los documentos como por si acaso: tenga en cuenta que combineLatest no emitirá un valor inicial hasta que cada observable emita al menos un valor
Puede usarmerge para combinar los dos observables en un solo observable. Luego, haga lo que sugirió @martin y mapee las emisiones de cada fuente en una pequeña estructura que le permita identificar la fuente:
const obs1$: Observable<number[]> = getNumbers(); const obs2$: Observable<string[]> = getLetters(); const combined$ = merge( obs1$.pipe(map(data => ({ source: 'obs1$', data }))), obs2$.pipe(map(data => ({ source: 'obs2$', data }))) ); combined$.subscribe( ({ source, data }) => console.log(`[${source}] data: ${data}`) ); // OUTPUT: // // [obs1$] data: 1 // [obs2$] data: A // [obs2$] data: A,B // [obs2$] data: A,B,C // [obs1$] data: 1,2 // [obs2$] data: A,B,C,D ...Aquí hay un pequeño ejemplo de StackBlitz .