prove there is something wrong

2026-10-15 17:00:03 +08:00 · 2018-07-19 21:13:27 +02:00
parent 773fd09166
commit 21048b51ae
1 changed files with 26 additions and 0 deletions
@@ -233,6 +233,32 @@ namespace MQTTnet.Core.Tests
                await c1.PublishAsync(message);
            }
        }
+        
+        [TestMethod]
+        public async Task MqttServer_ShutdownDisconnectsClientsGracefully()
+        {
+            var serverAdapter = new MqttTcpServerAdapter(new MqttNetLogger().CreateChildLogger());
+            var s = new MqttFactory().CreateMqttServer(new[] { serverAdapter }, new MqttNetLogger());
+
+            var clientOptions = new MqttClientOptionsBuilder()
+                .WithTcpServer("localhost")
+                .Build();
+
+            bool disconnectCalled = false;
+
+            await s.StartAsync(new MqttServerOptions());
+
+            var c1 = new MqttFactory().CreateMqttClient();
+            c1.Disconnected += (sender, args) => disconnectCalled = true;
+
+            await c1.ConnectAsync(clientOptions);
+
+            await s.StopAsync();
+
+            await Task.Delay(500);
+
+            Assert.IsTrue(disconnectCalled);
+        }

        [TestMethod]
        public async Task MqttServer_RetainedMessagesFlow()