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

stay in sync with multiple requests

This commit is contained in:
Adam D. Ruppe 2018-02-06 10:31:03 -05:00
parent f516304b04
commit c611f716bd
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
http2.d
View File

@ -925,8 +925,12 @@ class HttpRequest {
// responseData.content ~= cast(ubyte[]) uncompress.uncompress(data); // responseData.content ~= cast(ubyte[]) uncompress.uncompress(data);
//else //else
responseData.content ~= data; responseData.content ~= data;
assert(data.length <= bodyReadingState.contentLengthRemaining, format("%d <= %d\n%s", data.length, bodyReadingState.contentLengthRemaining, cast(string)data)); //assert(data.length <= bodyReadingState.contentLengthRemaining, format("%d <= %d\n%s", data.length, bodyReadingState.contentLengthRemaining, cast(string)data));
bodyReadingState.contentLengthRemaining -= data.length; int use = cast(int) data.length;
if(use > bodyReadingState.contentLengthRemaining)
use = bodyReadingState.contentLengthRemaining;
bodyReadingState.contentLengthRemaining -= use;
data = data[use .. $];
if(bodyReadingState.contentLengthRemaining == 0) { if(bodyReadingState.contentLengthRemaining == 0) {
if(bodyReadingState.isGzipped || bodyReadingState.isDeflated) { if(bodyReadingState.isGzipped || bodyReadingState.isDeflated) {
auto n = uncompress.uncompress(responseData.content); auto n = uncompress.uncompress(responseData.content);