Merge pull request #2 from eed3si9n/wip/test

Test cleans after itself

Author: eed3si9n

src/test/java/org/scalasbt/ipcsocket/UnixDomainSocketTest.java

@@ -13,16 +13,18 @@
 import java.net.ServerSocket;
 import java.net.Socket;
 import java.util.concurrent.CompletableFuture;
+import java.util.Random;
 
 public class UnixDomainSocketTest {
   @Test
   public void testAssertEquals() throws IOException, InterruptedException {
+    Random rand = new Random();
     Path tempDir = Files.createTempDirectory("ipcsocket");
-    Path sock = tempDir.resolve("foo.sock");
+    Path sock = tempDir.resolve("foo" + rand.nextInt() + ".sock");
+    ServerSocket serverSocket = new UnixDomainServerSocket(sock.toString());
 
     CompletableFuture<Boolean> server = CompletableFuture.supplyAsync(() -> {
       try {
-        ServerSocket serverSocket = new UnixDomainServerSocket(sock.toString());
         EchoServer echo = new EchoServer(serverSocket);
         echo.run();
       } catch (IOException e) { }
@@ -39,6 +41,7 @@ public void testAssertEquals() throws IOException, InterruptedException {
     String line = in.readLine();
     client.close();
     server.cancel(true);
+    serverSocket.close();
     assertEquals("echo did not return the content", line, "hello");
   }
 }

src/test/java/org/scalasbt/ipcsocket/Win32NamedPipeSocketTest.java

@@ -13,14 +13,16 @@
 import java.net.ServerSocket;
 import java.net.Socket;
 import java.util.concurrent.CompletableFuture;
+import java.util.Random;
 
 public class Win32NamedPipeSocketTest {
   @Test
   public void testAssertEquals() throws IOException, InterruptedException {
-    String pipeName = "\\\\.\\pipe\\ipcsockettest";
+    Random rand = new Random();
+    String pipeName = "\\\\.\\pipe\\ipcsockettest" + rand.nextInt();
+    ServerSocket serverSocket = new Win32NamedPipeServerSocket(pipeName);
     CompletableFuture<Boolean> server = CompletableFuture.supplyAsync(() -> {
       try {
-        ServerSocket serverSocket = new Win32NamedPipeServerSocket(pipeName);
         EchoServer echo = new EchoServer(serverSocket);
         echo.run();
       } catch (IOException e) { }
@@ -38,6 +40,7 @@ public void testAssertEquals() throws IOException, InterruptedException {
     System.out.println("windows client: " + line);
     client.close();
     server.cancel(true);
+    serverSocket.close();
     assertEquals("echo did not return the content", line, "hello");
   }
 }