В книге Албахари "C# 6.0 in a Nutshell" написано следующее:
В действительности класс
StreamReader
абсолютно запрещено применять вместе сNetworkStream
, даже если вы планируете вызывать только методReadLine
. Причина в том, что класс StreamReader имеет буфер опережающего чтения, который может привести к чтению большего числа байтов, чем доступно в текущий момент, и бесконечному блокированию (или до возникновения тайм-аута сокета). Другие потоки, такие какFileStream
, не страдают подобной несовместимостью с классомStreamReader
, потому что они поддерживают определенный признак окончания, при достижении которого методRead
немедленно завершается, возвращая значение0
.
Какая ошибка, например, в этом классе?
public class AsyncSocket : IDisposable
{
Socket socket;
StreamReader sr;
public AsyncSocket()
{
socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
sr = new StreamReader(new NetworkStream(socket));
}
// ... остальные члены убраны
public async Task<string> ReadLineAsync()
{
return await sr.ReadLineAsync();
}
public void Dispose()
{
if (sr != null) sr.Close();
if (socket != null) socket.Dispose();
}
}
Допустим, пришла строка "123\r\nqwe". StreamReader
считает всю её в свой внутренний буфер при вызове ReadLineAsync()
вернет "123". Данные из внутреннего буфера не удаляются же? При втором вызове ReadLineAsync()
завершится, когда придет конец строки и в результатом вернется "qwe".
Албахари пишет про бесконечное блокирование, так к нему может привести и обычный метод Read
, если никакие данные не будут отправлены сокету.
Объясните почему нельзя использовать класс StreamReader
вместе с NetworkStream
?