While publishing with websocket - server close

[TomaszKustra]

When i want to publish payload with topic - MqttChannelAdapter using MqttWebSocketChannel w'll send first topic (packet) and then payload - each time MqttWebSocketChannel send data with "endOfMessage" param "true".
For me server (i don't knwo implementation i'm calling only uwing API description) - closing seocket.
When i changed MqttChannelAdapter method to:

                    if (_channel is MqttWebSocketChannel)
                    {
                        var buff=packetBuffer.ToArray();                        
                        await _channel.WriteAsync(buff, 0, buff.Length, cancellationToken).ConfigureAwait(false);
                    }
                    else
                    {
                        await _channel.WriteAsync(packetBuffer.Packet.Array, packetBuffer.Packet.Offset,
                            packetBuffer.Packet.Count, cancellationToken).ConfigureAwait(false);

                        if (packetBuffer.Payload.Count > 0)
                        {
                            await _channel.WriteAsync(packetBuffer.Payload.Array, packetBuffer.Payload.Offset,
                                packetBuffer.Payload.Count, cancellationToken).ConfigureAwait(false);
                        }
                    }

working form me.

Maybe adding the "SendAtOnce" property to the MqttChannelAdapter and sending the packet in whole or in parts depending on it would solve the problem permanently.

[chkr1011]

Please check version 4.1.0.269 from the myget feed. It contains a fix. Please let me know if it works.

[chkr1011]

I was wrong. Please test version 4.1.272 from myget feed (see README) and let me know if it works now.