Angular 2 - Shared Observable - 第二个订阅错误回调失败

Question

我们有一个处理视图管理的组件和一个管理服务器交互和数据解析的服务。

服务 postForm 方法返回一个共享的 observable 给组件。 服务订阅它，组件订阅它。

成功后，服务回调方法会处理一些数据 同样在成功或错误时，组件回调会更新视图中的反馈。

问题：组件错误回调仅在服务订阅函数包含错误回调时触发。

我是否使用了错误的模式？ 如果不是，为什么我在两个订阅函数中都需要错误回调来让组件之一工作？

谢谢

组件：

    onSubmit(): void {
    this.service.postForm().subscribe(
        () => this.onSuccessfulPost(),
        ()=>this.onErrorPost()
    );
}

服务：

    postForm() {

    //Code here assembles url and body variables

    this.currentObservable = this.http.post(url, body)
        .map((response: Response) => this.parseResponse(response))
        .catch((err: Response) => this.onHttpError(err)).share();
    this.currentObservable.subscribe(
        (response: any) => this.onSuccessfulPost(response),
        () => {return}  //WITHOUT THIS LINE COMPONENT CALL FAILS
    );
    return this.currentObservable;
}

Answer 1

我不确定为什么没有错误回调它不起作用，两个观察者应该相互独立。但就模式而言，我会避免订阅服务并将订阅留给组件。如果您需要在服务中做一些独立于响应的逻辑，那么您可以使用do 运算符。

postForm() {
    //Code here assembles url and body variables

    this.currentObservable = this.http.post(url, body)
        .map((response: Response) => this.parseResponse(response))
        .catch((err: Response) => this.onHttpError(err))
        .do(response => this.onSuccessfulPost(response));
    return this.currentObservable;
}

由于您只有 1 个观察者（订阅者），因此您不再需要共享