Proyecta cada emisión de la fuente a un Observable interno que se fusiona con el Observable resultante únicamente si el Observable interno anterior se ha completado
💡 Se debe utilizar exhaustMap si se quiere ignorar los Observables internos mientras no se haya completado el Observable interno anterior
OperatorFunction<T, ObservedValueOf<O> | R>: Un Observable que contiene Observables proyectados de cada elemento de la fuente. Ignora los Observables proyectados que comiencen antes de que el Observable proyectado actual se haya completado.
Descripción
Proyecta cada valor a un Observable interno, y 'aplasta' todos estos Observables internos mediante el operador exhaust.
Retorna un Observable que aplica una función a cada uno de los elementos emitidos por el Observable fuente, donde dicha función retorna un Observable interno. Cuando se proyecta cada elemento de la fuente a un Observable, el Observable resultante comienza a emitir los elementos emitidos por el Observable interno. Sin embargo, exhaustMap ignora todos los Observables internos nuevos si el Observable interno anterior no se ha completado. Una vez se complete, exhaustMap se suscribirá y 'aplastará' el siguiente Observable interno y repetirá el proceso.
Ejemplos
Obtener 3 películas de Studio Ghibli al hacer click en el botón
Si hay alguna petición en curso, los clicks serán ignorados (cada petición tiene un retraso de 5s para poder observar este efecto.)
import { delay, exhaustMap, map, mergeAll, take } from"rxjs/operators";import { fromEvent } from"rxjs";import { ajax } from"rxjs/ajax";constclick$=fromEvent(document.getElementById("ghibliButton"),"click");functiongetGhibliFilms() {returnajax.getJSON("https://ghibliapi.herokuapp.com/films").pipe(delay(5000),mergeAll(),map(({ title }) => title),take(3) );}// Obtener 3 películas de Studio Ghibli al hacer click en el botón. Si hay alguna petición en curso, los clicks serán ignorados (cada petición tiene un retraso de 5s para poder observar este efecto.)
click$.pipe(exhaustMap((_) =>getGhibliFilms())).subscribe(console.log);// Salida: (Primer click) (click ignorado) (click ignorado) (5s) Castle in the Sky, Grave of the Fireflies, My Neighbor Totoro
Ejemplo de la documentación oficial
Ejecuta un temporizador con cada click, únicamente si no hay ningún temporizador activo