src/tomzx/Dataflow/Processor/Parallel.php 1 location
|
@@ 175-183 (lines=9) @@
|
172 |
|
* @param int|string $nodeIndex |
173 |
|
* @return array |
174 |
|
*/ |
175 |
|
private function getArguments($nodeIndex) |
176 |
|
{ |
177 |
|
$argumentsIndex = array_slice($this->nodes[$nodeIndex], 1); |
178 |
|
$arguments = []; |
179 |
|
foreach ($argumentsIndex as $nodeIndex) { |
180 |
|
$arguments[] = $this->processingNodes[$nodeIndex]->output(); |
181 |
|
} |
182 |
|
return $arguments; |
183 |
|
} |
184 |
|
} |
185 |
|
|
src/tomzx/Dataflow/Processor/Sequential.php 1 location
|
@@ 148-156 (lines=9) @@
|
145 |
|
* @param int|string $nodeIndex |
146 |
|
* @return array |
147 |
|
*/ |
148 |
|
private function getArguments($nodeIndex) |
149 |
|
{ |
150 |
|
$argumentsIndex = array_slice($this->nodes[$nodeIndex], 1); |
151 |
|
$arguments = []; |
152 |
|
foreach ($argumentsIndex as $nodeIndex) { |
153 |
|
$arguments[] = $this->processingNodes[$nodeIndex]->output(); |
154 |
|
} |
155 |
|
return $arguments; |
156 |
|
} |
157 |
|
} |
158 |
|
|