const clicks$ = Rx.Observable.fromEvent(document, 'click')
  .mapTo('click')

const reset$ = new Rx.BehaviorSubject('');
const bufferUntil = reset$.switchMap(
  () => clicks$
        .scan((acc, curr) => ++acc, 0)
        .filter(x => x > 1)
        .observeOn(Rx.Scheduler.asap)
        .merge(clicks$.debounceTime(250))
  );


clicks$
  .buffer(bufferUntil)
  .do(() => reset$.next(''))
  .filter(x => x.length > 1)
  .subscribe(val => console.log(val));