Distinguish clicks and multi clicks with RxJS

rx_multiclick.js

var tapStream = Rx.Observable.fromEvent(element, 'click');

// multi-tap logic
var multiTapStream = tapStream
    .buffer(function() { return tapStream.debounce(250); })
    .map(function(list) { return list.length; })
    .filter(function(x) { return x >= 2; });

// Same as above, but detects single taps
var singleTapStream = tapStream
    .buffer(function() { return tapStream.debounce(250); })
    .map(function(list) { return list.length; })
    .filter(function(x) { return x === 1; });

// Subscribe to both streams
multiTapStream.subscribe(function (numtaps) {
  console.log(numtaps+'x clicked !!!!!!');
});
singleTapStream.subscribe(function (numtaps) {
  console.log("clicked !!!!!!");
});

// When we are done !
singleTapStream.dispose();
multiTapStream.dispose();