Benchmark 2.x

benchmark/bufferWithCount/bufferWithCount.php

@@ -0,0 +1,11 @@
+<?php
+
+use Rx\Observable;
+use Rx\Scheduler\ImmediateScheduler;
+
+$source = Observable::range(0, 25, new ImmediateScheduler())
+    ->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::range(0, 25, $scheduler)
+    ->bufferWithCount(5);
+
+$factory = function() use ($source) {
+    return $source;
+};
+
+return [$factory, $loop];

benchmark/catch/catch.php

@@ -0,0 +1,15 @@
+<?php
+
+use Rx\Observable;
+use Rx\Scheduler\ImmediateScheduler;
+
+$scheduler = new ImmediateScheduler();
+
+$source = Observable::error(new \Exception('error'), $scheduler)
+    ->catch(function() use ($scheduler) {
+        return Observable::of(25, $scheduler);
+    });
+
+return function() use ($source) {
+    return $source;
+};

benchmark/catch/catch_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::error(new \Exception('error'), $scheduler)
+    ->catch(function() use ($scheduler) {
+        return Observable::of(25, $scheduler);
+    });
+
+return function() use ($source) {
+    return $source;
+};

benchmark/combineLatest/combineLatest.php

@@ -0,0 +1,15 @@
+<?php
+
+use Rx\Observable;
+use Rx\Scheduler\ImmediateScheduler;
+
+$scheduler = new ImmediateScheduler();
+
+$source = Observable::range(0, 25, $scheduler)
+    ->combineLatest([Observable::range(0, 25, $scheduler)], 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,13 @@
+<?php
+
+use Rx\Observable;
+use Rx\Scheduler\ImmediateScheduler;
+
+$scheduler = new ImmediateScheduler();
+
+$source = Observable::range(0, 25, $scheduler)
+    ->concat(Observable::range(0, 25, $scheduler));
+
+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,16 @@
+<?php
+
+use Rx\Observable;
+use Rx\Scheduler\ImmediateScheduler;
+
+$scheduler = new ImmediateScheduler();
+
+$source = Observable::range(0, 25, $scheduler)
+    ->map(function() use ($scheduler) {
+        return Observable::range(0, 25, $scheduler);
+    })
+    ->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,15 @@
+<?php
+
+use Rx\Observable;
+use Rx\Scheduler\ImmediateScheduler;
+
+$scheduler = new ImmediateScheduler();
+
+$source = Observable::range(1, 25, $scheduler)
+    ->concatMap(function($x) use ($scheduler) {
+        return Observable::range($x, 25, $scheduler);
+    });
+
+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,13 @@
+<?php
+
+use Rx\Observable;
+use Rx\Scheduler\ImmediateScheduler;
+
+$scheduler = new ImmediateScheduler();
+
+$source = Observable::empty($scheduler)
+    ->defaultIfEmpty(Observable::of(25, $scheduler));
+
+return function() use ($source) {
+    return $source;
+};

benchmark/defaultIfEmpty/defaultIfEmpty_eventloop.php

@@ -0,0 +1,15 @@
+<?php
+
+use Rx\Observable;
+use Rx\Scheduler\EventLoopScheduler;
+use React\EventLoop\StreamSelectLoop;
+
+$loop = new StreamSelectLoop();
+$scheduler = new EventLoopScheduler($loop);
+
+$source = Observable::empty($scheduler)
+    ->defaultIfEmpty(Observable::of(25, $scheduler));
+
+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::of(25, $scheduler)
+    ->delay(0, $scheduler);
+
+$factory = function() use ($source) {
+    return $source;
+};
+
+return [$factory, $loop];

benchmark/distinct/distinct.php

@@ -0,0 +1,16 @@
+<?php
+
+use Rx\Observable;
+use Rx\Scheduler\ImmediateScheduler;
+
+$scheduler = new ImmediateScheduler();
+
+$source = Observable::range(0, 25, $scheduler)
+    ->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,18 @@
+<?php
+
+use Rx\Observable;
+use Rx\Scheduler\ImmediateScheduler;
+
+$scheduler = new ImmediateScheduler();
+
+$source = Observable::range(0, 50, $scheduler)
+    ->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,15 @@
+<?php
+
+use Rx\Observable;
+use Rx\Scheduler\ImmediateScheduler;
+
+$scheduler = new ImmediateScheduler();
+
+$source = Observable::range(0, 25, $scheduler)
+    ->flatMap(function($x) use ($scheduler) {
+        return Observable::range($x, 25, $scheduler);
+    });
+
+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,18 @@
+<?php
+
+use Rx\Observable;
+use Rx\Scheduler\ImmediateScheduler;
+
+$scheduler = new ImmediateScheduler();
+
+$source = Observable::defer(function() use ($scheduler) {
+    return Observable::forkJoin([
+        Observable::of(25, $scheduler),
+        Observable::range(0, 25, $scheduler),
+        Observable::fromArray([1, 2, 3, 4, 5], $scheduler)
+    ]);
+}, $scheduler);
+
+return function() use ($source) {
+    return $source;
+};