|
@@ -41,7 +41,7 @@ discard block |
|
|
block discarded – undo |
|
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 |
|
|
block discarded – undo |
|
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. |
Please login to merge, or discard this patch.