/* jshint esnext: true */

​

var { of, combineLatest, fromEvent, from } = rxjs;

var { map, mergeMap, filter, publish, startWith, bufferWhen, take } = rxjs.operators;

​

console.clear();

​

var pausableBuffer = function(pauser) {

  return (source) => source.pipe(publish(_input => 

  combineLatest(_input, pauser.pipe(startWith(true))).pipe(

    map(([inp, pa]) => pa),

    filter(pa => pa),

    publish(_switch => _input.pipe(bufferWhen(() => _switch.pipe(take(1)))))

  )),

    mergeMap(e => from(e))

  );

}

​

const [event$, pause$] = ['event', 'pause'].map(s => fromEvent(document.getElementById(s), 'click'));

​

 event$.pipe(

   pausableBuffer(pause$.pipe(map((e, i) => i % 2 === 1))),

   map((e, i) => i)

 ).subscribe((e) => console.log(e));