Basic observable

OBSERVABLE.md

Basic observable

import Rx from 'rxjs/Rx';

const source$ = Rx.Observable(observer => {
    console.log('Creating observable');

    observer.next('Hello'); //emits value
    observer.complete(); //need to tell when the observer is complete
});

source$.subscribe(
    (x) => { // subscribing
        console.log(x);
    },
    (error) => { //error callback
        console.log(error);
    },
    () => { //callback to siganl completed
        console.log('completed');
    });

// Output
// Creating observable
// Hello completed
//