in src/main/java/org/apache/sling/pipes/internal/TraversePipe.java [128:143]
boolean goToNextElligibleNode() {
try {
while ((currentResources == null || !currentResources.hasNext()) && !nodesToVisit.isEmpty()) {
Node node = nodesToVisit.remove(0);
LOGGER.debug("visiting {}", node.getPath());
refreshResourceIterator(node);
int indexAdd = breadthFirst ? nodesToVisit.size() : 0;
if (isBeforeLastLevel(node)) {
nodesToVisit.addAll(indexAdd, IteratorUtils.toList(node.getNodes()));
}
}
} catch (RepositoryException e) {
LOGGER.error("unable to read node subpipes", e);
}
return currentResources != null && currentResources.hasNext();
}