|
|
@ -188,6 +188,7 @@ Parser.prototype._resUntagged = function() {
|
|
|
|
var which = m[1], size = parseInt(m[2], 10);
|
|
|
|
var which = m[1], size = parseInt(m[2], 10);
|
|
|
|
this._literallen = size;
|
|
|
|
this._literallen = size;
|
|
|
|
this._body = new ReadableStream();
|
|
|
|
this._body = new ReadableStream();
|
|
|
|
|
|
|
|
this._body._readableState.sync = false;
|
|
|
|
this._body._read = EMPTY_READCB;
|
|
|
|
this._body._read = EMPTY_READCB;
|
|
|
|
m = RE_SEQNO.exec(this._buffer);
|
|
|
|
m = RE_SEQNO.exec(this._buffer);
|
|
|
|
this._buffer = this._buffer.replace(RE_BODYLITERAL, '');
|
|
|
|
this._buffer = this._buffer.replace(RE_BODYLITERAL, '');
|
|
|
@ -440,6 +441,7 @@ function parseFetch(text, literals, seqno) {
|
|
|
|
// a body was sent as a non-literal
|
|
|
|
// a body was sent as a non-literal
|
|
|
|
val = new Buffer(''+val);
|
|
|
|
val = new Buffer(''+val);
|
|
|
|
body = new ReadableStream();
|
|
|
|
body = new ReadableStream();
|
|
|
|
|
|
|
|
body._readableState.sync = false;
|
|
|
|
body._read = EMPTY_READCB;
|
|
|
|
body._read = EMPTY_READCB;
|
|
|
|
this.emit('body', body, {
|
|
|
|
this.emit('body', body, {
|
|
|
|
seqno: seqno,
|
|
|
|
seqno: seqno,
|
|
|
|