function makeObservable() {

    let startTime = performance.now();

    let duration = 1000;

    let from = 100;

    let to = 200;

    let distance = Math.abs(to-from);

    let next = (to - from) < 0;

    return Rx.Observable.generate(

        performance.now(),

        x => x <= startTime + duration,

        x => performance.now(),

        x => (x-startTime)/duration,

        Rx.Scheduler.animationFrame

    )

    .map(p => from + (p * (next ? -distance: distance)))

    .concat(Rx.Observable.of(to))

    .distinctUntilChanged()

    .last();

}

​

function onMemory() {

    for(let i=0; i<1000; i++) {

        console.log("create observable", i, makeObservable());

    }

}

​

let eventObs = Rx.Observable.fromEvent(document.querySelector("#memory"), "click");

let eventSubscriber = eventObs

    .subscribe( x => {

        setInterval( () => {

          onMemory();

        },1000);

    });

​