chore(distinct): add perf tests for distinct

- Current performance is sub-par, 60% of the speed of Rx 4's operator.

perf/micro/immediate-scheduler/operators/distinct-keyselector.js

@@ -0,0 +1,19 @@
+var RxOld = require('rx');
+var RxNew = require('../../../../dist/cjs/Rx.KitchenSink');
+
+module.exports = function (suite) {
+ var source = Array.from({ length: 25 }, function (_, i) { return { value: i % 3 }; });
+ var _old = RxOld.Observable.fromArray(source).distinct(function (x) { return x.value; });
+ var _new = RxNew.Observable.fromArray(source).distinct(function (x) { return x.value; });
+
+ function _next(x) { }
+ function _error(e) { }
+ function _complete() { }
+ return suite
+ .add('old count with immediate scheduler', function () {
+ _old.subscribe(_next, _error, _complete);
+ })
+ .add('new count with immediate scheduler', function () {
+ _new.subscribe(_next, _error, _complete);
+ });
+};

perf/micro/immediate-scheduler/operators/distinct.js

@@ -0,0 +1,19 @@
+var RxOld = require('rx');
+var RxNew = require('../../../../dist/cjs/Rx.KitchenSink');
+
+module.exports = function (suite) {
+ var source = Array.from({ length: 25 }, function (_, i) { return i % 3; });
+ var _old = RxOld.Observable.fromArray(source).distinct();
+ var _new = RxNew.Observable.fromArray(source).distinct();
+
+ function _next(x) { }
+ function _error(e) { }
+ function _complete() { }
+ return suite
+ .add('old count with immediate scheduler', function () {
+ _old.subscribe(_next, _error, _complete);
+ })
+ .add('new count with immediate scheduler', function () {
+ _new.subscribe(_next, _error, _complete);
+ });
+};