more benchmarks

Author: martinsik

benchmark/bufferWithCount/bufferWithCount_eventloop.php

@@ -6,8 +6,9 @@
 
 $loop = new StreamSelectLoop();
 $scheduler = new EventLoopScheduler($loop);
-$source = Observable::range(0, 25, $scheduler)
-    ->bufferWithCount(5);
+
+$source = Observable::just(25)
+    ->delay(0, $scheduler);
 
 $factory = function() use ($source, $scheduler) {
     return $source;

benchmark/concat/concat.php

@@ -0,0 +1,10 @@
+<?php
+
+use Rx\Observable;
+
+$source = Observable::range(1, 25)
+    ->concat(Observable::range(1, 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(1, 25, $scheduler)
+    ->concat(Observable::range(1, 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/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/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;
+};