Updated benchmarks for 2.x

Author: davidwdan

benchmark/bufferWithCount/bufferWithCount.php

@@ -3,7 +3,7 @@
 use Rx\Observable;
 
 return function() use ($dummyObserver) {
-    Observable::range(0, 25)
+    Observable::range(0, 25, \Rx\Scheduler::getImmediate())
         ->bufferWithCount(5)
         ->subscribe($dummyObserver);
 };

benchmark/bufferWithCount/bufferWithCount_eventloop.php

@@ -1,16 +1,9 @@
 <?php
 
 use Rx\Observable;
-use Rx\Scheduler\EventLoopScheduler;
-use React\EventLoop\StreamSelectLoop;
 
-$loop = new StreamSelectLoop();
-$scheduler = new EventLoopScheduler($loop);
-
-return function() use ($dummyObserver, $scheduler, $loop) {
-    Observable::range(0, 25)
+return function() use ($dummyObserver) {
+    Observable::range(0, 25, \Rx\Scheduler::getAsync())
         ->bufferWithCount(5)
-        ->subscribe($dummyObserver, $scheduler);
-
-    $loop->run();
+        ->subscribe($dummyObserver);
 };

benchmark/distinct/distinct.php

@@ -7,7 +7,7 @@
 }, range(0, 25));
 
 return function() use ($source, $dummyObserver) {
-    Observable::fromArray($source)
+    Observable::fromArray($source, \Rx\Scheduler::getImmediate())
         ->distinct()
         ->subscribe($dummyObserver);
 };

benchmark/distinct/distinct_eventloop.php

@@ -1,20 +1,13 @@
 <?php
 
 use Rx\Observable;
-use Rx\Scheduler\EventLoopScheduler;
-use React\EventLoop\StreamSelectLoop;
-
-$loop = new StreamSelectLoop();
-$scheduler = new EventLoopScheduler($loop);
 
 $source = array_map(function($val) {
     return $val % 3;
 }, range(0, 25));
 
-return function() use ($source, $dummyObserver, $scheduler, $loop) {
-    Observable::fromArray($source)
+return function() use ($source, $dummyObserver) {
+    Observable::fromArray($source, \Rx\Scheduler::getAsync())
         ->distinct()
-        ->subscribe($dummyObserver, $scheduler);
-
-    $loop->run();
+        ->subscribe($dummyObserver);
 };

benchmark/filter/filter.php

@@ -3,7 +3,7 @@
 use Rx\Observable;
 
 return function() use ($dummyObserver) {
-    Observable::range(0, 50)
+    Observable::range(0, 50, \Rx\Scheduler::getImmediate())
         ->filter(function($value) {
             return $value % 2 == 0;
         })

benchmark/filter/filter_eventloop.php

@@ -1,21 +1,14 @@
 <?php
 
 use Rx\Observable;
-use Rx\Scheduler\EventLoopScheduler;
-use React\EventLoop\StreamSelectLoop;
 
-$loop = new StreamSelectLoop();
-$scheduler = new EventLoopScheduler($loop);
-
-return function() use ($dummyObserver, $scheduler, $loop) {
-    Observable::range(0, 50)
+return function() use ($dummyObserver) {
+    Observable::range(0, 50, \Rx\Scheduler::getAsync())
         ->filter(function($value) {
             return $value % 2 == 0;
         })
         ->filter(function($value) {
             return $value % 10 == 0;
         })
-        ->subscribe($dummyObserver, $scheduler);
-
-    $loop->run();
+        ->subscribe($dummyObserver);
 };

benchmark/run.php

@@ -28,14 +28,14 @@
 }
 
 
-Observable::just($files)
+Observable::just($files, \Rx\Scheduler::getImmediate())
     ->doOnNext(function(array $files) {
         printf("Benchmarking %d file/s (min %ds each)\n", count($files), MIN_TOTAL_DURATION);
         printf("script_name - total_runs (single_run_mean ±standard_deviation)\n");
         printf("==============================================================\n");
     })
     ->concatMap(function($files) { // Flatten the array
-        return Observable::fromArray($files);
+        return Observable::fromArray($files, \Rx\Scheduler::getImmediate());
     })
     ->doOnNext(function($file) {
         printf('%s', pathinfo($file, PATHINFO_FILENAME));

benchmark/skipLast/skipLast.php

@@ -3,7 +3,7 @@
 use Rx\Observable;
 
 return function() use ($dummyObserver) {
-    Observable::range(0, 500)
+    Observable::range(0, 500, \Rx\Scheduler::getImmediate())
         ->skipLast(50)
         ->subscribe($dummyObserver);
 };

benchmark/skipLast/skipLast_eventloop.php

@@ -1,16 +1,9 @@
 <?php
 
 use Rx\Observable;
-use Rx\Scheduler\EventLoopScheduler;
-use React\EventLoop\StreamSelectLoop;
 
-$loop = new StreamSelectLoop();
-$scheduler = new EventLoopScheduler($loop);
-
-return function() use ($dummyObserver, $scheduler, $loop) {
-    Observable::range(0, 500)
+return function() use ($dummyObserver) {
+    Observable::range(0, 500, \Rx\Scheduler::getAsync())
         ->skipLast(50)
-        ->subscribe($dummyObserver, $scheduler);
-
-    $loop->run();
+        ->subscribe($dummyObserver);
 };

benchmark/takeLast/takeLast.php

@@ -3,7 +3,7 @@
 use Rx\Observable;
 
 return function() use ($dummyObserver) {
-    Observable::range(0, 500)
+    Observable::range(0, 500, \Rx\Scheduler::getImmediate())
         ->takeLast(50)
         ->subscribe($dummyObserver);
 };