时间戳

首页 > 解决方案 > 合并一个 Observable 和 Promise 到一个对象

angular - 合并一个 Observable 和 Promise 到一个对象

问题描述

如何合并来自 Observables 的两个函数返回（一个返回一个承诺，一个返回一个对象）？我如何链接结果？这样做的正确方法是什么？

functionReturnObservable(
        element: SomeInterface,
    ): Observable<Interface> {
        return this.someService.fn2ReturnObservable().pipe(
            map((result) => {
                // the promise function needs to merge with the funcObject
                const updatedElement= from(this.fnPromise(element))
                return this.funObject(updatedElement, result);
            }),
        );
    }

funcObject(
        updatedElement: Readonly<Interface>,
        listItems: IInterface[],
    ): IObject {
        // returns a revised Object
        return updatedObjects;
    }

async fnPromise(elements: IElements): Promise<SomeInterface> {
        // ... some other stuff 
        let result;
        result.Name = "John"
        if( elements.References) {
            await this.otherService
            .lookup(elements.References)
            .then((result) => {
                result.Secret= result;
            });
        }
        return result;
    }

标签： angularrxjsrxjs6rxjs-observables

解决方案

使用更高阶的 observable：

functionReturnObservable(
    element: SomeInterface,
): Observable<Interface> {
    return this.someService.fn2ReturnObservable().pipe(
        switchMap((result) => {
            // switchMap will subscribe to inner observable, use map to combine results
            return from(this.fnPromise(element)).pipe(
              map(updatedElement => this.funObject(updatedElement, result)));
        }),
    );
}

这可能会在尝试使用 async / await 时有所突破，它与 observables 不能很好地混合。如果它仍然损坏，请删除 async / await 东西并返回承诺。

推荐阅读