如何將Fetch API響應轉換爲RxJS Observable？

Question

我如何轉換任何Fetch API返回RxJS Observable？ RxJS.fromPromise有幫助嗎？

Answer 1

退房這個article

var result = Rx.Observable.fromPromise(fetch('http://myserver.com/')); 
result.subscribe(x => console.log(x), e => console.error(e)); 

Answer 2

由於獲取調用返回尚未包含響應對象的另一個承諾，我會去創建自己觀察到的：

import { Observable } from 'rxjs'; 
 
import 'rxjs/add/operator/map'; 
 

 
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*/);

Answer 3

有庫文庫rxjs-fetch，但我建議不要使用它，而是寫：

const getData = (url, params) => { 
    return fetch(url, params).then(r => { 
     return r.ok ? r.text() : Promise.reject(`${r.statusText} ${r.status}`) 
    }) 
} 

const getDataObserver = (url, params) => Rx.Observable.fromPromise(getData()) 

（在你的NodeJS需要node-fetch）