¡Codifiqué la siguiente muestra y todavía no puedo entender el resultado!
import { combineLatestAll, of, map } from 'rxjs'; const s1 = of(1, 2, 3).pipe( map(v1 => of(100, 101, 102, 103, 104).pipe( map(v2 => [v1,v2]) ) ), combineLatestAll() ); s1.subscribe(console.log);La salida es:
[ [ 1, 104 ], [ 2, 104 ], [ 3, 100 ] ] [ [ 1, 104 ], [ 2, 104 ], [ 3, 101 ] ] [ [ 1, 104 ], [ 2, 104 ], [ 3, 102 ] ] [ [ 1, 104 ], [ 2, 104 ], [ 3, 103 ] ] [ [ 1, 104 ], [ 2, 104 ], [ 3, 104 ] ]He mirado la salida durante mucho tiempo, pero todavía no puedo entender el comportamiento de este operador.
Antes de que entiendas combineLatestAll , analicemos el comportamiento de combineLatest .
Según el diagrama de mármol que se muestra aquí , si tenemos 2 flujos de datos, combineLatest "combina" los valores más recientes de los 2 flujos.
Es decir, de las 2 transmisiones a las que se ha suscrito, a menos que ambas comiencen a emitir datos, no verá ningún resultado.
Sin embargo, ¿qué pasaría si la primera transmisión ya se completó cuando comienza la segunda?
var c1 = of(5, 15, 25); var c2 = of(6, 16, 26); var s2 = combineLatest([c1,c2]); s2.subscribe(console.log) // Outputs = [25,6] [25,16] and [25, 26] En tal caso, el operador combineLatest tomará el último/último valor de la fuente 1 (25 en el ejemplo anterior) y luego comenzará a emitir una salida cuando comience la segunda transmisión (combinando el último/último valor de la fuente 1 y todos los valores entrantes de la fuente 2)
¿Qué pasaría si hubiera 3 fuentes? En este caso, combineLatest generará una salida solo cuando las 3 transmisiones hayan comenzado a generar una salida.
var c1 = of(5, 15, 25); var c2 = of(6, 16, 26); var c3 = of(7, 17, 27); var s2 = combineLatest([c1,c2, c3]); s2.subscribe(console.log) // Outputs = [25,26, 7] [25,26, 17] and [25, 26, 27]En el caso anterior, cuando el tercer observable comienza a emitir el valor, los otros 2 observables ya se han completado. Por lo tanto, la salida se parece a tomar el último/último valor de las primeras 2 fuentes y luego combinarlo con todos los valores del tercer observable.
El ejemplo anterior también se puede escribir como -
var s3 = of(c1, c2, c3).pipe(combineLatestAll()); s3.subscribe(console.log);En su pregunta original, está viendo exactamente el mismo comportamiento. Los primeros 2 observables tienen el último valor y luego se combinan con cada valor del último observable.