Como muestra la demostración, como dice el título
const { combineLatest, interval, of } = rxjs; const { first, last, sample, take, withLatestFrom } = rxjs.operators; const numbers = interval(1000); const takeFourNumbers = numbers.pipe(take(4)); takeFourNumbers.subscribe(x => console.log('Next: ', x)); setTimeout(()=>{ console.log('how can we get the latest value which is 1?'); takeFourNumbers.pipe(first()).subscribe(v=>console.log(v,'actual get')) },2500) // Logs: // Next: 0 // Next: 1 // how can we get the latest value which is 1? // Next: 2 // 0 actual get // Next: 3 <script src="https://cdn.jsdelivr.net/npm/rxjs@7.5.5/dist/bundles/rxjs.umd.js"></script>En mi caso, solo quiero obtener el valor más reciente y hacer un trabajo de una sola vez. ¿Cómo puedo hacerlo?
Estoy pensando si tenemos un operador como takeLatest() o latest() . Pero no encontré a nadie.
El problema se reduce a compartir el proveedor (fuente de datos) o los observables "Hot vs Cold", desea que el valor más reciente se comparta entre diferentes suscripciones, por lo que básicamente desea un observable caliente, el Observable devuelto por el operador de intervalo está frío, por lo que debe hacer hace calor y hacerlo es bastante simple:
const takeFourNumbers = numbers.pipe(take(4), shareReplay(1));ahora no importa cuántas veces te suscribas, todos los suscriptores compartirán el valor
editar: mi error, debería ser shareReplay para que le brinde el último valor emitido tan pronto como se suscriba, por lo que ahora debería obtener 1 de esa suscripción dentro de setTimeout