tengo este observable
createMyRecord(): Observable<myRecord> { return of(TEMPLATE_DB).pipe( mergeMap((template) => doTask(template)), mergeMap(() => EMPTY) ); }lo llamo con
await createMyRecord().toPromise();.toPromise() está en desuso, por lo que me gustaría cambiar la llamada con lastValueFrom():
await lastValueFrom(createMyRecord()); pero recibo el siguiente error:
EmptyError no elements in sequenceACTUALIZACIÓN: por ahora, resuelto con:
await lastValueFrom(createMyRecord()).catch((err) => { if (err instanceof EmptyError) { log.info(OK"); } });pero hay una solución mejor?
Si y no.
En su caso mergeMap(_ => EMPTY) se asegurará de que su observable se complete sin emitir un valor. Las promesas se resuelven en un valor o fallan. Entonces, lo único que se puede hacer aquí que cumple con las especificaciones es arrojar un error.
Puedes eludir esto emitiendo algo. Por ejemplo, aquí emito null después de que se completa la fuente:
createMyRecord(): Observable<myRecord> { return of(TEMPLATE_DB).pipe( mergeMap((template) => doTask(template)), mergeMap(() => EMPTY), s => concat(s, of(null as myRecord)) ); } Ahora su promesa se resolverá con un null una vez que el observable se complete con éxito.
En lugar de cambiar su código, puede cambiar cómo lo llama. De esta manera, no necesita preocuparse por cómo interactúan los Observables y las Promises .
En lugar de await lastValueFrom(createMyRecord()); escribe:
createMyRecord().subscribe();lastValueFrom ahora toma un parámetro de configuración como su segundo parámetro, y puede especificar un valor predeterminado que se emitirá si el observable está vacío:
await rxjs.lastValueFrom(observableThing, {defaultValue: "oh no - empty!"})