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
//
Last active
June 23, 2020 06:28
-
-
Save jpalala/072b178c153f95fabcd4fd2b69a5815a to your computer and use it in GitHub Desktop.
Basic observable
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment