From 27bb22de0954edd1bf673af6b4f04a896f7a07fb Mon Sep 17 00:00:00 2001 From: Eggers Jan Date: Wed, 13 Sep 2017 09:35:46 +0200 Subject: [PATCH] use buffered receive stream --- MQTTnet.Core/Adapter/MqttChannelCommunicationAdapter.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/MQTTnet.Core/Adapter/MqttChannelCommunicationAdapter.cs b/MQTTnet.Core/Adapter/MqttChannelCommunicationAdapter.cs index 09875e2..a249238 100644 --- a/MQTTnet.Core/Adapter/MqttChannelCommunicationAdapter.cs +++ b/MQTTnet.Core/Adapter/MqttChannelCommunicationAdapter.cs @@ -65,7 +65,7 @@ namespace MQTTnet.Core.Adapter } else { - tuple = await ReceiveAsync(_channel.RawStream).ConfigureAwait(false); + tuple = await ReceiveAsync(_channel.ReceiveStream).ConfigureAwait(false); } var packet = PacketSerializer.Deserialize(tuple.Item1, tuple.Item2);