trato de obtener el último valor de un observable. el código de ejemplo es
// RxJS v6+ import { lastValueFrom, Subject } from 'rxjs'; import { scan } from 'rxjs/operators'; async function main() { const subject = new Subject(); const example = subject.pipe( scan((acc, curr) => { return Object.assign({}, acc, curr); }, {}), ); const subscribe = example.subscribe((val) => console.log('Accumulated object:', val), ); subject.next({ name: 'Joe' }); subject.next({ age: 30 }); subject.next({ favoriteLanguage: 'JavaScript' }); console.log('+++++++++++++'); const resp = await lastValueFrom(example); console.log(resp); console.log('end'); } main() .catch((e) => { console.error(e); }) .finally(async () => { console.log('final'); });la salida es
➜ npns-service git:(mr/master/658) ✗ ts-node prisma/test.ts Accumulated object: { name: 'Joe' } Accumulated object: { name: 'Joe', age: 30 } Accumulated object: { name: 'Joe', age: 30, favoriteLanguage: 'JavaScript' } +++++++++++++No puedo recibir el mensaje de salida de resp.
¿Cómo puedo obtener el valor de respuesta del ejemplo Observable?
Actualice su código para completar su observable:
setTimeout(() => { // setTimeout is just a simple way to use JS's event loop subject.next({ name: 'Joe' }); subject.next({ age: 30 }); subject.next({ favoriteLanguage: 'JavaScript' }); subject.complete(); // signal that our observable is done emitting // subject.next(something) here would do // nothing, the observable is complete }, 0); console.log('+++++++++++++'); const resp = await lastValueFrom(example); console.log(resp); console.log('end');Si no completa un observable, en lo que respecta a su tiempo de ejecución, aún puede emitir algo más en un minuto, 5 horas, el próximo año, ¿quién sabe? Debe haber alguna condición que desencadene la finalización.
Un pequeño aparte: arrojé el código que emite sobre su tema en el bucle de eventos para que el código que sigue pueda await . De lo contrario, su sujeto se completaría sincrónicamente antes de que se ejecutara ese código.
Haga de example un observable que recuerde (buffer) la última emisión. Luego, simplemente use take(1) para leer el valor almacenado en el búfer.
const subject = new Subject(); const example = subject.pipe( scan((acc, curr) => Object.assign({}, acc, curr), {}), shareReplay(1) ); example.subscribe(val => console.log('Accumulated object:', val) ); subject.next({ name: 'Joe' }); subject.next({ age: 30 }); subject.next({ favoriteLanguage: 'JavaScript' }); console.log('+++++++++++++'); const resp = await lastValueFrom(example.pipe(take(1)); console.log(resp); console.log('end');