RxJS Playground

A blank canvas to play / experiment with RxJS: https://github.com/Reactive-Extensions/RxJS

by Jeancarlo Fontalvo

HTML

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/4.0.7/rx.all.js"></script>

JavaScript

/* ### Observable from Create ###
const observable = Rx.Observable.create( observer => {
	observer.next( "Hello!" );
  observer.next( "How's it going?" );
});


*/

/* ### Observable from Event ###
const observable = Rx.Observable.fromEvent( document, 'click' );
*/

/* ### Observable from Promise ###
const promise = new Promise( (resolve, reject) => {
	setTimeout( () => {
  	resolve( 'resolved' );
  }, 1000);
} );

const observable = Rx.Observable.fromPromise( promise );
*/

/* ### Observable from Timer ###
const observable = Rx.Observable.timer( 1000 );
*/

/* ### Observable from Timer ###
const observable = Rx.Observable.interval( 1000 );
*/
observable.subscribe( int => print( int + 1 ) );

function print( value ) {
	let el 				= document.createElement( "p" );
  el.innerHTML 	= value;
  document.body.appendChild( el );
}