suppress pause when end comes back to back

rx

var Rx = require('rx');
var pauses = new Rx.Subject();
var ends = new Rx.Subject();

pauses.
    flatMap(function () {
        return Rx.Observable.amb(
            Rx.Observable.timer(1000).
                map(function () { return true }),
            ends.map(function () { return false })
        ).take(1);
    }).
    filter(Boolean).
    forEach(
        console.log.bind(console, 'next'),
        console.log.bind(console, 'error'),
        console.log.bind(console, 'complete')
    );

pauses.onNext('pause');
setTimeout(function () {
    ends.onNext('end');
}, 1500);