diff --git a/MQTTnet.Core/Client/MqttPacketDispatcher.cs b/MQTTnet.Core/Client/MqttPacketDispatcher.cs index ffbacab..f057b97 100644 --- a/MQTTnet.Core/Client/MqttPacketDispatcher.cs +++ b/MQTTnet.Core/Client/MqttPacketDispatcher.cs @@ -44,13 +44,13 @@ namespace MQTTnet.Core.Client { if (_packetByIdentifier.TryRemove(withIdentifier.PacketIdentifier, out var tcs)) { - packetAwaiter.TrySetResult(packet); + tcs.TrySetResult(packet); packetDispatched = true; } } else if (_packetByResponseType.TryRemove(packet.GetType(), out var tcs) ) { - tcs.SetResult(packet); + tcs.TrySetResult( packet); packetDispatched = true; }