Angular 2 — обработка нескольких подписок на одном наблюдаемом

Я работаю над приложением Angular 2, и мне нужно руководство о том, как правильно обрабатывать ошибки аутентификации.

Моя конечная цель — иметь возможность централизованно обрабатывать ошибки аутентификации (в частности, 401 и 403) для каждого запроса Http.

Я нашел этот вопрос очень полезным для начала, однако я застрял как правильно зарегистрировать мой обработчик ошибок для каждого наблюдаемого, возвращаемого моей пользовательской реализацией Http.

Вот пример того, с чем я сейчас работаю:

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;
    }
}

Приведенное выше решение «работает» с одной заминкой... Каждый HTTP-запрос выполняется дважды. Это не хорошо.

Любое руководство о том, как правильно это сделать?

(Обновление) Рабочий код

Основываясь на информации в принятом ответе, вот как выглядит класс в правильно функционирующей форме.

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;
    }
}