Moved Benchmark from v1

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/bufferWithCount/bufferWithCount_eventloop.php

@@ -0,0 +1,16 @@
+<?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)
+        ->bufferWithCount(5)
+        ->subscribe($dummyObserver, $scheduler);
+
+    $loop->run();
+};

benchmark/distinct/distinct.php

@@ -0,0 +1,13 @@
+<?php
+
+use Rx\Observable;
+
+$source = array_map(function($val) {
+    return $val % 3;
+}, range(0, 25));
+
+return function() use ($source, $dummyObserver) {
+    Observable::fromArray($source)
+        ->distinct()
+        ->subscribe($dummyObserver);
+};

benchmark/distinct/distinct_eventloop.php

@@ -0,0 +1,20 @@
+<?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)
+        ->distinct()
+        ->subscribe($dummyObserver, $scheduler);
+
+    $loop->run();
+};

benchmark/filter/filter.php

@@ -0,0 +1,14 @@
+<?php
+
+use Rx\Observable;
+
+return function() use ($dummyObserver) {
+    Observable::range(0, 50)
+        ->filter(function($value) {
+            return $value % 2 == 0;
+        })
+        ->filter(function($value) {
+            return $value % 10 == 0;
+        })
+        ->subscribe($dummyObserver);
+};

benchmark/filter/filter_eventloop.php

@@ -0,0 +1,21 @@
+<?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)
+        ->filter(function($value) {
+            return $value % 2 == 0;
+        })
+        ->filter(function($value) {
+            return $value % 10 == 0;
+        })
+        ->subscribe($dummyObserver, $scheduler);
+
+    $loop->run();
+};

benchmark/run.php

@@ -0,0 +1,106 @@
+<?php
+
+if (file_exists($file = __DIR__.'/../vendor/autoload.php')) {
+    $autoload = require_once $file;
+    $autoload->addPsr4('Vendor\\Rx\\Operator\\', __DIR__ . '/custom-operator');
+} else {
+    throw new RuntimeException('Install dependencies to run benchmark suite.');
+}
+
+use Rx\Observable;
+use Rx\Observer\CallbackObserver;
+
+define('MIN_TOTAL_DURATION', 5);
+$start = microtime(true);
+
+if ($_SERVER['argc'] === 1) {
+    $files = glob(__DIR__ . '/**/*.php');
+} else {
+    $files = [];
+    foreach (array_slice($_SERVER['argv'], 1) as $fileOrDir) {
+        if (is_dir($fileOrDir)) {
+            $files = array_merge($files, glob($fileOrDir . '/*.php'));
+        } else {
+            // Force absolute path
+            $files[] = $file[0] === DIRECTORY_SEPARATOR ? $file : $_SERVER['PWD'] . DIRECTORY_SEPARATOR . $file;
+        }
+    }
+}
+
+
+Observable::just($files)
+    ->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);
+    })
+    ->doOnNext(function($file) {
+        printf('%s', pathinfo($file, PATHINFO_FILENAME));
+    })
+    ->map(function($file) { // Run benchmark
+        $totalDuration = 0.0;
+        $durations = [];
+
+        ob_start();
+
+        $dummyObserver = new Rx\Observer\CallbackObserver(
+            function ($value) { },
+            function ($error) { },
+            function () { }
+        );
+
+        $testClosure = @include $file;
+        if (!$testClosure) {
+            throw new Exception("Unable to load file \"$file\"");
+        }
+
+        while ($totalDuration < MIN_TOTAL_DURATION) {
+            $start = microtime(true);
+
+            $testClosure();
+
+            $duration = microtime(true) - $start;
+
+            $durations[] = $duration * 1000;
+            $totalDuration += $duration;
+        }
+
+        ob_end_clean();
+
+        return [
+            'file' => $file,
+            'durations' => $durations,
+        ];
+    })
+    ->doOnNext(function(array $result) { // Print the number of successful runs
+        printf(' - %d', count($result['durations']));
+    })
+    ->map(function(array $result) { // Calculate the standard deviation
+        $count = count($result['durations']);
+        $mean = array_sum($result['durations']) / $count;
+
+        $variance = array_sum(array_map(function($duration) use ($mean) {
+            return pow($mean - $duration, 2);
+        }, $result['durations']));
+
+        return [
+            'file' => $result['file'],
+            'mean' => $mean,
+            'standard_deviation' => pow($variance / $count, 0.5),
+        ];
+    })
+    ->subscribe(new CallbackObserver(
+        function(array $result) {
+            printf(" (%.2fms ±%.2fms)\n", $result['mean'], $result['standard_deviation']);
+        },
+        function(\Exception $error) {
+            printf("\nError: %s\n", $error->getMessage());
+        },
+        function() use ($start) {
+            printf("============================================================\n");
+            printf("total duration: %.2fs\n", microtime(true) - $start);
+        }
+    ));

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/skipLast/skipLast_eventloop.php

@@ -0,0 +1,16 @@
+<?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)
+        ->skipLast(50)
+        ->subscribe($dummyObserver, $scheduler);
+
+    $loop->run();
+};

benchmark/takeLast/takeLast.php

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