Skip to content

Commit

Permalink
Renames
Browse files Browse the repository at this point in the history
  • Loading branch information
shartte committed Sep 4, 2024
1 parent 590e6f5 commit 125ac0d
Showing 1 changed file with 4 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -66,21 +66,20 @@ public boolean process(FileSource source, FileSink sink, List<SourceTransformer>
});
}
} else {
AtomicBoolean status = new AtomicBoolean(true);
var success = new AtomicBoolean(true);
try (var asyncOut = new OrderedParallelWorkQueue(sink, maxQueueDepth);
var stream = source.streamEntries()) {
stream.forEach(entry -> asyncOut.submitAsync(parallelSink -> {
try {
var isOk = processEntry(entry, sourceRoot, transformers, parallelSink);
if (!isOk) {
status.set(false);
if (!processEntry(entry, sourceRoot, transformers, parallelSink)) {
success.set(false);
}
} catch (IOException e) {
throw new UncheckedIOException(e);
}
}));
}
if (!status.get()) {
if (!success.get()) {
return false;
}
}
Expand Down

0 comments on commit 125ac0d

Please sign in to comment.