#291 close streams

testcontainers · Feb 21, 2017 · 153e187 · 153e187
1 parent 0e093e4
commit 153e187
Showing 1 changed file with 16 additions and 2 deletions.
diff --git a/.../src/main/java/org/testcontainers/dockerclient/NamedPipeSocketClientProviderStrategy.java b/.../src/main/java/org/testcontainers/dockerclient/NamedPipeSocketClientProviderStrategy.java
@@ -63,8 +63,22 @@ InetSocketAddress start() throws IOException {
                             Socket incomingSocket = listenSocket.accept();
                             log.debug("Accepting incoming connection from {}", incomingSocket.getRemoteSocketAddress());
 
-                            executorService.submit(() -> IOUtils.copyLarge(incomingSocket.getInputStream(), new FileOutputStream(randomAccessFile.getFD())));
-                            executorService.submit(() -> IOUtils.copyLarge(new FileInputStream(randomAccessFile.getFD()), incomingSocket.getOutputStream()));
+                            executorService.submit(() -> {
+                                try (
+                                        InputStream in = incomingSocket.getInputStream();
+                                        FileOutputStream out = new FileOutputStream(randomAccessFile.getFD())
+                                ) {
+                                    return IOUtils.copyLarge(in, out);
+                                }
+                            });
+                            executorService.submit(() -> {
+                                try (
+                                        FileInputStream in = new FileInputStream(randomAccessFile.getFD());
+                                        OutputStream out = incomingSocket.getOutputStream()
+                                ) {
+                                    return IOUtils.copyLarge(in, out);
+                                }
+                            });
 
                         } catch (IOException e) {
                             log.warn("", e);