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

Configure context.

Browse Source
This commit is contained in:
Gen
2020-04-14 07:37:23 -07:00
parent 79d95c8516
commit 2b2b30912c
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Source/MQTTnet/Implementations/MqttTcpChannel.Uwp.cs
+2 -4
View File
@@ -64,8 +64,7 @@ namespace MQTTnet.Implementations
if (_options.TlsOptions?.UseTls != true)
{
var asyncAction = _socket.ConnectAsync(new HostName(_options.Server), _options.GetPort().ToString());
await asyncAction;
await _socket.ConnectAsync(new HostName(_options.Server), _options.GetPort().ToString()).AsTask().ConfigureAwait(false);
}
else
{
@@ -86,8 +85,7 @@ namespace MQTTnet.Implementations
socketProtectionLevel = SocketProtectionLevel.Tls10;
}
var asyncAction = _socket.ConnectAsync(new HostName(_options.Server), _options.GetPort().ToString(), socketProtectionLevel);
await asyncAction;
await _socket.ConnectAsync(new HostName(_options.Server), _options.GetPort().ToString()).AsTask().ConfigureAwait(false);
}
Endpoint = _socket.Information.RemoteAddress + ":" + _socket.Information.RemotePort;