Browse Source

fixed tests

release/3.x.x
JanEggers 6 years ago
parent
commit
8c37cf16c0
2 changed files with 2 additions and 2 deletions
  1. +1
    -1
      Frameworks/MQTTnet.NetStandard/Serializer/MqttPacketSerializer.cs
  2. +1
    -1
      Frameworks/MQTTnet.NetStandard/Serializer/MqttPacketWriter.cs

+ 1
- 1
Frameworks/MQTTnet.NetStandard/Serializer/MqttPacketSerializer.cs View File

@@ -397,7 +397,7 @@ namespace MQTTnet.Serializer
throw new MqttProtocolViolationException("Protocol version not supported."); throw new MqttProtocolViolationException("Protocol version not supported.");
} }


stream.Write((byte)packet.ConnectReturnCode);
stream.WriteByte((byte)packet.ConnectReturnCode);


return MqttPacketWriter.BuildFixedHeader(MqttControlPacketType.ConnAck); return MqttPacketWriter.BuildFixedHeader(MqttControlPacketType.ConnAck);
} }


+ 1
- 1
Frameworks/MQTTnet.NetStandard/Serializer/MqttPacketWriter.cs View File

@@ -25,7 +25,7 @@ namespace MQTTnet.Serializer
{ {
if (value == null) throw new ArgumentNullException(nameof(value)); if (value == null) throw new ArgumentNullException(nameof(value));


stream.Write(value.Value);
stream.WriteByte(value.Value);
} }


public static void WriteWithLengthPrefix(this Stream stream, string value) public static void WriteWithLengthPrefix(this Stream stream, string value)


Loading…
Cancel
Save