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);