是否有可能以某种方式同步调用异步离子存储？

Question

我正在尝试在 Angular2 HTTP 类之上创建一个用于使用 API 的类。主要的是我需要添加用户授权后可用的自定义身份验证标头。

主要问题是token存储在Ionic Storage模块中，只能异步获取，但我需要返回具体的类型......

export class APIRequest extends Http {

    private storage : Storage;

    constructor (backend: XHRBackend, options: RequestOptions) {
        super(backend, options);

        this.storage = new Storage;
    }

    request(url: string|Request, options?: RequestOptionsArgs): Observable<Response> {
        if (typeof url === 'string') {
            url = AppConfig.API_SERVER + url
        } else {
            url.url = AppConfig.API_SERVER + url.url
        }

        this.storage.get('authToken').then(token => {
            if (typeof url === 'string') {
                if (!options) {
                    options = {headers: new Headers()};
                }

                options.headers.set('Authorization', `Bearer ${token}`);
            } else {
                url.headers.set('Authorization', `Bearer ${token}`);
            }
            // Here I need to return 
        }, err => {
            // throw some error
        })

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

所以基本上我需要以某种方式将return super.request(url, options)... 放入存储的承诺中，并在我获得该令牌时返回。

Answer 1

几乎是重复的。 （没找到）

至少，答案可以应用于同一个问题。如果您想保留返回的Observable，则可以将您的Promise (this.storage.get) 转换为Observable。

之后，您可以使用flapMap 之类的运算符来返回super.request 的值。

（注意：编译器不明白它现在返回的是Response，所以将返回类型更改为Observable<any>（仍将返回Response））

export class APIRequest extends Http {

    private storage : Storage;

    constructor (backend: XHRBackend, options: RequestOptions) {
        super(backend, options);

        this.storage = new Storage;
    }
    // any return type (will return Response object but compiler doesn't understand that)
    request(url: string|Request, options?: RequestOptionsArgs): Observable<any> {
        if (typeof url === 'string') {
            url = AppConfig.API_SERVER + url
        } else {
            url.url = AppConfig.API_SERVER + url.url
        }

        //convert the Promise to an Observable
        val storageObservable = Observable.fromPromise(this.sotrage.get('authToken'));

        // rxjs/add/operator/mergeMap
        return storageObservable.flatMap(token => {
            if (typeof url === 'string') {
                if (!options) {
                    options = {headers: new Headers()};
                }

                options.headers.set('Authorization', `Bearer ${token}`);
            } else {
                url.headers.set('Authorization', `Bearer ${token}`);
            }
            // the value that will be returned
            return super.request(url, options).catch(this.catchAuthError(this));
        }, err => {
            // throw some error
        })


    }
}

有用的链接：

• 来自 reactivex.io 的文档。例如，对于 flatMap：http://reactivex.io/documentation/operators/flatmap.html
• Why we need to use flatMap?