Rebuild into async only with sync API

Author: WyriHaximus

Diff for: benchmark/consumer.php

@@ -1,6 +1,8 @@
 <?php
 namespace Bunny;
 
+use Bunny\Message;
+
 require_once __DIR__ . "/../vendor/autoload.php";
 
 $c = new Client();
@@ -13,18 +15,16 @@
 $t = null;
 $count = 0;
 
-$ch->run(function (Message $msg, Channel $ch, Client $c) use (&$t, &$count) {
+$ch->consume(function (Message $msg, Channel $ch, Client $c) use (&$t, &$count) {
     if ($t === null) {
         $t = microtime(true);
     }
 
     if ($msg->content === "quit") {
         printf("Pid: %s, Count: %s, Time: %.4f\n", getmypid(), $count, microtime(true) - $t);
-        $c->stop();
+        $c->disconnect();
     } else {
         ++$count;
     }
 
 }, "bench_queue", "", false, true);
-
-$c->disconnect();

Diff for: benchmark/consumer_async.php

@@ -1,6 +1,8 @@
 <?php
 namespace Bunny;
 
+use Bunny\Client;
+
 require_once __DIR__ . "/../vendor/autoload.php";
 
 $c = new Client();

Diff for: benchmark/producer.php

@@ -1,7 +1,7 @@
 {
     "name": "bunny/bunny",
     "type": "library",
-    "description": "Performant pure-PHP AMQP (RabbitMQ) sync/async (ReactPHP) library",
+    "description": "Performant pure-PHP AMQP (RabbitMQ) non-blocking ReactPHP library",
     "keywords": [
         "rabbitmq",
         "rabbit",
@@ -25,22 +25,28 @@
         }
     ],
     "require": {
-        "php": "^7.1 || ^8.0",
-        "react/event-loop": "^1.0 || ^0.5 || ^0.4",
-        "react/promise": "~2.2"
+        "php": "^8.1",
+        "react/event-loop": "^1.5",
+        "react/promise": "^3.1",
+        "react/stream": "^1.3",
+        "react/async": "^4.2",
+        "react/socket": "^1.15",
+        "react/promise-timer": "^1.10",
+        "evenement/evenement": "^3"
     },
     "require-dev": {
         "ext-pcntl": "*",
-        "phpunit/phpunit": "^9.5 || ^7.5.20",
-        "symfony/process": "^6.1 || ^4.4",
-        "phpstan/phpstan": "^1.10"
+        "phpunit/phpunit": "^9.6",
+        "symfony/process": "^6.4",
+        "phpstan/phpstan": "^1.10",
+        "wyrihaximus/react-phpunit-run-tests-in-fiber": "^1"
     },
     "suggest": {
         "ext-pcntl": "For using synchronous AMQP/RabbitMQ client"
     },
     "autoload": {
         "psr-4": {
-            "Bunny\\": "src/Bunny/"
+            "Bunny\\": "src/"
         }
     },
     "autoload-dev": {

Diff for: benchmark/producer_async.php

@@ -0,0 +1,66 @@
+<?php
+
+use Bunny\Client;
+use Bunny\Channel;
+use Bunny\Message;
+use Bunny\Protocol\MethodBasicConsumeOkFrame;
+
+use React\EventLoop\Loop;
+use function React\Async\async;
+
+require dirname(__DIR__) . '/vendor/autoload.php';
+
+$channel = null;
+$consumerTag = null;
+
+// Capture signals - SIGINT = Ctrl+C; SIGTERM = `kill`
+Loop::addSignal(SIGINT, function (int $signal) use (&$channel, &$consumerTag) {
+    print 'Consumer cancelled\n';
+    $channel->cancel($consumerTag);
+
+    Loop::addTimer(3, static function () {
+        Loop::stop();
+    });
+});
+Loop::addSignal(SIGTERM, function (int $signal) use (&$channel, &$consumerTag) {
+    print 'Consumer cancelled\n';
+    $channel->cancel($consumerTag);
+
+    Loop::addTimer(3, static function () {
+        Loop::stop();
+    });
+});
+
+$clientConfig = [
+    "host" => "rabbitmq.example.com",
+    "port" => 5672,
+    "vhost" => "/",
+    "user" => "appuser",
+    "password" => "apppass",
+];
+
+$client = new Client($clientConfig);
+$channel = $client->channel();
+$channel->qos(0, 13);
+$channel->queueDeclare('hello', false, false, false, false);
+$channelRef = $channel;
+echo ' [*] Waiting for messages. To exit press CTRL+C', "\n";
+$response = $channel->consume(
+    async(function (Message $message, Channel $channel) {
+        echo ' [x] Received ', $message->content, "\n";
+
+        // Do some work - we generate password hashes with a high cost
+        // sleep() gets interrupted by Ctrl+C so it's not very good for demos
+        // Performing multiple work units demonstrates that nothing is skipped
+        for ($i = 0; $i < 3; $i++) {
+            print 'WU {$i}\n';
+            password_hash(random_bytes(255), PASSWORD_BCRYPT, ['cost' => 15]);
+        }
+        echo ' [x] Done ', $message->content, "\n";
+
+        $channel->ack($message);
+    }),
+    'hello',
+    noAck: true,
+);
+$consumerTag = $response->consumerTag;

Diff for: composer.json

@@ -1,6 +1,7 @@
 <?php
 namespace Bunny;
 
+use Bunny\Constants;
 use Bunny\Protocol\ContentHeaderFrame;
 
 require_once __DIR__ . "/../vendor/autoload.php";