while (!reforkNeeded && itemsIterator.hasNext()) {
final ReforkReasonKey currentItemKey = itemsIterator.next();
final Object currentItemData = reforkDecisionContext.getData(currentItemKey);
if (currentItemData != null) {
final ReforkReasonDataProcessor currentItemDataProcessor = itemProcessors.get(currentItemKey);
<BUG>reforkNeeded = currentItemDataProcessor.determineReforkNeeded(currentItemData);
</BUG>
}
}
return reforkNeeded;

while (!reforkNeeded && itemsIterator.hasNext()) {
final ReforkReasonKey currentItemKey = itemsIterator.next();
final Object currentItemData = reforkDecisionContext.getData(currentItemKey);
if (currentItemData != null) {
final ReforkReasonDataProcessor currentItemDataProcessor = itemProcessors.get(currentItemKey);
reforkNeeded = currentItemDataProcessor.determineReforkNeeded(pipeline, forkId, currentItemData);
}
}
return reforkNeeded;
