Skip to content

Commit 4fe5bb3

Browse files
Fixed network stream reading
1 parent 3bdf8cd commit 4fe5bb3

File tree

1 file changed

+7
-6
lines changed

1 file changed

+7
-6
lines changed

Meshtastic/Connections/TcpConnection.cs

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -58,15 +58,16 @@ public override async Task ReadFromRadio(Func<FromRadio, DeviceStateContainer, T
5858
if (networkStream == null)
5959
throw new ApplicationException("Could not establish network stream");
6060

61-
var buffer = new byte[DEFAULT_BUFFER_SIZE];
62-
while (networkStream.CanRead)
63-
{
64-
await networkStream.ReadExactlyAsync(buffer);
65-
foreach (var item in buffer)
61+
var buffer = new byte[DEFAULT_BUFFER_SIZE];
62+
int bytesRead = await networkStream.ReadAsync(buffer, 0, buffer.Length);
63+
while (bytesRead > 0)
64+
{
65+
for (int i = 0; i < bytesRead; i++)
6666
{
67-
if (await ParsePackets(item, isComplete))
67+
if (await ParsePackets(buffer[i], isComplete))
6868
return;
6969
}
70+
bytesRead = await networkStream.ReadAsync(buffer, 0, buffer.Length);
7071
}
7172
}
7273

0 commit comments

Comments
 (0)