将承诺转化为可观察的

Question

我试图把头围在可观察物上。我喜欢可观测技术解决开发和可读性问题的方式。如我所读，好处是巨大的。HTTP和集合上的可观察对象似乎很简单。我如何将类似的东西转换为可观察的模式。这是从我的服务组件提供身份验证的。我希望它可以像Angular2中的其他HTTP服务一样工作-支持数据，错误和完成处理程序。firebase.auth().createUserWithEmailAndPassword(email, password)  .then(function(firebaseUser) {    // do something to update your UI component    // pass user object to UI component  })  .catch(function(error) {    // Handle Errors here.    var errorCode = error.code;    var errorMessage = error.message;    // ...  });在这里的任何帮助将不胜感激。我唯一的替代解决方案是创建EventEmitter。但是我想这是在服务部分做事的一种糟糕方法

Answer 1

如果您使用的是RxJS 6.0.0：

import { from } from 'rxjs';

const observable = from(promise);

Answer 2

尝试这个：

import { Observable } from "rxjs/Observable";

var subscription = Observable.fromPromise(

    firebase.auth().createUserWithEmailAndPassword(email, password)

);

subscription.subscribe(firebaseUser => /* Do anything with data received */,

                       error => /* Handle error here */);

您可以在此处找到对fromPromise运算符的完整参考。