From 495bf8931ffe850474fe6dd9affd7f431ddf1c52 Mon Sep 17 00:00:00 2001
From: nathan <nathan@dorkbox.com>
Date: Fri, 11 Sep 2020 03:30:00 +0200
Subject: [PATCH] Added test for media driver disconnects in same JVM

---
 .../network/DisconnectReconnectTest.kt        | 45 +++++++++++++++++++
 1 file changed, 45 insertions(+)

diff --git a/test/dorkboxTest/network/DisconnectReconnectTest.kt b/test/dorkboxTest/network/DisconnectReconnectTest.kt
index 61117d05..9d9614bb 100644
--- a/test/dorkboxTest/network/DisconnectReconnectTest.kt
+++ b/test/dorkboxTest/network/DisconnectReconnectTest.kt
@@ -125,4 +125,49 @@ class DisconnectReconnectTest : BaseTest() {
         System.err.println("Connection count (after reconnecting) is: " + reconnectCount.value)
         Assert.assertEquals(4, reconnectCount.value)
     }
+
+    @Test
+    fun disconenctedMediaDriver() {
+        val server: Server<Connection>
+        run {
+            val config = serverConfig()
+            config.enableIpc = false
+            config.aeronDirectoryForceUnique = true
+
+            server = Server(config)
+            addEndPoint(server)
+            server.bind()
+
+            server.onConnect { connection ->
+                connection.logger.error("Connected!")
+            }
+        }
+
+        val client: Client<Connection>
+        run {
+            val config = clientConfig()
+            config.enableIpc = false
+            config.aeronDirectoryForceUnique = true
+
+            client = Client(config)
+            addEndPoint(client)
+
+            client.onConnect { connection ->
+                connection.logger.error("Connected!")
+            }
+
+            client.onDisconnect {
+                stopEndPoints()
+            }
+
+            runBlocking {
+                client.connect(LOOPBACK)
+            }
+        }
+
+        server.close()
+
+
+        waitForThreads()
+    }
 }