From 87968f3be184a6c97071ce4d89e4a8789707f243 Mon Sep 17 00:00:00 2001
From: Matthias Jaros <jarlucmat@mailbox.org>
Date: Fri, 7 Aug 2026 22:36:43 +0200
Subject: Created central variable for poll interval. Set interval even higher
 than before since it only affects reaction time to idle events and does not
 effect performance when data arrives

---
 src/main/java/com/it_jaros/jscanner/Scanner.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

(limited to 'src')

diff --git a/src/main/java/com/it_jaros/jscanner/Scanner.java b/src/main/java/com/it_jaros/jscanner/Scanner.java
index beeb62e..71933a9 100644
--- a/src/main/java/com/it_jaros/jscanner/Scanner.java
+++ b/src/main/java/com/it_jaros/jscanner/Scanner.java
@@ -17,6 +17,7 @@ import java.util.function.Function;
 
 public class Scanner implements AutoCloseable {
 
+    private static final Duration pollInterval = Duration.ofSeconds(1);
     private static final int READ_BUFFER_SIZE = 1024;
 
     private volatile boolean cancelled = false;
@@ -96,7 +97,7 @@ public class Scanner implements AutoCloseable {
     }
 
     private PollState<ScanResult> getHostResult(ProducerState<ScanResult> state) throws InterruptedException {
-        Future<ScanResult> finishedHost = state.completionService().poll(500, TimeUnit.MILLISECONDS);
+        Future<ScanResult> finishedHost = state.completionService().poll(pollInterval.toMillis(), TimeUnit.MILLISECONDS);
         if (finishedHost == null) {
             return new PollState.Unavailable<>();
         }
@@ -277,7 +278,7 @@ public class Scanner implements AutoCloseable {
         }
 
         private PollState<PortResult> getPortResult(ProducerState<PortResult> state) throws InterruptedException {
-            Future<PortResult> portResultFuture = state.completionService().poll(500, TimeUnit.MILLISECONDS);
+            Future<PortResult> portResultFuture = state.completionService().poll(pollInterval.toMillis(), TimeUnit.MILLISECONDS);
             if (portResultFuture == null) {
                 return new PollState.Unavailable<>();
             }
-- 
cgit v1.3.1