• Empleos
  • Sobre nosotros
  • profesionales
    • Inicio
    • Empleos
    • Cursos y retos
    • Preguntas
    • Profesores
  • empresas
    • Inicio
    • Publicar vacante
    • Nuestro proceso
    • Precios
    • Pruebas Online
    • Nómina
    • Blog
    • Comercial
    • Calculadora de salario

0

127
Vistas
Cómo evitar devolver un observable dentro de una promesa

Estoy usando AngularFire para administrar usuarios dentro de mi aplicación. Todavía estoy aprendiendo sobre observables y rxjs.

Estoy tratando de llamar al método signInWithEmailAndPassword , que devuelve una promesa, y recuperar un documento de una colección.

En mi servicio obtengo el documento usando este método:

 getDbUser(uid): Observable<User> { return this.angularFirestore.collection<User>(USERS).doc(uid).valueChanges() }

y entro como usuario con:

 login(user: User) { // sign in con email e password return this.angularFireAuth.signInWithEmailAndPassword(user.email, user.password) .then((result) => { if(result.user?.uid) { // get user doc return this.getDbUser(result.user.uid); } return null; }); }

Con este código, llamar al método de inicio de sesión requiere resolver una promesa y luego suscribirse al observable, así:

 this.userService.login(this.loginUser) .then((userObs) => { userObs.subscribe((user) => { console.log(user); }); })

Realmente me gustaría evitar esto, pero no estoy seguro de cómo hacerlo. Intenté usar el operador RxJs toPromise :

 login(user: User) { // sign in con email e password return this.angularFireAuth.signInWithEmailAndPassword(user.email, user.password) .then((result) => { if(result.user?.uid) { // recupero l'utente dal db return this.getDbUser(result.user.uid).toPromise(); } return null; }); }

pero de alguna manera esto no funciona (la promesa nunca se resuelve).

almost 3 years ago · Juan Pablo Isaza
3 Respuestas
Responde la pregunta

0

La razón por la que toPromise() no funciona porque el observable permanece abierto. Use el primer operador o, si usa una versión posterior de rxjs, firstValueFrom . Lea más sobre esto en Conversion to Promises de la documentación de rxjs.

Dado que está utilizando valueChanges en lugar de get , entonces tal vez su intención sea mantener abierto el observable. Si ese es el caso, lo mejor que puede hacer es convertir el inicio de sesión en un observable usando from .

 login(user: User) { return from(this.angularFireAuth.signInWithEmailAndPassword(user.email, user.password)).pipe( switchMap(res => (res.user.uid) ? this.getDbuser(res.user.uid) : of(null)) ); }
almost 3 years ago · Juan Pablo Isaza Denunciar

0

El primer comentario es la respuesta correcta:

Puede agregar .pipe(first()) antes .toPromise "

almost 3 years ago · Juan Pablo Isaza Denunciar

0

Si desea informar a cualquier consumidor observable que un usuario acaba de iniciar sesión solo después de que signInWithEmailAndPassword () haya regresado, me gustaría marcar un asunto y suscribirme al usuario $ de cualquier consumidor de servicio.

 private userSubject$:Subject<string>=new Subject<string>(); public user$:Observable<string>=this.userSubject$.asObservable(); login(user: User) { // sign in con email e password return this.angularFireAuth.signInWithEmailAndPassword(user.email, user.password) .then((result) => { if(result.user?.uid) { // recupero l'utente dal db return this.userSubject$.next(result.user.uid); } return null; });

} y desde fuera usarás el servicio:

 this.userService.login(this.loginUser); this.userService.user$.subscribe(user=>console.log);
almost 3 years ago · Juan Pablo Isaza Denunciar
Responde la pregunta
Encuentra empleos remotos

¡Descubre la nueva forma de encontrar empleo!

Top de empleos
Top categorías de empleo
Empresas
Publicar vacante Precios Nuestro proceso Comercial
Legal
Términos y condiciones Política de privacidad
© 2025 PeakU Inc. All Rights Reserved.

Andres GPT

Recomiéndame algunas ofertas
Necesito ayuda