Removed parameter because the variable is global in class. Renamed

parameter to consumer instead of calllable

1 files changed, 5 insertions, 5 deletions

diff --git a/src/main/java/com/it_jaros/jns/scan/engine/ConsumerThread.java b/src/main/java/com/it_jaros/jns/scan/engine/ConsumerThread.java
index 8bc7fdf..8f93317 100644
--- a/src/main/java/com/it_jaros/jns/scan/engine/ConsumerThread.java
+++ b/src/main/java/com/it_jaros/jns/scan/engine/ConsumerThread.java
@@ -23,15 +23,15 @@ public class ConsumerThread<T> {
      * all results (also partial) collected for the consumer
      * with whatever is there already
      */
-    public void runConsumerLoop(Consumer<PollState<T>> callable) {
+    public void runConsumerLoop(Consumer<PollState<T>> consumer) {
         while (!cancelledToken.isCancelled() && (state.running().get() || state.inPipeline().get() > 0)) {
-            callable.accept(getPollResult(state));
+            consumer.accept(getPollResult());
         }
     }
 
-    private PollState<T> getPollResult(ProducerState<T> state) {
+    private PollState<T> getPollResult() {
         try {
-            return pollResult(state);
+            return pollResult();
         } catch (InterruptedException e) {
             Thread.currentThread().interrupt();
         }
@@ -39,7 +39,7 @@ public class ConsumerThread<T> {
         return new PollState.Unavailable<>();
     }
 
-    private PollState<T> pollResult(ProducerState<T> state) throws InterruptedException {
+    private PollState<T> pollResult() throws InterruptedException {
         Future<T> future = state.completionService().poll(ProducerThread.pollInterval.toMillis(), TimeUnit.MILLISECONDS);
 
         if (future == null) {