Let Consumer of PortResults also wait till all threads died instead of

stopping immediatetly on cancellation

1 files changed, 1 insertions, 1 deletions

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);