Merge pull request #1 from reactphp-parallel/quick-create-factory-method

Quick factory method to create runtimes with the default autoloader

Author: WyriHaximus

composer.json

@@ -14,7 +14,8 @@
         "ext-parallel": "*",
         "react-parallel/future-to-promise-converter": "dev-master",
         "react/event-loop": "^1.1",
-        "react/promise": "^2.7"
+        "react/promise": "^2.7",
+        "wyrihaximus/constants": "^1.4.3"
     },
     "require-dev": {
         "wyrihaximus/async-test-utilities": "^2.0.0-alpha1",

composer.lock

@@ -2,8 +2,8 @@ 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#'
+		- '#Thrown exceptions in a catch block must bundle the previous exception \(see throw statement line 97\). More info: http:\/\/bit.ly\/bundleexception#'
+		- '#Thrown exceptions in a catch block must bundle the previous exception \(see throw statement line 126\). More info: http:\/\/bit.ly\/bundleexception#'
 
 includes:
 	- vendor/wyrihaximus/async-test-utilities/rules.neon

phpstan.neon

@@ -8,13 +8,19 @@
 use React\Promise\PromiseInterface;
 use ReactParallel\FutureToPromiseConverter\FutureToPromiseConverter;
 use function React\Promise\resolve;
+use const WyriHaximus\Constants\ComposerAutoloader\LOCATION;
 
 final class Runtime
 {
     private ParallelRuntime $runtime;
 
     private FutureToPromiseConverter $futureToPromiseConverter;
 
+    public static function create(FutureToPromiseConverter $futureToPromiseConverter): self
+    {
+        return new self($futureToPromiseConverter, LOCATION);
+    }
+
     public function __construct(FutureToPromiseConverter $futureToPromiseConverter, string $autoload)
     {
         $this->futureToPromiseConverter = $futureToPromiseConverter;

src/Runtime.php

@@ -16,10 +16,13 @@
  */
 final class RuntimeTest extends AsyncTestCase
 {
-    public function testConvertSuccess(): void
+    /**
+     * @test
+     */
+    public function convertSuccess(): void
     {
         $loop = Factory::create();
-        $runtime = new Runtime(new FutureToPromiseConverter($loop), \dirname(__DIR__) . '/vendor/autoload.php');
+        $runtime = Runtime::create(new FutureToPromiseConverter($loop));
 
         /** @var ExtendedPromiseInterface $promise */
         $promise = $runtime->run(function (): int {
@@ -38,13 +41,16 @@ public function testConvertSuccess(): void
         self::assertSame(3, $three);
     }
 
-    public function testConvertFailure(): void
+    /**
+     * @test
+     */
+    public function convertFailure(): void
     {
         self::expectException(\Exception::class);
         self::expectExceptionMessage('Rethrow exception');
 
         $loop = Factory::create();
-        $runtime = new Runtime(new FutureToPromiseConverter($loop), \dirname(__DIR__) . '/vendor/autoload.php');
+        $runtime = Runtime::create(new FutureToPromiseConverter($loop));
 
         /** @var ExtendedPromiseInterface $promise */
         $promise = $runtime->run(function (): void {
@@ -63,13 +69,16 @@ public function testConvertFailure(): void
         self::assertSame(3, $three);
     }
 
-    public function testWeClosedTheThread(): void
+    /**
+     * @test
+     */
+    public function weClosedTheThread(): void
     {
         self::expectException(Closed::class);
         self::expectExceptionMessage('Runtime closed');
 
         $loop = Factory::create();
-        $runtime = new Runtime(new FutureToPromiseConverter($loop), \dirname(__DIR__) . '/vendor/autoload.php');
+        $runtime = Runtime::create(new FutureToPromiseConverter($loop));
 
         /** @var ExtendedPromiseInterface $promise */
         $promise = timedPromise($loop, 1, $runtime)->then(function (Runtime $runtime) {
@@ -89,13 +98,16 @@ public function testWeClosedTheThread(): void
         }
     }
 
-    public function testWeKilledTheThread(): void
+    /**
+     * @test
+     */
+    public function weKilledTheThread(): void
     {
         self::expectException(Closed::class);
         self::expectExceptionMessage('Runtime closed');
 
         $loop = Factory::create();
-        $runtime = new Runtime(new FutureToPromiseConverter($loop), \dirname(__DIR__) . '/vendor/autoload.php');
+        $runtime = Runtime::create(new FutureToPromiseConverter($loop));
 
         /** @var ExtendedPromiseInterface $promise */
         $promise = timedPromise($loop, 1, $runtime)->then(function (Runtime $runtime) {