如何将 promise 与 observable 混合？

Question

我遇到了 promise 和 observables 的问题。我有一些使用 Promise 在包中定义的 http 请求。在我的其余代码中，我将 observables 用于各种事情，包括其他 http 调用。在一个特定部分中，我正在检查用户的不记名令牌是否已过期，如果是，我将获得一个新令牌，然后继续进行其余的通话。

if (!token || token.exp < Math.round((new Date()).getTime() / 1000)) {
  from(this._store.refreshBearerToken())
    .pipe(flatMap(resp => {
       let newToken = resp.data;
       newToken.exp = (new Date()).getTime() / 1000 + newToken.expires_in;
       localStorage.setItem('token', JSON.stringify(newToken))

       options = options || {};
       options.headers = new HttpHeaders({
         "Authorization": `${newToken.token_type} ${newToken.access_token}`,
         "Content-Type": "application/json"
        });
       return this._http$.request<T>(method, url, options as Object).pipe(share());
     }));
}

Bearer Token方法：

async refreshBearerToken() {
    const response = await this._q2.sources.requestExtensionData({
        route: "refreshBearerToken"
    });
    console.log(response);
    return response;
}

由于this._store.refreshBearerToken 返回一个承诺，我将调用包装在from 中以将其转换为可观察对象。这可以编译，但是当它运行时我得到“无法读取未定义的属性'管道'”。

如何将此 promise 转换为 observable，以便我可以刷新令牌，然后继续进行其余的调用？

编辑：

我正在通过import { Observable, from } from "rxjs"; 导入from。

所以，我认为错误来自.pipe(flatMap(resp =>... 行，但我错了。错误来自调用它的方法。

GetInitialLinkList(): Observable<Institution[]>
{
    let base = { 'MemberId': localStorage.getItem('memberId') };
    let ins = localStorage.getItem("initialInstitutionList");
    if (ins)
    {
        return of(JSON.parse(ins));
    }
    return this._settingsService.get().pipe(
        flatMap(settings =>
        {
            this._settings = settings;
            return this._api.request<Institution[]>("Post", `${this._settings.mea}/GetInitialLinkList`, { body: base })
                .pipe(
                    retry(1),
                    catchError(this.handleError)
                )
                .pipe(flatMap(instList =>
                {
                    localStorage.setItem("initialInstitutionList", JSON.stringify(instList));
                    return of(instList);
                }))
        }));
}

这是在我的组件中订阅的：

private GetLinkList()
{
    this.showWaiting.emit(true);
    this._data.GetInitialLinkList().subscribe((result) =>
    {
        this.initialList = result;
        this.showWaiting.emit(false);
    });
}

根据 Brandon 所说的（我忘了返回 /facepalm...）我添加了返回，所以我有 return from(this._store.refreshBearerToken()) 这将我的错误更改为

ERROR Error Code: undefined
Message: You provided an invalid object where a stream was expected. You can provide an Observable, Promise, Array, or Iterable.
defaultErrorLogger @ core.js:6014

Answer 1

您能否显示实际错误以及发生错误的代码行？同时显示您在何处以及如何导入from。

我注意到你的代码 sn-p 没有返回它通过from(...).pipe(...) 建立的可观察对象，也没有订阅它。这可能有助于展示您的代码如何实际使用这个 observable。