Skip to content

Instantly share code, notes, and snippets.

@wKoza
Last active May 22, 2017 10:00
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
Star You must be signed in to star a gist
Save wKoza/849472658dfe2d0e0aaffb5710de18a6 to your computer and use it in GitHub Desktop.
import {Observable} frpm 'rxjs/Observable';
import 'rxjs/Rx';
const myObservable = new Observable((observer) => {
const datasource = new DataSource();
datasource.ondata = (e) => observer.next(e);
datasource.onerror = (err) => observer.error(err);
datasource.oncomplete = () => observer.complete();
return () => {
datasource.destroy();
};
});
myObservable.subscribe(value => { console.log(value) },
error => { console.log(error) },
() => { console.log('fin') }
);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment