Fix ProcessExecutorTest

Author: vbauer

src/main/java/com/github/vbauer/avconv4java/util/process/ProcessExecutor.java

@@ -3,12 +3,7 @@
 import com.github.vbauer.avconv4java.util.AVUtils;
 
 import java.util.List;
-import java.util.concurrent.Callable;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-import java.util.concurrent.Future;
-import java.util.concurrent.TimeUnit;
-import java.util.concurrent.TimeoutException;
+import java.util.concurrent.*;
 import java.util.logging.Logger;
 
 /**
@@ -50,12 +45,7 @@ private static ProcessInfo waitWithoutTimeout(final Process process) throws Exce
     private static ProcessInfo waitWithTimeout(final Process process, final long timeout) throws Exception {
         final ExecutorService executor = Executors.newSingleThreadExecutor();
         try {
-            final Callable<ProcessInfo> task = new Callable<ProcessInfo>() {
-                public ProcessInfo call() throws Exception {
-                    return waitWithoutTimeout(process);
-                }
-            };
-            final Future<ProcessInfo> future = executor.submit(task);
+            final Future<ProcessInfo> future = executor.submit(() -> waitWithoutTimeout(process));
             return future.get(timeout, TimeUnit.MILLISECONDS);
         } catch (final TimeoutException ex) {
             return ProcessInfo.error(ex.getMessage());

src/test/java/com/github/vbauer/avconv4java/util/ProcessExecutorTest.java

@@ -1,19 +1,18 @@
 package com.github.vbauer.avconv4java.util;
 
-import java.lang.reflect.Method;
-import java.util.List;
-import java.util.concurrent.ExecutorService;
-
 import com.github.vbauer.avconv4java.common.TestUtils;
 import com.github.vbauer.avconv4java.util.process.ProcessExecutor;
 import com.github.vbauer.avconv4java.util.process.ProcessInfo;
 import org.testng.SkipException;
 import org.testng.annotations.Test;
 import org.testng.collections.Lists;
+
+import java.lang.reflect.Method;
+import java.util.List;
+import java.util.concurrent.ExecutorService;
+
 import static org.hamcrest.MatcherAssert.assertThat;
-import static org.hamcrest.Matchers.equalTo;
-import static org.hamcrest.Matchers.not;
-import static org.hamcrest.Matchers.nullValue;
+import static org.hamcrest.Matchers.*;
 
 /**
  * @author Vladislav Bauer
@@ -73,7 +72,8 @@ public void testShutdownExecutor() throws Exception {
         final Method method = ProcessExecutor.class.getDeclaredMethod("shutdownExecutor", ExecutorService.class);
         method.setAccessible(true);
 
-        assertThat((Boolean) method.invoke(null, new Object[] { null }), equalTo(false));
+        final Object result = method.invoke(null, new Object[]{null});
+        assertThat(result, nullValue());
     }