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

Remove obsolete methods.

Browse Source
This commit is contained in:
Christian Kratky
2019-03-24 10:05:38 +01:00
parent 11a5b5a080
commit d0f1659eec
3 changed files with 7 additions and 53 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Source/MQTTnet/Server/MqttClientConnection.cs
+7 -5
View File
@@ -138,7 +138,9 @@ namespace MQTTnet.Server
Session.WillMessage = _connectPacket.WillMessage;
Task.Run(() => SendPendingPacketsAsync(), _cancellationToken.Token);
#pragma warning disable 4014
Task.Run(() => SendPendingPacketsAsync(_cancellationToken.Token), _cancellationToken.Token);
#pragma warning restore 4014
// TODO: Change to single thread in SessionManager. Or use SessionManager and stats from KeepAliveMonitor.
_keepAliveMonitor.Start(_connectPacket.KeepAlivePeriod, _cancellationToken.Token);
@@ -372,22 +374,22 @@ namespace MQTTnet.Server
//await Task.FromResult(0);
}
private async Task SendPendingPacketsAsync()
private async Task SendPendingPacketsAsync(CancellationToken cancellationToken)
{
MqttPendingApplicationMessage queuedApplicationMessage = null;
MqttPublishPacket publishPacket = null;
try
{
while (!_cancellationToken.IsCancellationRequested)
while (!cancellationToken.IsCancellationRequested)
{
queuedApplicationMessage = await Session.ApplicationMessagesQueue.TakeAsync(_cancellationToken.Token).ConfigureAwait(false);
queuedApplicationMessage = await Session.ApplicationMessagesQueue.TakeAsync(cancellationToken).ConfigureAwait(false);
if (queuedApplicationMessage == null)
{
return;
}
if (_cancellationToken.IsCancellationRequested)
if (cancellationToken.IsCancellationRequested)
{
return;
}