RxJでアクションを実行した後、オブザーバブルを再試行するにはどうすればよいですか？

Angular 2とRxJSを使用して、APIレイヤーからデータを取得しています。HTTPリクエストを処理するために作成した基本サービスがあります。次のコードは私のサービス内でこれを行います：

protected apiGet(uri: string): Observable<HttpMappedResponse<T>> {
    return this.mapAndHandle<T>(this.http.get(uri));
}

private mapAndHandle<T>(observable: Observable<Response>): Observable<HttpMappedResponse<T>> {
    const o = observable
        .map(res => {
            const data = res.json() || {};
            const mappedResponse = new HttpMappedResponse<T>(res, data);
            // Retrieve page information from HTTP headers
            mappedResponse.pageInfo = new PageInfo(res.headers);
            return mappedResponse;
        })
        .share();

    o.subscribe(null, e => this.errorService.handleHttpResponse(e));
    return o;
}

これはうまく機能し、電話をかけるときに必要なすべてのデータを取得しますapiGet()。私が今やろうとしていることは次のとおりです。

• HTTPリクエストを送信する
• 特定の文字列で401エラーが返された場合：
  • 別のURLに別のリクエストを送信する
  • 別のサービスを更新する
  • 元のリクエストを再試行してください
  • （次に、可能な無限の再試行を処理するロジックを追加します）
• そうしないと
  • 元のhttpエラーを再スローします
• エラーをキャプチャして処理します

.catch（）、. retryWhen（）、. map（）、および.flatMapTo（）を使用しようとしましたが、成功しませんでした。最も近いのは次のとおりです。

enum HttpVerb {
    Put,
    Post,
    Get,
    Delete
}

private mapAndHandle<T>(uri: string, type: HttpVerb): Observable<HttpMappedResponse<T>> {
    const restObservable = this.getRestObservable(uri, type);

    const o = restObservable
        .map(res => this.mapToHttpMappedResponse<T>(res))
        .catch((error, sourceObservable) => {
            const data = error.json() || {};

            if (error.status === 401 && data.Message === 'Token expired') {
                console.log('Retrying');
                // Refresh the expired auth token
                const refreshToken = this.authService.userData.RefreshToken;
                console.log(refreshToken);

                this.authService
                    .refresh(new RefreshRequestModel(refreshToken))
                    .subscribe(x => null);

                // Retry original
                return this
                    .getRestObservable(uri, type)
                    .map(x => this.mapToHttpMappedResponse(x));
            }
            throw error;
        })
        .share();

    o.subscribe(null, e => {
        this.errorService.handleHttpResponse(e);
    });
    return o;
}

private mapToHttpMappedResponse<T>(res: Response): HttpMappedResponse<T> {
    console.log('Attempt ' + Date.now());
    const data = res.json() || {};
    const mappedResponse = new HttpMappedResponse<T>(res, data);
    // Retrieve page information from HTTP headers
    mappedResponse.pageInfo = new PageInfo(res.headers);
    return mappedResponse;
}

しかし、これは私に正しい結果を与えません。

これを行うために使用できる演算子はありますか？tryWhen（）が最も論理的であるように見えますが、私はRxJで混乱し続けています！