diff options
| -rw-r--r-- | src/main/java/com/it_jaros/jscanner/Scanner.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/main/java/com/it_jaros/jscanner/Scanner.java b/src/main/java/com/it_jaros/jscanner/Scanner.java index 775c0d5..770cb2b 100644 --- a/src/main/java/com/it_jaros/jscanner/Scanner.java +++ b/src/main/java/com/it_jaros/jscanner/Scanner.java @@ -244,8 +244,9 @@ public class Scanner implements AutoCloseable { ); // consumer is the main thread - // we run as long as the producer is running or as long as things are in pipeline to be processed - // only exception is when cancelled is set + // we run as long as the producer is running OR + // as long as things are in pipeline waiting to be processed + // ONLY exception is when cancelled is set final PortResultAccumulator accumulator = new PortResultAccumulator(host); while (!cancelled && (state.running().get() || state.inPipeline().get() > 0)) { try { |