YangWX/MQTTnet
1
0
Fork 0
mirror of https://github.com/dotnet/MQTTnet.git synced 2026-10-16 17:23:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

Changed MqttServerClientDisconnectedHandlerDelegate back again.

Browse Source
This commit is contained in:
SeppPenner
2020-09-27 17:43:06 +02:00
parent 21a9974e5d
commit 252772007b
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Source/MQTTnet/Server/MqttServerClientDisconnectedHandlerDelegate.cs
+8 -8
View File
@@ -5,27 +5,27 @@ namespace MQTTnet.Server
{
public class MqttServerClientDisconnectedHandlerDelegate : IMqttServerClientDisconnectedHandler
{
private readonly Func<MqttServerClientDisconnectedEventArgs, Task> _callback;
private readonly Func<MqttServerClientDisconnectedEventArgs, Task> _handler;
public MqttServerClientDisconnectedHandlerDelegate(Action<MqttServerClientDisconnectedEventArgs> callback)
public MqttServerClientDisconnectedHandlerDelegate(Action<MqttServerClientDisconnectedEventArgs> handler)
{
if (callback == null) throw new ArgumentNullException(nameof(callback));
if (handler == null) throw new ArgumentNullException(nameof(handler));
_callback = eventArgs =>
_handler = eventArgs =>
{
callback(eventArgs);
handler(eventArgs);
return Task.FromResult(0);
};
}
public MqttServerClientDisconnectedHandlerDelegate(Func<MqttServerClientDisconnectedEventArgs, Task> callback)
public MqttServerClientDisconnectedHandlerDelegate(Func<MqttServerClientDisconnectedEventArgs, Task> handler)
{
_callback = callback ?? throw new ArgumentNullException(nameof(callback));
_handler = handler ?? throw new ArgumentNullException(nameof(handler));
}
public Task HandleClientDisconnectedAsync(MqttServerClientDisconnectedEventArgs eventArgs)
{
return _callback(eventArgs);
return _handler(eventArgs);
}
}
}