|
@@ -56,6 +56,7 @@ namespace EVCB_OCPP.WSServer.Service.WsService
|
|
|
|
|
|
private async Task StartReceivd(WebSocket webSocket, CancellationToken token)
|
|
|
{
|
|
|
+ string received = string.Empty;
|
|
|
while (!token.IsCancellationRequested)
|
|
|
{
|
|
|
var buffer = new byte[1024 * 4];
|
|
@@ -65,10 +66,14 @@ namespace EVCB_OCPP.WSServer.Service.WsService
|
|
|
_ = InternalClose(result.CloseStatus.Value);
|
|
|
break;
|
|
|
}
|
|
|
- string received = Encoding.UTF8.GetString(buffer, 0, result.Count);
|
|
|
+ received += Encoding.UTF8.GetString(buffer, 0, result.Count);
|
|
|
//m_ReceiveData?.Invoke(this, received);
|
|
|
LastActiveTime = DateTime.UtcNow;
|
|
|
- HandleReceivedData(received);
|
|
|
+ if (result.EndOfMessage)
|
|
|
+ {
|
|
|
+ HandleReceivedData(received);
|
|
|
+ received = string.Empty;
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
|