From 11ba46d140d0674cee4949eeb6125e777fa08773 Mon Sep 17 00:00:00 2001 From: Israel Lot Date: Mon, 16 Apr 2018 14:01:07 -0300 Subject: [PATCH] Remove useless stream flush --- .../Adapter/MqttChannelAdapter.cs | 14 +++++--------- 1 file changed, 5 insertions(+), 9 deletions(-) diff --git a/Frameworks/MQTTnet.NetStandard/Adapter/MqttChannelAdapter.cs b/Frameworks/MQTTnet.NetStandard/Adapter/MqttChannelAdapter.cs index e853d6b9..d84a8a18 100644 --- a/Frameworks/MQTTnet.NetStandard/Adapter/MqttChannelAdapter.cs +++ b/Frameworks/MQTTnet.NetStandard/Adapter/MqttChannelAdapter.cs @@ -76,7 +76,11 @@ namespace MQTTnet.Adapter { return; } - await _channel.SendStream.WriteAsync(packetData.Array, packetData.Offset, (int)packetData.Count, cancellationToken).ConfigureAwait(false); + await _channel.SendStream.WriteAsync( + packetData.Array, + packetData.Offset, + (int)packetData.Count, + cancellationToken).ConfigureAwait(false); } @@ -85,14 +89,6 @@ namespace MQTTnet.Adapter return; } - if (timeout > TimeSpan.Zero) - { - await _channel.SendStream.FlushAsync(cancellationToken).TimeoutAfter(timeout).ConfigureAwait(false); - } - else - { - await _channel.SendStream.FlushAsync(cancellationToken).ConfigureAwait(false); - } }); }