Angular - Refresh JWT Token (parallel calls)

Question

I have a question about the flow of refresh token.

I try to make a call this the token. The token is expired and make a second request to refresh the token. I'm taking the response and rerun the request with the new token.

Everything is perfect until i try to make multiple parallel requests with the same invalid token.

The problem is that if i make 3 parallel calls with the same token, then the first call make the token invalid for the other 2 calls..

Am I doing something wrong with the flow?

import {Injectable} from '@angular/core';
import {Request, XHRBackend, RequestOptions, Response, Http, RequestOptionsArgs, Headers} from '@angular/http';
import {Observable} from 'rxjs/Observable';
import {Router} from '@angular/router';
import 'rxjs/add/operator/catch';
import 'rxjs/add/observable/throw';
import {RefreshTokenService} from "../services/refreshToken.service";

@Injectable()
export class HttpService extends Http {

constructor(
    backend: XHRBackend,
    options: RequestOptions,
    private refreshTokenService?: RefreshTokenService,
    private router?: Router
) {
    super(backend, options);
}

request(url: string | Request, options?: RequestOptionsArgs): Observable<Response> {

    if (typeof url === 'string') {
        if (!options) {
            options = {headers: new Headers()};
        }
        this.setHeaders(options);
    } else {
        this.setHeaders(url);
    }

    return super.request(url, options).catch(this.catchErrors(url, options));
}

private catchErrors(url: string | Request, options?: RequestOptionsArgs) {
    return (res: Response) => {

        if (res.status === 401 || res.status === 403) {


            if ( this.refreshTokenService.wait === false ) {

                this.refreshTokenService.wait = true;
                return this.refreshTokenService.refreshToken(localStorage.getItem('JWToken'))
                    .flatMap((result: any) => {
                        // if got new access token - retry request
                        if (JSON.parse(result._body).token) {
                            localStorage.setItem('JWToken', JSON.parse(result._body).token);
                            this.setHeaders(url);
                            this.refreshTokenService.wait = false;
                            return this.request(url, options);
                        } else {
                            return Observable.throw(new Error('Can\'t refresh the token'));
                        }

                    })
            } else {
                // TODO... return this only if new token is ok
                this.setHeaders(url);
                return this.request(url, options);
            }
        } else {
            Observable.throw(res);
        }
    };
}

private setHeaders(objectToSetHeadersTo: Request | RequestOptionsArgs) {
    // add whatever header that you need to every request
    objectToSetHeadersTo.headers.set('Authorization', 'Bearer ' + localStorage.getItem('JWToken'));
}


}