Benchmark runner

benchmark/bufferWithCount/bufferWithCount.php

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

benchmark/bufferWithCount/bufferWithCount_eventloop.php

@@ -0,0 +1,17 @@
+<?php
+
+use Rx\Observable;
+use Rx\Scheduler\EventLoopScheduler;
+use React\EventLoop\StreamSelectLoop;
+
+$loop = new StreamSelectLoop();
+$scheduler = new EventLoopScheduler($loop);
+
+$source = Observable::just(25)
+    ->delay(0, $scheduler);
+
+$factory = function() use ($source, $scheduler) {
+    return $source;
+};
+
+return [$factory, $loop];

benchmark/catch/catch.php

@@ -0,0 +1,12 @@
+<?php
+
+use Rx\Observable;
+
+$source = Observable::error(new \Exception('error'))
+    ->catchError(function() {
+        return Observable::just(25);
+    });
+
+return function() use ($source) {
+    return $source;
+};

benchmark/combineLatest/combineLatest.php

@@ -0,0 +1,12 @@
+<?php
+
+use Rx\Observable;
+
+$source = Observable::range(0, 25)
+    ->combineLatest([Observable::range(0, 25)], function($a, $b) {
+        return $a + $b;
+    });
+
+return function() use ($source) {
+    return $source;
+};

benchmark/combineLatest/combineLatest_eventloop.php

@@ -0,0 +1,19 @@
+<?php
+
+use Rx\Observable;
+use Rx\Scheduler\EventLoopScheduler;
+use React\EventLoop\StreamSelectLoop;
+
+$loop = new StreamSelectLoop();
+$scheduler = new EventLoopScheduler($loop);
+
+$source = Observable::range(0, 25, $scheduler)
+    ->combineLatest([Observable::range(0, 25, $scheduler)], function($a, $b) {
+        return $a + $b;
+    });
+
+$factory =  function() use ($source) {
+    return $source;
+};
+
+return [$factory, $loop];

benchmark/concat/concat.php

@@ -0,0 +1,10 @@
+<?php
+
+use Rx\Observable;
+
+$source = Observable::range(0, 25)
+    ->concat(Observable::range(0, 25));
+
+return function() use ($source) {
+    return $source;
+};

benchmark/concat/concat_eventloop.php

@@ -0,0 +1,17 @@
+<?php
+
+use Rx\Observable;
+use Rx\Scheduler\EventLoopScheduler;
+use React\EventLoop\StreamSelectLoop;
+
+$loop = new StreamSelectLoop();
+$scheduler = new EventLoopScheduler($loop);
+
+$source = Observable::range(0, 25, $scheduler)
+    ->concat(Observable::range(0, 25, $scheduler));
+
+$factory = function() use ($source) {
+    return $source;
+};
+
+return [$factory, $loop];

benchmark/concatAll/concatAll.php

@@ -0,0 +1,13 @@
+<?php
+
+use Rx\Observable;
+
+$source = Observable::range(0, 25)
+    ->map(function() {
+        return Observable::range(0, 25);
+    })
+    ->concatAll();
+
+return function() use ($source) {
+    return $source;
+};

benchmark/concatAll/concatAll_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 = Observable::range(0, 25, $scheduler)
+    ->map(function() use ($scheduler) {
+        return Observable::range(0, 25, $scheduler);
+    })
+    ->concatAll();
+
+$factory = function() use ($source) {
+    return $source;
+};
+
+return [$factory, $loop];

benchmark/concatMap/concatMap.php

@@ -0,0 +1,12 @@
+<?php
+
+use Rx\Observable;
+
+$source = Observable::range(1, 25)
+    ->concatMap(function($x) {
+        return Observable::range($x, 25);
+    });
+
+return function() use ($source) {
+    return $source;
+};

benchmark/concatMap/concatMap_eventloop.php

@@ -0,0 +1,19 @@
+<?php
+
+use Rx\Observable;
+use Rx\Scheduler\EventLoopScheduler;
+use React\EventLoop\StreamSelectLoop;
+
+$loop = new StreamSelectLoop();
+$scheduler = new EventLoopScheduler($loop);
+
+$source = Observable::range(1, 25, $scheduler)
+    ->concatMap(function($x) use ($scheduler) {
+        return Observable::range($x, 25, $scheduler);
+    });
+
+$factory = function() use ($source) {
+    return $source;
+};
+
+return [$factory, $loop];

benchmark/defaultIfEmpty/defaultIfEmpty.php

@@ -0,0 +1,10 @@
+<?php
+
+use Rx\Observable;
+
+$source = Observable::emptyObservable()
+    ->defaultIfEmpty(Observable::just(25));
+
+return function() use ($source) {
+    return $source;
+};

benchmark/delay/delay.php

@@ -0,0 +1,11 @@
+<?php
+
+use Rx\Observable;
+use Rx\Scheduler\ImmediateScheduler;
+
+$source = Observable::just(25)
+    ->delay(0, new ImmediateScheduler());
+
+return function() use ($source) {
+    return $source;
+};

benchmark/delay/delay_eventloop.php

@@ -0,0 +1,17 @@
+<?php
+
+use Rx\Observable;
+use Rx\Scheduler\EventLoopScheduler;
+use React\EventLoop\StreamSelectLoop;
+
+$loop = new StreamSelectLoop();
+$scheduler = new EventLoopScheduler($loop);
+
+$source = Observable::just(25)
+    ->delay(0, $scheduler);
+
+$factory = function() use ($source) {
+    return $source;
+};
+
+return [$factory, $loop];

benchmark/distinct/distinct.php

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

benchmark/distinct/distinct_eventloop.php

@@ -0,0 +1,21 @@
+<?php
+
+use Rx\Observable;
+use Rx\Observable\ArrayObservable;
+use Rx\Scheduler\EventLoopScheduler;
+use React\EventLoop\StreamSelectLoop;
+
+$loop = new StreamSelectLoop();
+$scheduler = new EventLoopScheduler($loop);
+
+$source = Observable::range(0, 25, $scheduler)
+    ->map(function($i) {
+        return $i % 3;
+    })
+    ->distinct();
+
+$factory = function() use ($source) {
+    return $source;
+};
+
+return [$factory, $loop];

benchmark/filter/filter.php

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

benchmark/filter/filter_eventloop.php

@@ -0,0 +1,22 @@
+<?php
+
+use Rx\Observable;
+use Rx\Scheduler\EventLoopScheduler;
+use React\EventLoop\StreamSelectLoop;
+
+$loop = new StreamSelectLoop();
+$scheduler = new EventLoopScheduler($loop);
+
+$source = Observable::range(0, 50, $scheduler)
+    ->filter(function($value) {
+        return $value % 2 == 0;
+    })
+    ->filter(function($value) {
+        return $value % 10 == 0;
+    });
+
+$factory = function() use ($source) {
+    return $source;
+};
+
+return [$factory, $loop];

benchmark/flatMap/flatMap.php

@@ -0,0 +1,12 @@
+<?php
+
+use Rx\Observable;
+
+$source = Observable::range(0, 25)
+    ->flatMap(function($x) {
+        return Observable::range($x, 25);
+    });
+
+return function() use ($source) {
+    return $source;
+};

benchmark/flatMap/flatMap_eventloop.php

@@ -0,0 +1,19 @@
+<?php
+
+use Rx\Observable;
+use Rx\Scheduler\EventLoopScheduler;
+use React\EventLoop\StreamSelectLoop;
+
+$loop = new StreamSelectLoop();
+$scheduler = new EventLoopScheduler($loop);
+
+$source = Observable::range(0, 25, $scheduler)
+    ->flatMap(function($x) use ($scheduler) {
+        return Observable::range($x, 25, $scheduler);
+    });
+
+$factory = function() use ($source) {
+    return $source;
+};
+
+return [$factory, $loop];

benchmark/forkJoin/forkJoin.php

@@ -0,0 +1,15 @@
+<?php
+
+use Rx\Observable;
+
+$source = Observable::defer(function() {
+    return Observable::forkJoin([
+        Observable::just(25),
+        Observable::range(0, 25),
+        Observable::fromArray(([1, 2, 3, 4, 5]))
+    ]);
+});
+
+return function() use ($source) {
+    return $source;
+};

benchmark/groupBy/groupBy.php

@@ -0,0 +1,15 @@
+<?php
+
+use Rx\Observable;
+
+$source = Observable::range(0, 25)
+    ->map(function($i) {
+        return ['key' => $i % 5];
+    })
+    ->groupBy(function($item) {
+        return $item['key'];
+    });
+
+return function() use ($source) {
+    return $source;
+};

benchmark/groupBy/groupBy_eventloop.php

@@ -0,0 +1,22 @@
+<?php
+
+use Rx\Observable;
+use Rx\Scheduler\EventLoopScheduler;
+use React\EventLoop\StreamSelectLoop;
+
+$loop = new StreamSelectLoop();
+$scheduler = new EventLoopScheduler($loop);
+
+$source = Observable::range(0, 25, $scheduler)
+    ->map(function($i) {
+        return ['key' => $i % 5];
+    })
+    ->groupBy(function($item) {
+        return $item['key'];
+    });
+
+$factory = function() use ($source) {
+    return $source;
+};
+
+return [$factory, $loop];

benchmark/isEmpty/isEmpty.php

@@ -0,0 +1,10 @@
+<?php
+
+use Rx\Observable;
+
+$source = Observable::just(25)
+    ->isEmpty();
+
+return function() use ($source) {
+    return $source;
+};