From 8d784554146b8bbc4e28273e8af73875132bdb66 Mon Sep 17 00:00:00 2001 From: Christian Kratky Date: Fri, 16 Nov 2018 22:18:59 +0100 Subject: [PATCH] Fix breaking changes. --- Source/MQTTnet.AspnetCore/MqttConnectionContext.cs | 2 +- Tests/MQTTnet.AspNetCore.Tests/MqttConnectionContextTest.cs | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/Source/MQTTnet.AspnetCore/MqttConnectionContext.cs b/Source/MQTTnet.AspnetCore/MqttConnectionContext.cs index 56c094c0..1b54ef55 100644 --- a/Source/MQTTnet.AspnetCore/MqttConnectionContext.cs +++ b/Source/MQTTnet.AspnetCore/MqttConnectionContext.cs @@ -107,7 +107,7 @@ namespace MQTTnet.AspNetCore public async Task SendPacketAsync(MqttBasePacket packet, CancellationToken cancellationToken) { - var buffer = PacketSerializer.Serialize(packet).AsMemory(); + var buffer = PacketSerializerAdapter.Serialize(packet).AsMemory(); var output = Connection.Transport.Output; await _writerSemaphore.WaitAsync(cancellationToken).ConfigureAwait(false); diff --git a/Tests/MQTTnet.AspNetCore.Tests/MqttConnectionContextTest.cs b/Tests/MQTTnet.AspNetCore.Tests/MqttConnectionContextTest.cs index 699aa65b..2ec621de 100644 --- a/Tests/MQTTnet.AspNetCore.Tests/MqttConnectionContextTest.cs +++ b/Tests/MQTTnet.AspNetCore.Tests/MqttConnectionContextTest.cs @@ -17,7 +17,7 @@ namespace MQTTnet.AspNetCore.Tests [TestMethod] public async Task TestReceivePacketAsyncThrowsWhenReaderCompleted() { - var serializer = new MqttPacketSerializer {}; + var serializer = new MqttPacketSerializerAdapter(MqttProtocolVersion.V311); var pipe = new DuplexPipeMockup(); var connection = new DefaultConnectionContext(); connection.Transport = pipe; @@ -31,7 +31,7 @@ namespace MQTTnet.AspNetCore.Tests [TestMethod] public async Task TestParallelWrites() { - var serializer = new MqttPacketSerializer { }; + var serializer = new MqttPacketSerializerAdapter(MqttProtocolVersion.V311); var pipe = new DuplexPipeMockup(); var connection = new DefaultConnectionContext(); connection.Transport = pipe;