//emit four strings

const example = Rx.Observable.of('WAIT','ONE','SECOND','Last will display');

/*

    Only emit values after a second has passed between the last emission, 

    throw away all other values

*/

const debouncedExample = example.debounce(() => Rx.Observable.timer(1000));

/*

    In this example, all values but the last will be omitted

    output: 'Last will display'

*/

const subscribe = debouncedExample.subscribe(val => console.log(val));