1 files changed, 4 insertions, 4 deletions
diff --git a/caliper/src/main/java/com/google/caliper/runner/StreamService.java b/caliper/src/main/java/com/google/caliper/runner/StreamService.java
index a5852d0..4b8928a 100644
--- a/caliper/src/main/java/com/google/caliper/runner/StreamService.java
+++ b/caliper/src/main/java/com/google/caliper/runner/StreamService.java
@@ -158,11 +158,11 @@ import javax.inject.Inject;
     Charset processCharset = Charset.defaultCharset();
     runningReadStreams.addAndGet(2);
     openStreams.addAndGet(1);
-    streamExecutor.submit(
+    ListenableFuture possiblyIgnoredError1 = streamExecutor.submit(
         threadRenaming("worker-stderr", 
             new StreamReader("stderr", 
                 new InputStreamReader(process.getErrorStream(), processCharset))));
-    streamExecutor.submit(
+    ListenableFuture possiblyIgnoredError2 = streamExecutor.submit(
         threadRenaming("worker-stdout",
             new StreamReader("stdout", 
                 new InputStreamReader(process.getInputStream(), processCharset))));
@@ -176,7 +176,7 @@ import javax.inject.Inject;
               socketWriter = openedSocket.writer();
               runningReadStreams.addAndGet(1);
               openStreams.addAndGet(1);
-              streamExecutor.submit(threadRenaming("worker-socket",
+              ListenableFuture possiblyIgnoredError = streamExecutor.submit(threadRenaming("worker-socket",
                   new SocketStreamReader(openedSocket.reader())));
             } catch (ExecutionException e) {
               notifyFailed(e.getCause());
@@ -250,7 +250,7 @@ import javax.inject.Inject;
     // Experimentally, even with well behaved processes there is some time between when all streams
     // are closed as part of process shutdown and when the process has exited. So to not fail 
     // flakily when shutting down normally we need to do a timed wait
-    streamExecutor.submit(new Callable<Void>() {
+    ListenableFuture possiblyIgnoredError = streamExecutor.submit(new Callable<Void>() {
       @Override public Void call() throws Exception {
         boolean threw = true;
         try {