rxjs - 如何将 Fetch API 响应转换为 RxJS Observable？

Question

我如何转换任何内容 Fetch API返回 RxJS Observable ?是否RxJS.fromPromise帮助？

Answer 1

当 fetch 调用返回另一个包含响应对象的 promise 时，我将创建您自己的 observable:

import { Observable } from 'rxjs';

const data$ = Observable.create(observer => {
  fetch('http://server.com')
    .then(response => response.json()) // or text() or blob() etc.
    .then(data => {
      observer.next(data);
      observer.complete();
    })
    .catch(err => observer.error(err));
});

data$.subscribe(data => /*do something with data*/);