Test runtime::kill && close methods

Author: WyriHaximus

composer.json

@@ -17,7 +17,8 @@
     },
     "require-dev": {
         "thecodingmachine/safe": "^0.1.16",
-        "wyrihaximus/async-test-utilities": "^1.1"
+        "wyrihaximus/async-test-utilities": "^1.1",
+        "wyrihaximus/ticking-promise": "^1.6"
     },
     "config": {
         "platform": {

composer.lock

@@ -1,6 +1,9 @@
 parameters:
 	ignoreErrors:
 		- '#Do not throw the \\Exception base class. Instead, extend the \\Exception base class. More info: http:\/\/bit.ly\/subtypeexception#'
+		- '#Invalid type Throwable|null to throw.#'
+		- '#Thrown exceptions in a catch block must bundle the previous exception \(see throw statement line 88\). More info: http:\/\/bit.ly\/bundleexception#'
+		- '#Thrown exceptions in a catch block must bundle the previous exception \(see throw statement line 114\). More info: http:\/\/bit.ly\/bundleexception#'
 
 includes:
 	- vendor/wyrihaximus/async-test-utilities/rules.neon

phpstan.neon

@@ -7,7 +7,9 @@
 use WyriHaximus\AsyncTestUtilities\AsyncTestCase;
 use WyriHaximus\React\Parallel\FutureToPromiseConverter;
 use WyriHaximus\React\Parallel\Runtime;
+use parallel\Runtime\Error\Closed;
 use function Safe\sleep;
+use function WyriHaximus\React\timedPromise;
 
 /**
  * @internal
@@ -60,4 +62,56 @@ public function testConvertFailure(): void
 
         self::assertSame(3, $three);
     }
+
+    public function testWeClosedTheThread(): void
+    {
+        self::expectException(Closed::class);
+        self::expectExceptionMessage('Runtime closed');
+
+        $loop = Factory::create();
+        $runtime = new Runtime(new FutureToPromiseConverter($loop), \dirname(__DIR__) . '/vendor/autoload.php');
+
+        /** @var ExtendedPromiseInterface $promise */
+        $promise = timedPromise($loop, 1, $runtime)->then(function (Runtime $runtime) {
+            return $runtime->run(function (): int {
+                return 3;
+            });
+        });
+
+        $loop->futureTick(function () use ($runtime): void {
+            $runtime->close();
+        });
+
+        try {
+            $this->await($promise, $loop, 3.3);
+        } catch (\Exception $exception) {
+            throw $exception->getPrevious();
+        }
+    }
+
+    public function testWeKilledTheThread(): void
+    {
+        self::expectException(Closed::class);
+        self::expectExceptionMessage('Runtime closed');
+
+        $loop = Factory::create();
+        $runtime = new Runtime(new FutureToPromiseConverter($loop), \dirname(__DIR__) . '/vendor/autoload.php');
+
+        /** @var ExtendedPromiseInterface $promise */
+        $promise = timedPromise($loop, 1, $runtime)->then(function (Runtime $runtime) {
+            return $runtime->run(function (): int {
+                return 3;
+            });
+        });
+
+        $loop->futureTick(function () use ($runtime): void {
+            $runtime->kill();
+        });
+
+        try {
+            $this->await($promise, $loop, 3.3);
+        } catch (\Exception $exception) {
+            throw $exception->getPrevious();
+        }
+    }
 }