summaryrefslogtreecommitdiff
path: root/lib/internal/http2/compat.js
diff options
context:
space:
mode:
Diffstat (limited to 'lib/internal/http2/compat.js')
-rw-r--r--lib/internal/http2/compat.js14
1 files changed, 6 insertions, 8 deletions
diff --git a/lib/internal/http2/compat.js b/lib/internal/http2/compat.js
index 4622d97614..145e774104 100644
--- a/lib/internal/http2/compat.js
+++ b/lib/internal/http2/compat.js
@@ -1,5 +1,6 @@
'use strict';
+const assert = require('assert');
const Stream = require('stream');
const Readable = Stream.Readable;
const binding = internalBinding('http2');
@@ -331,15 +332,12 @@ class Http2ServerRequest extends Readable {
_read(nread) {
const state = this[kState];
- if (!state.closed) {
- if (!state.didRead) {
- state.didRead = true;
- this[kStream].on('data', onStreamData);
- } else {
- process.nextTick(resumeStream, this[kStream]);
- }
+ assert(!state.closed);
+ if (!state.didRead) {
+ state.didRead = true;
+ this[kStream].on('data', onStreamData);
} else {
- this.emit('error', new ERR_HTTP2_INVALID_STREAM());
+ process.nextTick(resumeStream, this[kStream]);
}
}