From ca55005c302b29a27873f3db5c30af8e7a3d3fb1 Mon Sep 17 00:00:00 2001 From: Oliver Booth Date: Mon, 23 Jan 2023 10:50:36 +0000 Subject: [PATCH] Use synchronous reading of length prefix --- TcpDotNet/BaseClientNode.cs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/TcpDotNet/BaseClientNode.cs b/TcpDotNet/BaseClientNode.cs index a9744a2..a9f9cd8 100644 --- a/TcpDotNet/BaseClientNode.cs +++ b/TcpDotNet/BaseClientNode.cs @@ -1,4 +1,4 @@ -using System.Collections.Concurrent; +using System.Collections.Concurrent; using System.Net; using System.Net.Sockets; using System.Reflection; @@ -96,7 +96,7 @@ public abstract class BaseClientNode : Node int length; try { - length = await Task.Factory.StartNew(networkReader.ReadInt32, cancellationToken); + length = networkReader.ReadInt32(); } catch (EndOfStreamException) { @@ -123,7 +123,7 @@ public abstract class BaseClientNode : Node int packetHeader; try { - packetHeader = await Task.Factory.StartNew(bufferReader.ReadInt32, cancellationToken); + packetHeader = bufferReader.ReadInt32(); } catch (EndOfStreamException) {