Skip to content

Instantly share code, notes, and snippets.

@jpalala
Last active June 23, 2020 06:28
Show Gist options
  • Save jpalala/072b178c153f95fabcd4fd2b69a5815a to your computer and use it in GitHub Desktop.
Save jpalala/072b178c153f95fabcd4fd2b69a5815a to your computer and use it in GitHub Desktop.
Basic observable

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
// 
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment