✨ add swoole adapter

.gitignore

@@ -2,3 +2,4 @@
 /vendor/
 /composer.lock
 /.php_cs.cache
+/.phpunit.result.cache

.travis.yml

@@ -8,6 +8,9 @@ before_script:
   - phpenv config-rm xdebug.ini
   - composer install
 
+before_install:
+  - printf "\n" | pecl install swoole
+
 env:
   - TASK=tests-unit
   - TASK=tests-examples

composer.json

@@ -33,11 +33,13 @@
         "react/promise": "^2.7",
         "phpstan/phpstan": "^0.10.5",
         "symfony/http-client": "^4.3",
+        "swoole/ide-helper": "^4.6.5",
         "psr/http-factory": "^1.0",
         "http-interop/http-factory-guzzle": "^1.0"
     },
     "suggest": {
         "ext-curl": "Required to use Curl and HTTP2 features",
+        "ext-swoole": "Required to use Tornado\\Adapter\\Swoole\\EventLoop",
         "amphp/amp": "Required to use Tornado\\Adapter\\Amp\\EventLoop",
         "react/event-loop": "Required to use Tornado\\Adapter\\ReactPhp\\EventLoop",
         "react/promise": "Required to use Tornado\\Adapter\\ReactPhp\\EventLoop",

examples/00-README-samples.php

@@ -101,6 +101,7 @@ function waitException(Tornado\EventLoop $eventLoop)
 //$eventLoop = new Tornado\Adapter\Tornado\SynchronousEventLoop();
 //$eventLoop = new Tornado\Adapter\Amp\EventLoop();
 //$eventLoop = new Tornado\Adapter\ReactPhp\EventLoop(new \React\EventLoop\StreamSelectLoop());
+//$eventLoop = new Tornado\Adapter\Swoole\EventLoop();
 
 // Tornado provides only one HttpClient implementation, using Guzzle
 $httpClient = new Tornado\Adapter\Guzzle\HttpClient($eventLoop, new Tornado\Adapter\Guzzle\CurlMultiClientWrapper());

examples/01-async-countdown.php

@@ -27,6 +27,7 @@ function asynchronousCountdown(EventLoop $eventLoop, string $name, int $count):
 //$eventLoop = new Adapter\Tornado\SynchronousEventLoop();
 //$eventLoop = new Adapter\Amp\EventLoop();
 //$eventLoop = new Adapter\ReactPhp\EventLoop(new \React\EventLoop\StreamSelectLoop());
+//$eventLoop = new Tornado\Adapter\Swoole\EventLoop();
 
 echo "Let's start!\n";
 

examples/02-failures.php

@@ -19,6 +19,7 @@ function throwingGenerator(): \Generator
 //$eventLoop = new Adapter\Tornado\SynchronousEventLoop();
 //$eventLoop = new Adapter\Amp\EventLoop();
 //$eventLoop = new Adapter\ReactPhp\EventLoop(new \React\EventLoop\StreamSelectLoop());
+//$eventLoop = new Tornado\Adapter\Swoole\EventLoop();
 
 echo "Let's start!\n";
 

examples/03-http-client.php

@@ -27,6 +27,7 @@ function monitorRequest(EventLoop $eventLoop, HttpClient $httpClient, string $ur
 //$eventLoop = new Adapter\Tornado\SynchronousEventLoop();
 //$eventLoop = new Adapter\Amp\EventLoop();
 //$eventLoop = new Adapter\ReactPhp\EventLoop(new \React\EventLoop\StreamSelectLoop());
+//$eventLoop = new Tornado\Adapter\Swoole\EventLoop();
 
 // Choose your adapter
 $httpClient = new Adapter\Symfony\HttpClient(new \Symfony\Component\HttpClient\CurlHttpClient(), $eventLoop, new \Http\Factory\Guzzle\ResponseFactory(), new \Http\Factory\Guzzle\StreamFactory());

examples/04-foreach.php

@@ -70,6 +70,7 @@ function compareMethods(EventLoop $eventLoop)
 //$eventLoop = new Adapter\Tornado\SynchronousEventLoop();
 //$eventLoop = new Adapter\Amp\EventLoop();
 //$eventLoop = new Adapter\ReactPhp\EventLoop(new \React\EventLoop\StreamSelectLoop());
+//$eventLoop = new Tornado\Adapter\Swoole\EventLoop();
 
 echo "Let's start!\n";
 // Run the event loop until our goal promise is reached.

src/Adapter/Amp/EventLoop.php

@@ -153,7 +153,7 @@ function (Promise $promise) {
             $promises
         );
 
-        foreach ($promises as $index => $promise) {
+        foreach ($promises as $promise) {
             \Amp\Promise\rethrow(new \Amp\Coroutine($wrapPromise($promise)));
         }
 

src/Adapter/ReactPhp/EventLoop.php

@@ -69,6 +69,8 @@ public function async(\Generator $generator): Promise
             try {
                 if (!$generator->valid()) {
                     $deferred->resolve($generator->getReturn());
+
+                    return;
                 }
                 $promise = $generator->current();
                 if (!$promise instanceof Internal\PromiseWrapper) {