No estoy muy seguro de cómo formular esta pregunta, pero estoy tratando de combinar un evento con varios otros eventos, de manera que la canalización del evento compartido solo se calcule una vez (para evitar cálculos innecesarios o solicitudes de corte)

Aquí hay un ejemplo del problema que quiero resolver:

 import { fromEvent, combineLatest, map } from 'rxjs'; import Emitter from 'events' const emitter = new Emitter() const shared = fromEvent(emitter, 'shared') const specific1 = fromEvent(emitter, '1') const specific2 = fromEvent(emitter, '2') const pipe = shared.pipe( map(() => { const calculatedValue = Math.random() // This function is called twice, instead of once console.log(`calculation performed: ${calculatedValue}`) return calculatedValue }) ) /** * @param {import('rxjs').Observable<any>} observable */ const combine = (observable) => { combineLatest([pipe, observable]).subscribe(console.log) } combine(specific1) combine(specific2) console.log('Emitting shared event') emitter.emit('shared') // logs: "calculation performed: [random value] // logs: "calculation performed: [a different random value] console.log('Emitting event 1') emitter.emit('1') // uses the first random number console.log('Emitting event 2') emitter.emit('2') // uses the second random number

Los observables combinados primero y segundo ahora usan dos valores diferentes, aunque quiero que usen lo mismo. ¿Hay alguna manera de asegurarme de que la función de mapa solo se llame una vez, mientras sigo usando funciones rxjs (es decir, evitando escribir una variable con el valor calculado)?

Otro ejemplo que puedes ver aquí, usando botones html