No estoy muy seguro de si estoy haciendo esto correctamente.
Tengo una function simple que tiene un argument que quiero usar dentro de un observable combineLatest . Luego se devuelve ese observable.
fn(arg) { return combineLatest([ observable..., observable..., ]).pipe( map(() => arg) ); }El problema aquí es que cuando la función se llama muchas veces, crea observables duplicados.
¿Cuál sería la solución adecuada? ¿Para hacer que el argumento también sea observable? Entonces, la función solo se llama una vez, pero devuelve el valor correcto cuando cambia el argumento.
La solución no es usar Observables esta manera. Usa un Subject para ese tipo de cosas:
readonly actionSubject = new Subject<unknown>(); ... ngOnInit(): void { this.actionSubject.pipe( switchMap(newValue => combineLatest([ observable..., observable..., ]).pipe(map(() => newValue)), ) ).subscribe(); } ... ngOnDestroy(): void { this.actionSubject.complete(); } Y en lugar del uso de su función en lugar de fn :
this.actionSubject.next(someNewValue); ¿Qué pasa aquí? SwitchMap detendrá su hilo antiguo y comenzará uno nuevo cada vez que tenga un valor nuevo. Esa es la solución.