chore(test): add micro-benchmark performance test for bufferCount ope…

…rator

perf/micro/current-thread-scheduler/operators/buffer-count.js

@@ -0,0 +1,20 @@
+var RxOld = require("rx");
+var RxNew = require("../../../../index");
+
+module.exports = function (suite) {
+
+  var oldBufferCountWithCurrentThreadScheduler = RxOld.Observable.range(0, 25, RxOld.Scheduler.currentThread).bufferWithCount(5);
+  var newBufferCountWithCurrentThreadScheduler = RxNew.Observable.range(0, 25).bufferCount(5);
+
+  return suite
+    .add('old bufferCount with current thread scheduler', function () {
+      oldBufferCountWithCurrentThreadScheduler.subscribe(_next, _error, _complete);
+    })
+    .add('new bufferCount with current thread scheduler', function () {
+      newBufferCountWithCurrentThreadScheduler.subscribe(_next, _error, _complete);
+    });
+
+  function _next(x) { }
+  function _error(e){ }
+  function _complete(){ }
+};

perf/micro/immediate-scheduler/operators/buffer-count.js

@@ -0,0 +1,20 @@
+var RxOld = require("rx");
+var RxNew = require("../../../../index");
+
+module.exports = function (suite) {
+
+  var oldBufferCountWithImmediateScheduler = RxOld.Observable.range(0, 25, RxOld.Scheduler.immediate).bufferWithCount(5);
+  var newBufferCountWithImmediateScheduler = RxNew.Observable.range(0, 25).bufferCount(5);
+
+  return suite
+    .add('old bufferCount with immediate scheduler', function () {
+      oldBufferCountWithImmediateScheduler.subscribe(_next, _error, _complete);
+    })
+    .add('new bufferCount with immediate scheduler', function () {
+      newBufferCountWithImmediateScheduler.subscribe(_next, _error, _complete);
+    });
+
+  function _next(x) { }
+  function _error(e){ }
+  function _complete(){ }
+};

perf/micro/index.js

@@ -13,6 +13,7 @@ Observable.from([
         require("./immediate-scheduler/observable/range"),
         require("./immediate-scheduler/observable/throw"),
 
+        require("./immediate-scheduler/operators/buffer-count"),
         require("./immediate-scheduler/operators/combine-latest"),
         require("./immediate-scheduler/operators/concat"),
         require("./immediate-scheduler/operators/concat-all"),
@@ -44,6 +45,7 @@ Observable.from([
         require("./current-thread-scheduler/observable/range"),
         require("./current-thread-scheduler/observable/throw"),
 
+        require("./current-thread-scheduler/operators/buffer-count"),
         require("./current-thread-scheduler/operators/combine-latest"),
         require("./current-thread-scheduler/operators/concat"),
         require("./current-thread-scheduler/operators/concat-all"),