Estoy aprendiendo RxJS y no puedo entender la diferencia entre escanear y mergeScan de RxJS. Ambos ejemplos:
const click$ = fromEvent(document, 'click'); const one$ = click$.pipe(mapTo(1)); const seed = 0; const count$ = one$.pipe( mergeScan((acc, one) => of(acc + one), seed), ); count$.subscribe(x => console.log(x));... y
const click$ = fromEvent(document, 'click'); const one$ = click$.pipe(mapTo(1)); const seed = 0; const count$ = one$.pipe(scan((acc, one) => (acc + one), seed)); count$.subscribe((x) => console.log(x));... produce los mismos resultados (número de clics del mouse), entonces, ¿cuál es la diferencia? ¿Son necesarios ambos?
mergeScan puede ejecutar observable en el interior, pero el scan no puede, un caso de uso típico sería algo así como un desplazamiento infinito que desea llamar al punto final continuamente
const click$ = fromEvent(loadmore, 'click'); const count$ = click$.pipe( mergeScan((acc, one) => httpGetPage(acc.pageCusor+1).pipe(map(res=>{ return {pageCusor:pageCusor++,contet.concat(res)} })), {pageCursor:0,content:[]}), ); Para examinar, puede probar console.log en su ejemplo de scan e intentar devolver un of(value) , mostrará Observable
const count$ = one$.pipe(scan((acc, one) => of(acc + one), seed)); count$.subscribe((x) => console.log(x));Como dice la documentacion
Es como escanear, pero los Observables devueltos por el acumulador se fusionan con el Observable exterior.
El tipo de retorno de la función del acumulador de mergeScan debe ser ObservableInput
mergeScan 1st realiza la operación de scan y luego se suscribe al observable interno que es devuelto por la función del acumulador y lo almacena acc y emite lo mismo.
si reemplaza mergeScan` con escaneo en esta línea e inicia sesión como a continuación
scan((acc, one) => { console.log("acc ",acc); return of(acc + one); }, seed), Verá el valor acc almacenado como un Observable . El registro será así acc Observable {_subscribe: ƒ}
Pero si usa maergeScan , veremos el registro como acc 1
Entonces, la moraleja de la historia es que si su función de acumulador devuelve observable, debe usar mergeScan de lo contrario, el scan estará bien