是否有可能以某種方式同步調用異步Ionic Storage？

Question

我正嘗試在Angular2 HTTP類的頂部創建一個使用API​​的類。最主要的是我需要添加自定義的auth頭，這是在用戶授權後可用的。

的主要問題是該令牌存儲在從它只能異步得到的離子性存儲模塊，但我需要返回的特定類型....

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

接近成爲重複。 （Couln't找到它）

至少，答案可以應用於相同的問題。如果你想保持返回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?