javascript - rxjs 订阅 onerror 绑定(bind)

Question

我正在使用 angular2/rxjs，并且很难理解 .subscribe() 的 onerror 回调的有用性。我见过的每个示例都只是打印到控制台，但是，如果我想做其他事情(例如让另一个服务处理错误)怎么办？仅调用 this.otherservice.handleError 无法正确绑定(bind) this。所以我需要像 this.otherservice.handleError.bind(this.otherservice) 那样调用它。这是预期的还是我错过了什么？

@Injectable
export class OtherService {
    public foo: Subject<string>;
    constructor() {
        this.foo = new Subject<string>();
    }
    handleError(error: any) {
        this.foo.next(error);
    }
}


@Injectable
export class MyService {
    constructor(private http: Http, private otherservice: OtherService) {}
    get() {
        this.http.get('www.foo.com').subscribe(
            () => 'success',
            this.otherservice.handleError
        )
    }
}

谢谢

Answer 1

基本上，当你使用闭包进行订阅时，它会转换为以下形式:

observer = {
  next: onNextFn,
  error: onErrorFn,
  complete: onCompleteFn
}

所以当你输入:

 .subscribe(
    () => 'success',
    this.otherservice.handleError
 )

这意味着:

{
  next: () => 'success',
  error: this.otherservice.handleError
}

所以this上下文将是observer对象。您需要绑定(bind)上下文来维护这些函数的正确上下文。