Intercepting Publish on server does not return the correct status code to the client about mqttnet HOT 3 CLOSED

       [Test]
    public async Task TestCancelPublish()
    {
        var testTopic = "test/topic";
        var mqttFactory = new MqttFactory();
        var mqttServerOptions = new MqttServerOptionsBuilder()
            .WithDefaultEndpoint()
            .Build();
        using (var mqttServer = mqttFactory.CreateMqttServer(mqttServerOptions))
        {
            await mqttServer.StartAsync();
            bool messageInterceptedOnServer = false;
            
            mqttServer.InterceptingPublishAsync += async (args) =>
            {
                // intercept server message and set reason code to NotAuthorized
                args.Response.ReasonCode = MqttPubAckReasonCode.NotAuthorized;
                args.Response.ReasonString = "Not Authorized";
                messageInterceptedOnServer = true;
            };

            using (var client1 = mqttFactory.CreateMqttClient())
            {
                var client1Options = new MqttClientOptionsBuilder()
                    .WithTcpServer("localhost")
                    .WithClientId(Guid.NewGuid().ToString())
                    .WithProtocolVersion(MQTTnet.Formatter.MqttProtocolVersion.V500)
                    .Build();
                
                await client1.ConnectAsync(client1Options, CancellationToken.None);

                using(var client2 = mqttFactory.CreateMqttClient())
                {
                    var client2Options = new MqttClientOptionsBuilder()
                        .WithTcpServer("localhost")
                        .WithClientId(Guid.NewGuid().ToString())
                        .WithProtocolVersion(MQTTnet.Formatter.MqttProtocolVersion.V500)
                        .Build();
                    await client2.ConnectAsync(client2Options, CancellationToken.None);
                    await client2.SubscribeAsync(testTopic,MqttQualityOfServiceLevel.AtLeastOnce);

                    // publish the message
                    var res = await client1.PublishStringAsync(testTopic, "hello",MqttQualityOfServiceLevel.AtLeastOnce);

                    while (messageInterceptedOnServer == false)
                    {
                        await Task.Delay(300);
                    }

                    await client2.DisconnectAsync();
                    // Now get not authorized
                    Assert.AreEqual(res.ReasonCode, MqttClientPublishReasonCode.NotAuthorized);

                }
                await client1.DisconnectAsync();
            }

            await mqttServer.StopAsync();
        }
    }