Angular7中如何使用Rxjs进行Rxjs异步请求操作？

本文共计832个文字，预计阅读时间需要4分钟。

Promise与RxJS处理异步对比：let promise=new Promise(resolve=> { setTimeout(()=> { resolve('---promise timeout---'); });});

Promise和RxJS处理异步对比Promise处理异步:letpromisenewPromise(resolve{setTimeout(()

Promise 和 RxJS 处理异步对比

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 的基本用法非常类似，除了一些关键词不同。