testcontainers#291 use ByteStreams

bsideup · Feb 21, 2017 · ed0f64d · ed0f64d
1 parent fa7e9d9
commit ed0f64d
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/.../src/main/java/org/testcontainers/dockerclient/NamedPipeSocketClientProviderStrategy.java b/.../src/main/java/org/testcontainers/dockerclient/NamedPipeSocketClientProviderStrategy.java
@@ -2,9 +2,9 @@
 
 import com.github.dockerjava.core.DefaultDockerClientConfig;
 import com.github.dockerjava.core.DockerClientConfig;
+import com.google.common.io.ByteStreams;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.io.IOUtils;
 import org.jetbrains.annotations.NotNull;
 
 import java.io.*;
@@ -89,27 +89,27 @@ InetSocketAddress start() throws IOException {
                             executorService.submit(() -> {
                                 try (RandomAccessFile randomAccessFile = new RandomAccessFile(file, "rw")) {
                                     log.info("Created RandomAccessFile from " + file);
-                                    Future<Integer> inputFuture = executorService.submit(() -> {
+                                    Future<Long> inputFuture = executorService.submit(() -> {
                                         try (
                                                 InputStream in = incomingSocket.getInputStream();
                                                 FileOutputStream out = new FileOutputStream(randomAccessFile.getFD())
                                         ) {
-                                            return IOUtils.copy(in, out);
+                                            return ByteStreams.copy(in, out);
                                         } catch (Exception e) {
                                             log.warn("", e);
-                                            return -1;
+                                            return null;
                                         }
                                     });
 
-                                    Future<Integer> outputFuture = executorService.submit(() -> {
+                                    Future<Long> outputFuture = executorService.submit(() -> {
                                         try (
                                                 FileInputStream in = new FileInputStream(randomAccessFile.getFD());
                                                 OutputStream out = incomingSocket.getOutputStream()
                                         ) {
-                                            return IOUtils.copy(in, out);
+                                            return ByteStreams.copy(in, out);
                                         } catch (Exception e) {
                                             log.warn("", e);
-                                            return -1;
+                                            return null;
                                         }
                                     });