Skip to content

Instantly share code, notes, and snippets.

@Yago

Yago/as-rxjs-observable.js

Last active May 2, 2017 07:46
Show Gist options
  • Save Yago/2b356900d8d8e34563dcc9b0cd616dd9 to your computer and use it in GitHub Desktop.
Save Yago/2b356900d8d8e34563dcc9b0cd616dd9 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
as-rxjs-observable.js
const listStream = Rx.Observable.from([1, 2, 3]);
const timeStream = Rx.Observable.interval(1000); // 1000ms
const promiseStream = Rx.Observable.fromPromise(fetch('ip.jsontest.com'));
const mergedStreams = Rx.Observable.merge(listStream, timeStream);
const emptyStream = Rx.Observable.empty();
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment