ExtendedObservable: any = Observable

Exports the Observable class.

the observable proposal is 'dead'

// create observable, which ticks all 100 msec
const observable = new Observable((observer: any) => {
let counter = 0;
const t = setInterval(() => {
observer.next(++counter);
}, 100);
// return a cleanup function, is called if subscriber unsubscribes
return () => {
clearInterval(t);
};
});
// now somebody can subscribe
const subscription = observable.subscribe({
next(value: number) {
console.debug(value);
}
});
// to unlink do:
subscription.unsubscribe();
// use object observable definition
observable.subscribe({
next(value) { },
error(e) { },
complete() { }
});
// use method definition, first argument is next, second error and third complete
observable.subscribe(
(value)=> {},
(e)=> {},
()=> {}
);