Increased polling interval

1 files changed, 2 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 df6b30d..659b62b 100644
--- a/src/main/java/com/it_jaros/jscanner/Scanner.java
+++ b/src/main/java/com/it_jaros/jscanner/Scanner.java
@@ -95,7 +95,7 @@ public class Scanner implements AutoCloseable {
     }
 
     private PollState<ScanResult> getHostResult(ProducerState<ScanResult> state) throws InterruptedException {
-        Future<ScanResult> finishedHost = state.completionService().poll(10, TimeUnit.MILLISECONDS);
+        Future<ScanResult> finishedHost = state.completionService().poll(500, TimeUnit.MILLISECONDS);
         if (finishedHost == null) {
             return new PollState.Unavailable<>();
         }
@@ -274,7 +274,7 @@ public class Scanner implements AutoCloseable {
         }
 
         private PollState<PortResult> getPortResult(ProducerState<PortResult> state) throws InterruptedException {
-            Future<PortResult> portResultFuture = state.completionService().poll(10, TimeUnit.MILLISECONDS);
+            Future<PortResult> portResultFuture = state.completionService().poll(500, TimeUnit.MILLISECONDS);
             if (portResultFuture == null) {
                 return new PollState.Unavailable<>();
             }