function getAggregatedDebouncedStream(subject, options, scheduler) {
    return subject
        .filter(function(x) {
            return options.get("watchEvents").indexOf(x.event) > -1;
        })
        .buffer(subject.debounce(options.get("reloadDebounce"), scheduler));
}
@param subject
@param options
@param scheduler