Estoy trabajando en una aplicación Angular 2 y necesito orientación sobre cómo manejar los errores de autenticación de manera limpia.

Mi objetivo final es poder manejar de forma centralizada los errores de autenticación (específicamente 401 y 403) para cada solicitud Http .

Encontré esta pregunta muy útil para comenzar, sin embargo, estoy atascado en cuanto a la forma correcta de registrar mi controlador de errores para cada observable devuelto por mi implementación Http personalizada.

Aquí hay una muestra de lo que estoy trabajando actualmente:

 import { Injectable } from 'angular2/core'; import { Http, ConnectionBackend, Request, RequestOptions, RequestOptionsArgs, Response } from 'angular2/http'; import { Observable } from 'rxjs/Observable'; @Injectable() export class ClauthHttp extends Http { constructor(backend: ConnectionBackend, defaultOptions: RequestOptions) { super(backend, defaultOptions); } get(url: string, options ? : RequestOptionsArgs): Observable < Response > { var response = super.get(url, options); return this._handleSecurityResponse(response); } /* Other overrides omitted for brevity... */ private _handleSecurityResponse(response: Observable < Response > ): Observable < Response > { response.subscribe(null, (error: Response) => { // Do some nifty error handling here. }); return response; } }

La solución anterior "funciona" con un solo problema... Cada solicitud HTTP se realiza dos veces. Eso no es bueno.

¿Alguna guía sobre cómo hacer esto correctamente?

(Actualización) Código de trabajo

Según la información en la respuesta aceptada, aquí se muestra cómo se ve la clase en su forma de funcionamiento adecuado.

 import {Injectable} from 'angular2/core'; import {Http, ConnectionBackend, Request, RequestOptions, RequestOptionsArgs, Response} from 'angular2/http'; import {Observable} from 'rxjs/Observable'; import 'rxjs/add/operator/share'; @Injectable() export class ClauthHttp extends Http { constructor(backend: ConnectionBackend, defaultOptions: RequestOptions) { super(backend, defaultOptions); } get(url: string, options ? : RequestOptionsArgs): Observable < Response > { var response = super.get(url, options); return this._handleSecurityResponse(response); } /* Other overrides omitted for brevity... */ private _handleSecurityResponse(response: Observable < Response > ): Observable < Response > { var sharable = response.share(); sharable.subscribe(null, (error: Response) => { // Do some nifty error handling here. }); return sharable; } }