Variable ExtendedObservableConst

Exports the Observable class.

Deprecated

the observable proposal is 'dead'

Example

// create observable, which ticks all 100 msec
var observable = new Observable(observer => {
    let counter = 0;
    let t = setInterval(() => {
        observer.next(++counter);
    }, 100);
    // return a cleanup function, is called if subscriber unsubscribes
    return () => {
        clearInterval(t);
    };
});

// now somebody can subscribe
var subscription = observable.subscribe({ next(value) { console.debug(value); } });

// to unlink do:
subscription.unsubscribe();
Copy

Example

// use object observable definition
observable.subscribe({
    next(value) { },
    error(e) { },
    complete() { }
});
Copy

Example

// use method definition, first argument is next, second error and third complete
observable.subscribe(
    (value)=> {},
    (e)=> {},
    ()=> {}
);
Copy

See

• TC39 Proposal
• TC39 Proposal Github