Improve Unit Tests.

2026-10-20 19:58:57 +08:00 · 2020-10-31 11:33:44 +01:00
parent 838d50c1d3
commit 34ae54d542
2 changed files with 17 additions and 4 deletions
@@ -471,11 +471,19 @@ namespace MQTTnet.Tests
                var client1 = await testEnvironment.ConnectClientAsync(options);
                await Task.Delay(500);

+                MqttClientDisconnectReason disconnectReason = MqttClientDisconnectReason.NormalDisconnection;
+                client1.DisconnectedHandler = new MqttClientDisconnectedHandlerDelegate(c =>
+                {
+                    disconnectReason = c.Reason;
+                });
+
                var client2 = await testEnvironment.ConnectClientAsync(options);
                await Task.Delay(500);

                Assert.IsFalse(client1.IsConnected);
                Assert.IsTrue(client2.IsConnected);
+
+                Assert.AreEqual(MqttClientDisconnectReason.SessionTakenOver, disconnectReason);
            }
        }