diff --git a/Source/MQTTnet/Implementations/PlatformAbstractionLayer.cs b/Source/MQTTnet/Implementations/PlatformAbstractionLayer.cs index a940eac5..ee9057a4 100644 --- a/Source/MQTTnet/Implementations/PlatformAbstractionLayer.cs +++ b/Source/MQTTnet/Implementations/PlatformAbstractionLayer.cs @@ -88,5 +88,17 @@ namespace MQTTnet.Implementations #endif } + public static Task CompletedTask + { + get + { +#if NET452 + return Task.FromResult(0); +#else + return Task.CompletedTask; +#endif + } + } + } } diff --git a/Source/MQTTnet/Server/MqttRetainedMessagesManager.cs b/Source/MQTTnet/Server/MqttRetainedMessagesManager.cs index c4e2f966..f4ebe487 100644 --- a/Source/MQTTnet/Server/MqttRetainedMessagesManager.cs +++ b/Source/MQTTnet/Server/MqttRetainedMessagesManager.cs @@ -3,6 +3,7 @@ using System.Collections.Generic; using System.Linq; using System.Threading.Tasks; using MQTTnet.Diagnostics; +using MQTTnet.Implementations; using MQTTnet.Internal; namespace MQTTnet.Server @@ -21,7 +22,7 @@ namespace MQTTnet.Server if (logger == null) throw new ArgumentNullException(nameof(logger)); _logger = logger.CreateChildLogger(nameof(MqttRetainedMessagesManager)); _options = options ?? throw new ArgumentNullException(nameof(options)); - return Task.CompletedTask; + return PlatformAbstractionLayer.CompletedTask; } public async Task LoadMessagesAsync()