Promise和Observable的映射

Posted 2022-10-27 samwu

前言

1. promise解决了嵌套地狱的问题，Observable解决了promise只有一个结果，和不可以取消的问题。
2. 使用的是rxjs6版本。
3. 这篇文章是方便使用Observable的API替换Promise的API。

正常用法

promise
.then(result => )
.catch(error => )
.finally(() => );

observable.subscribe(
  result => ,
  error => ,
  ()=>,  // finally
);

then

promise
.then(result => )
.then(result => )
.then(result => )

import  concat  from 'rxjs';
concat(observable0,observable1,observable2).subscribe(
  result => ,
  error => ,
  ()=>,  // finally
);

Promise.all

Promise.all([promise0, promise1]).then((result)=>);

import  forkJoin  from 'rxjs';
forkJoin([observable0, observable1]).subscribe(result => );

Promise.race

Promise.race([promise0, promise1]).then((result)=>);

import  race  from 'rxjs/observable/race';
race([observable0, observable1]).subscribe(result => );