From aeb4b5ff81d997c432a421eeb36b019884745104 Mon Sep 17 00:00:00 2001
From: Matthias Jaros <jarlucmat@mailbox.org>
Date: Fri, 21 Aug 2026 18:35:43 +0200
Subject: Let Consumer of PortResults also wait till all threads died instead
 of stopping immediatetly on cancellation

---
 src/main/java/com/it_jaros/jns/scan/engine/ScanHostTask.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/com/it_jaros/jns/scan/engine/ScanHostTask.java b/src/main/java/com/it_jaros/jns/scan/engine/ScanHostTask.java
index 4a77cb1..b3b062b 100644
--- a/src/main/java/com/it_jaros/jns/scan/engine/ScanHostTask.java
+++ b/src/main/java/com/it_jaros/jns/scan/engine/ScanHostTask.java
@@ -100,7 +100,7 @@ public class ScanHostTask implements Callable<ScanResult> {
      * ONLY exception is when cancelled is set
      */
     private void runConsumerLoop(ProducerState<PortResult> state) {
-        while (!cancelledToken.isCancelled() && (state.running().get() || state.inPipeline().get() > 0)) {
+        while (state.running().get() || state.inPipeline().get() > 0) {
             PollState<PortResult> poll = getPortResult(state);
             if (poll instanceof PollState.Success<PortResult>(PortResult value)) {
                 accumulator.add(value);
-- 
cgit v1.3.1