Added the JobCode to the SchedulingInterface::job() method arguments

Author: gplanchat

.php-cs-fixer.dist.php

@@ -34,6 +34,7 @@
         'error_suppression' => true,
         'ereg_to_preg' => true,
         'dir_constant' => true,
+        'phpdoc_align' => ['align' => 'left'],
     ])
     ->setFinder($finder)
     ->setCacheFile('.php-cs-fixer.cache') // forward compatibility with 3.x line

src/JobCodeInterface.php

@@ -0,0 +1,7 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Kiboko\Contract\Pipeline;
+
+interface JobCodeInterface extends \Stringable {}

src/PipelineRunnerInterface.php

@@ -13,9 +13,8 @@ interface PipelineRunnerInterface
      * @template OutputType
      *
      * @param \Iterator<int, InputType|null> $source
-     * @param \Generator<int, ResultBucketInterface<InputType>, InputType|null, void> $coroutine
-     * @param StepRejectionInterface<InputType> $rejection
-     * @param StepStateInterface $state
+     * @param StepRejectionInterface<InputType|null> $rejection
+     *
      * @return \Iterator<int, ResultBucketInterface<OutputType>|null>
      */
     public function run(

src/SchedulingInterface.php

@@ -8,5 +8,5 @@
 
 interface SchedulingInterface
 {
-    public function job(RunnableInterface $job): self;
+    public function job(JobCodeInterface $job, RunnableInterface $job): self;
 }