forks
/
arsd
mirror of https://github.com/adamdruppe/arsd.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' of github.com:adamdruppe/arsd

This commit is contained in:
Adam D. Ruppe 2021-09-18 07:33:32 -04:00
parent feb66fc4ef 9ce96cfdbd
commit db2ca76e60
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
http2.d
View File

@ -3545,6 +3545,15 @@ class WebSocket {
public bool lowLevelReceive() { public bool lowLevelReceive() {
if(readyState == CONNECTING) if(readyState == CONNECTING)
throw new Exception("WebSocket not connected when trying to receive. Did you forget to call connect(); ?"); throw new Exception("WebSocket not connected when trying to receive. Did you forget to call connect(); ?");
if (receiveBufferUsedLength == receiveBuffer.length)
{
if (receiveBuffer.length == config.maximumReceiveBufferSize)
throw new Exception("Maximum receive buffer size exhausted");
import std.algorithm : min;
receiveBuffer.length = min(receiveBuffer.length + config.initialReceiveBufferSize,
config.maximumReceiveBufferSize);
}
auto r = socket.receive(receiveBuffer[receiveBufferUsedLength .. $]); auto r = socket.receive(receiveBuffer[receiveBufferUsedLength .. $]);
if(r == 0) if(r == 0)
return false; return false;