rxjs fetch

gistfile1.txt

const storiesEndpoint = 'https://hacker-news.firebaseio.com/v0/topstories.json?limit=10';
const storiesFetch$ = Rx.Observable.fromPromise(fetch(storiesEndpoint));
const decoder = new TextDecoder();

const storyIds$ = storiesFetch$
  .map(response => response.body)
  .map(body => body.getReader())
  .switchMap((reader) => {
    return Rx.Observable.create((observer) => {
      function search() {
        reader.read().then((data) => {
          if(!data.done) {
            observer.next(data.value);
            return search();
          }
          observer.complete();
        })
      }
      search();
    })
  }).subscribe((val) => {
    console.log('val >', val);
  })