代码之家 › 专栏 › 技术社区 › MgSam Brad M

扁平化承诺

rxjs typescript

MgSam Brad M · 技术社区 · 6 年前

我有一个函数可以执行以下操作:

async foo() {
    await doSomething();

    return getObservableFromSomewhereElse();
}

问题是 await 使签名成为 Promise<Observable<T>> .因为我已经返回了一个可观察的,所以我只想将承诺折叠到可观察的中,以便签名 Observable<T> 。

注: doSomething() 必须发生在之前 getObservableFromSomewhereElse() 。

我想 Observable.defer() 可能会有帮助,但我不确定。

关于如何使此函数返回的任何想法 可观察(<T> ?

1 回复 | 直到 6 年前

udalmik 6 年前

如评论线程中所述-您可以离开 foo 功能为 async 并重用其承诺,从而实现与

async function foo() {
    await doSomething();
}

function bar() {
    return Observable
       // emits one value from resolved promise
       .fromPromise(foo())
       // maps it to your observable stream
       .flatMap(() => getObservableFromSomewhereElse());
}

推荐文章

Fahad Subzwari · 我不能用rxjs过滤器过滤记录?

2 年前

Fazla Elahi Md Jubayer · 在rxjs中使用管道内的两个concatmap时,如何提取订阅块内的结果

2 年前

Irakli · 我想以角度显示id相似的数据

3 年前

Akash · 当BehaviorSubject发出两次真值时,使ngOnChange被激发

6 年前

Shamshiel · 将rxjs升级到6后,类型“Observable”上不存在属性“map”

6 年前

Corey Cole Roberto Tyley · 使用RxJS 6。x WebSocketSubject客户端

6 年前

gog · 如何观察rxjs中的属性更改?

6 年前

jesdynf · 在继续之前,如何使角度拦截器延迟?

6 年前

Sean Ivins · 角度2+HttpIntercept:在返回intercept函数之前,等待来自服务器的令牌

6 年前

Kevin Kalitowski · RxJs 6:从Observable获取ConnectableObservable

6 年前