Promise和RxJS处理异步对比

Posted 2020-11-22 zhx119

Promise 处理异步:

let promise = new Promise(resolve => { setTimeout(() => {

 

resolve(‘---promise timeout---‘); }, 2000);

});
promise.then(value => console.log(value));

 

RxJS 处理异步:

import {Observable} from ‘rxjs‘;

 

let stream = new Observable(observer => { setTimeout(() => {

observer.next(‘observable timeout‘); }, 2000);

});
stream.subscribe(value => console.log(value));

 

从上面列子可以看到 RxJS 和 Promise 的基本用法非常类似，除了一些关键词不同。Promise 里面用的是 then() 和 resolve()，而 RxJS 里面用的是 next() 和 subscribe()。