Use synchronous reading of length prefix
This commit is contained in:
parent
f377cd7de1
commit
ca55005c30
|
@ -1,4 +1,4 @@
|
||||||
using System.Collections.Concurrent;
|
using System.Collections.Concurrent;
|
||||||
using System.Net;
|
using System.Net;
|
||||||
using System.Net.Sockets;
|
using System.Net.Sockets;
|
||||||
using System.Reflection;
|
using System.Reflection;
|
||||||
|
@ -96,7 +96,7 @@ public abstract class BaseClientNode : Node
|
||||||
int length;
|
int length;
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
length = await Task.Factory.StartNew(networkReader.ReadInt32, cancellationToken);
|
length = networkReader.ReadInt32();
|
||||||
}
|
}
|
||||||
catch (EndOfStreamException)
|
catch (EndOfStreamException)
|
||||||
{
|
{
|
||||||
|
@ -123,7 +123,7 @@ public abstract class BaseClientNode : Node
|
||||||
int packetHeader;
|
int packetHeader;
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
packetHeader = await Task.Factory.StartNew(bufferReader.ReadInt32, cancellationToken);
|
packetHeader = bufferReader.ReadInt32();
|
||||||
}
|
}
|
||||||
catch (EndOfStreamException)
|
catch (EndOfStreamException)
|
||||||
{
|
{
|
||||||
|
|
Loading…
Reference in New Issue