Merge pull request #17 from hschimpf/2.x-dev

Minor fixes

src/Internals/ProgressBarWorker/HasChannels.php

@@ -27,6 +27,8 @@ protected function send(mixed $value): mixed {
     }
 
     protected function release(): void {
+        if ( !PARALLEL_EXT_LOADED) return;
+
         $this->progressbar_channel->release();
     }
 

src/Internals/Worker/CommunicatesWithProgressBarWorker.php

@@ -56,6 +56,9 @@ final public function clear(): void {
     }
 
     private function newProgressBarAction(string $action, ...$args): void {
+        // check if progressbar is active
+        if ($this->progressbar_channel === null) return;
+
         $message = new Commands\ProgressBar\ProgressBarActionMessage(
             action: $action,
             args:   $args,

src/ParallelWorker.php

@@ -32,7 +32,7 @@ abstract class ParallelWorker implements Contracts\ParallelWorker {
     /**
      * @var mixed Worker execution result
      */
-    private mixed $result;
+    private mixed $result = null;
 
     final public function getState(): int {
         return $this->state;

tests/ParallelTest.php

@@ -122,6 +122,7 @@ public function testProgressBar(): void {
         }
     }
 
+    /** @depends testThatParallelExtensionIsAvailable */
     public function testThatTasksCanBeRemovedFromQueue(): void {
         Scheduler::using(Workers\LongRunningWorker::class);
 
@@ -155,6 +156,7 @@ public function testThatTasksCanBeRemovedFromQueue(): void {
         Scheduler::removeAllTasks();
     }
 
+    /** @depends testThatParallelExtensionIsAvailable */
     public function testThatTasksCanBeCancelled(): void {
         Scheduler::using(Workers\LongRunningWorker::class);
 
@@ -185,6 +187,7 @@ public function testThatTasksCanBeCancelled(): void {
         Scheduler::removeAllTasks();
     }
 
+    /** @depends testThatParallelExtensionIsAvailable */
     public function testThatChannelsDontOverlap(): void {
         Scheduler::using(Workers\WorkerWithSubWorkers::class);