Comments refactored

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 {