@@ -41,7 +41,7 @@ discard block |
||
41 | 41 | public function processData(DataItemInterface $item, array &$context) |
42 | 42 | { |
43 | 43 | foreach ($this->chainProcessors as $chainProcessor) { |
44 | - $chainProcessor->processItem($item, 0, $context); |
|
44 | + $chainProcessor->processItem($item, 0, $context); |
|
45 | 45 | } |
46 | 46 | |
47 | 47 | // Nothing to process. |
@@ -58,7 +58,7 @@ discard block |
||
58 | 58 | public function processStop(StopItem $item, array &$context) |
59 | 59 | { |
60 | 60 | foreach ($this->chainProcessors as $chainProcessor) { |
61 | - $result = $chainProcessor->processItem($item, 0, $context); |
|
61 | + $result = $chainProcessor->processItem($item, 0, $context); |
|
62 | 62 | |
63 | 63 | if ($result !== $item) { |
64 | 64 | // Return a new stop item in order to continue flushing out data with stop items. |