From 28d31d0cf52022808096d58e04d24759750d7544 Mon Sep 17 00:00:00 2001 From: 1iveowl Date: Sun, 24 Sep 2017 17:03:29 +0200 Subject: [PATCH] Increased PR quality --- .../Adapter/MqttChannelCommunicationAdapter.cs | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/MQTTnet.Core/Adapter/MqttChannelCommunicationAdapter.cs b/MQTTnet.Core/Adapter/MqttChannelCommunicationAdapter.cs index f439a52..8eb47a9 100644 --- a/MQTTnet.Core/Adapter/MqttChannelCommunicationAdapter.cs +++ b/MQTTnet.Core/Adapter/MqttChannelCommunicationAdapter.cs @@ -83,7 +83,7 @@ namespace MQTTnet.Core.Adapter { foreach (var packet in packets) { - if (packet == null) continue; + if (packet == null) {continue}; MqttTrace.Information(nameof(MqttChannelCommunicationAdapter), $"TX >>> {packet} [Timeout={timeout}]"); @@ -93,7 +93,7 @@ namespace MQTTnet.Core.Adapter if (timeout > TimeSpan.Zero) { - _sendTask = _sendTask.ContinueWith(c => _channel.SendStream.FlushAsync(cancellationToken).TimeoutAfter(timeout), cancellationToken);// _channel.SendStream.FlushAsync(cancellationToken).TimeoutAfter(timeout);//.ConfigureAwait(false); + _sendTask = _sendTask.ContinueWith(c => _channel.SendStream.FlushAsync(cancellationToken).TimeoutAfter(timeout), cancellationToken).ConfigureAwait(false); } else { @@ -105,17 +105,17 @@ namespace MQTTnet.Core.Adapter await _sendTask; // configure await false generates stackoverflow } - catch (TaskCanceledException ex) + catch (TaskCanceledException) { - throw ex; + throw; } - catch (MqttCommunicationTimedOutException ex) + catch (MqttCommunicationTimedOutException) { - throw ex; + throw; } - catch (MqttCommunicationException ex) + catch (MqttCommunicationException) { - throw ex; + throw; } catch (Exception exception) { @@ -190,4 +190,4 @@ namespace MQTTnet.Core.Adapter return new ReceivedMqttPacket(header, new MemoryStream(body, 0, body.Length)); } } -} \ No newline at end of file +}