added more benchmarks, updated existing from RxJS 5

Author: martinsik

benchmark/bufferWithCount/bufferWithCount.php

@@ -0,0 +1,9 @@
+<?php
+
+use Rx\Observable;
+
+return function() use ($dummyObserver) {
+    Observable::range(0, 25)
+        ->bufferWithCount(5)
+        ->subscribe($dummyObserver);
+};

benchmark/distinct/distinct.php

@@ -2,8 +2,12 @@
 
 use Rx\Observable;
 
-return function() use ($dummyObserver) {
-    Observable::range(1, pow(10, 3))
+$source = array_map(function($val) {
+    return $val % 3;
+}, range(0, 25));
+
+return function() use ($source, $dummyObserver) {
+    Observable::fromArray($source)
         ->distinct()
         ->subscribe($dummyObserver);
 };

benchmark/filter/filter.php

@@ -3,9 +3,12 @@
 use Rx\Observable;
 
 return function() use ($dummyObserver) {
-    Observable::range(1, pow(10, 3))
+    Observable::range(0, 50)
         ->filter(function($value) {
             return $value % 2 == 0;
         })
+        ->filter(function($value) {
+            return $value % 10 == 0;
+        })
         ->subscribe($dummyObserver);
 };

benchmark/skipLast/skipLast.php

@@ -0,0 +1,9 @@
+<?php
+
+use Rx\Observable;
+
+return function() use ($dummyObserver) {
+    Observable::range(0, 500)
+        ->skipLast(50)
+        ->subscribe($dummyObserver);
+};

benchmark/takeLast/takeLast.php

@@ -0,0 +1,9 @@
+<?php
+
+use Rx\Observable;
+
+return function() use ($dummyObserver) {
+    Observable::range(0, 500)
+        ->takeLast(50)
+        ->subscribe($dummyObserver);
+};

benchmark/zip/zip.php

@@ -0,0 +1,11 @@
+<?php
+
+use Rx\Observable;
+
+return function() use ($dummyObserver) {
+    Observable::range(0, 25)
+        ->zip([Observable::range(0, 25)], function($a, $b) {
+            return $a + $b;
+        })
+        ->subscribe($dummyObserver);
+};