|
|
@@ -154,7 +154,11 @@ namespace MQTTnet.Implementations |
|
|
|
|
|
|
|
private void CreateStreams() |
|
|
|
{ |
|
|
|
_readStream = _socket.InputStream.AsStreamForRead(_bufferSize); |
|
|
|
// Attention! Do not set the buffer for the read method. This will |
|
|
|
// limit the internal buffer and the read operation will hang forever |
|
|
|
// is more data than the buffer size was received. |
|
|
|
_readStream = _socket.InputStream.AsStreamForRead(); |
|
|
|
|
|
|
|
_writeStream = _socket.OutputStream.AsStreamForWrite(_bufferSize); |
|
|
|
} |
|
|
|
|
|
|
|