Const// 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() { }
});
Exports the Observable class.