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

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