Merge pull request #73 from vuongxuongminh/synchronous-catch-exceptio…

…n-bugfix

Bugfix handling exception in synchronous process

src/Process/ProcessCallbacks.php

@@ -68,6 +68,8 @@ public function triggerError()
         }
     }
 
+    abstract protected function resolveErrorOutput(): Throwable;
+
     public function triggerTimeout()
     {
         foreach ($this->timeoutCallbacks as $callback) {

src/Process/SynchronousProcess.php

@@ -71,4 +71,9 @@ public function getCurrentExecutionTime(): float
     {
         return $this->executionTime;
     }
+
+    protected function resolveErrorOutput(): Throwable
+    {
+        return $this->getErrorOutput();
+    }
 }

tests/ErrorHandlingTest.php

@@ -139,4 +139,22 @@ public function deep_syntax_errors_are_thrown()
 
         $pool->wait();
     }
+
+    /** @test */
+    public function it_can_handle_synchronous_exception()
+    {
+        Pool::$forceSynchronous = true;
+
+        $pool = Pool::create();
+
+        $pool->add(function () {
+            throw new MyException('test');
+        })->catch(function (MyException $e) {
+            $this->assertRegExp('/test/', $e->getMessage());
+        });
+
+        $pool->wait();
+
+        Pool::$forceSynchronous = false;
+    }
 }