已解決430363個問題，去搜搜看，總會有你想問的

如何在完成 Rxjs Observable 之前等待在 subscribe 內部定義的異步方法？

首頁猿問如何在完成 Rxjs...

如何在完成 Rxjs Observable 之前等待在 subscribe 內部定義的異步方法？

JavaScript

瀟瀟雨雨 2021-12-02 15:40:50

讓我們看下面的代碼：myObservable.subscribe({ next: async () => { await something(); }, complete: () => { console.log('All async task are comlpeted'); }});問題是console.log在最后一個next被觸發后被調用，但我希望在最后一個something()完成后調用它。有沒有辦法做到這一點？我指定我myObservable自己使用new Obsercable(observer => ...). 所以可以修改。

查看完整描述

1 回答

臨摹微笑

TA貢獻1982條經驗獲得超2個贊

我會 a) 堅持 observable 配方，并將承諾轉換為 observable，或者 b) 堅持承諾/異步等待模式，并將 observable 轉換為承諾。坦率地說，我不知道如何成功地混合這兩者。

基于 Rx 的解決方案：

import { from } from 'rxjs';

import { finalize } from 'rxjs/operators';

myObservable.pipe(

switchMap(() => from(something()),

finalize(() => console.log('All async task are comlpeted')),

).subscribe(someFunction);

反對回復 2021-12-02

1 回答
0 關注
308 瀏覽

關注

添加回答

舉報

0/150

提交

取消

亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

熱搜

最近搜索清空

如何在完成 Rxjs Observable 之前等待在 subscribe 內部定義的異步方法？

如何在完成 Rxjs Observable 之前等待在 subscribe 內部定義的異步方法？

1 回答

添加回答

如何在完成 Rxjs Observable 之前等待在 subscribe 內部定義的異步方法？