如何链接rxjs observable

Question

我来自 Angular1，并且像链接承诺一样，我希望有类似的行为。

我在 someclass 中有一个方法：-

{.........
      doLogin (username, password) {
            .......
            .......
            return this.http.get(api).subscribe(
                    data => {.....}, //enters here
                    err => {.....}
        }

然后我调用这个方法：-

 someclass.doLogin(username, password).subscribe(
           data => { }, //Not getting called
            err => { }
 }

正如我在上述代码中作为 cmets 所提到的，订阅不会在调用者类中被调用。

关于如何做到这一点的任何建议？

Answer 1

实际上，您返回的是subscribe 方法的对象。这是订阅而不是可观察的。因此，您将无法（再次）订阅返回的对象。

Observables 允许基于 observable 算子构建数据流链。这取决于你想做什么。

如果您只是简单地触发某事或从您的服务设置服务属性，您可以使用do 运算符和catch 一个进行错误处理：

doLogin (username, password) {
  .......
  .......
  return this.http.get(api).do(data => {
    .....
    // Call something imperatively
  })
  .catch(err => {
    .....
    // Eventually if you want to throw the original error
    // return Observable.throw(err);
  });
}

不要忘记包含这些运算符，因为 Rxjs 没有开箱即用地包含它们：

import 'rxjs/add/operator/do';
import 'rxjs/add/operator/catch';

或全局（所有运算符）：

import 'rxjs/Rx';

查看相关问题：

• Angular 2, best practice to load data from a server one time and share results to components
• Angular 2 HTTP GET with TypeScript error http.get(...).map is not a function in [null]