diff options
author | James M Snell <jasnell@gmail.com> | 2017-11-25 13:02:16 -0800 |
---|---|---|
committer | James M Snell <jasnell@gmail.com> | 2017-11-28 10:30:39 -0800 |
commit | 1b99542ea49b302c7e13f16b81cd7420eb76fc2e (patch) | |
tree | c492ab657570a43c62eb3f22daac00f46da80a20 /test | |
parent | df33d8d0b39be893ad7864cc5e1b65bc448ba1f4 (diff) | |
download | android-node-v8-1b99542ea49b302c7e13f16b81cd7420eb76fc2e.tar.gz android-node-v8-1b99542ea49b302c7e13f16b81cd7420eb76fc2e.tar.bz2 android-node-v8-1b99542ea49b302c7e13f16b81cd7420eb76fc2e.zip |
http2: use 'close' event instead of 'streamClosed'
PR-URL: https://github.com/nodejs/node/pull/17328
Fixes: https://github.com/nodejs/node/issues/15303
Reviewed-By: Anatoli Papirovski <apapirovski@mac.com>
Reviewed-By: Sebastiaan Deckers <sebdeckers83@gmail.com>
Diffstat (limited to 'test')
22 files changed, 27 insertions, 27 deletions
diff --git a/test/parallel/test-http2-client-http1-server.js b/test/parallel/test-http2-client-http1-server.js index 44d8d392f4..53f7bf42c4 100644 --- a/test/parallel/test-http2-client-http1-server.js +++ b/test/parallel/test-http2-client-http1-server.js @@ -13,7 +13,7 @@ server.listen(0, common.mustCall(() => { const client = http2.connect(`http://localhost:${server.address().port}`); const req = client.request(); - req.on('streamClosed', common.mustCall()); + req.on('close', common.mustCall()); client.on('error', common.expectsError({ code: 'ERR_HTTP2_ERROR', diff --git a/test/parallel/test-http2-client-rststream-before-connect.js b/test/parallel/test-http2-client-rststream-before-connect.js index e4aff87be9..eb3a0087d7 100644 --- a/test/parallel/test-http2-client-rststream-before-connect.js +++ b/test/parallel/test-http2-client-rststream-before-connect.js @@ -27,7 +27,7 @@ server.on('listening', common.mustCall(() => { // second call doesn't do anything assert.doesNotThrow(() => req.rstStream(8)); - req.on('streamClosed', common.mustCall((code) => { + req.on('close', common.mustCall((code) => { assert.strictEqual(req.destroyed, true); assert.strictEqual(code, 0); server.close(); diff --git a/test/parallel/test-http2-client-stream-destroy-before-connect.js b/test/parallel/test-http2-client-stream-destroy-before-connect.js index 4eefc4b9f3..06afbf3ce8 100644 --- a/test/parallel/test-http2-client-stream-destroy-before-connect.js +++ b/test/parallel/test-http2-client-stream-destroy-before-connect.js @@ -41,7 +41,7 @@ server.on('listening', common.mustCall(() => { })(err); })); - req.on('streamClosed', common.mustCall((code) => { + req.on('close', common.mustCall((code) => { assert.strictEqual(req.rstCode, NGHTTP2_INTERNAL_ERROR); assert.strictEqual(code, NGHTTP2_INTERNAL_ERROR); server.close(); diff --git a/test/parallel/test-http2-client-unescaped-path.js b/test/parallel/test-http2-client-unescaped-path.js index 3a7a607bc3..adfbd61fe7 100644 --- a/test/parallel/test-http2-client-unescaped-path.js +++ b/test/parallel/test-http2-client-unescaped-path.js @@ -30,7 +30,7 @@ server.listen(0, common.mustCall(() => { type: Error, message: 'Stream closed with error code 1' })); - req.on('streamClosed', common.mustCall(maybeClose)); + req.on('close', common.mustCall(maybeClose)); } for (let i = 0; i <= count; i += 1) diff --git a/test/parallel/test-http2-compat-serverresponse-end.js b/test/parallel/test-http2-compat-serverresponse-end.js index fafb3ea76d..366d523215 100644 --- a/test/parallel/test-http2-compat-serverresponse-end.js +++ b/test/parallel/test-http2-compat-serverresponse-end.js @@ -183,10 +183,10 @@ const { { - // Should be able to call .end with cb from stream 'streamClosed' + // Should be able to call .end with cb from stream 'close' const server = createServer(mustCall((request, response) => { response.writeHead(HTTP_STATUS_OK, { foo: 'bar' }); - response.stream.on('streamClosed', mustCall(() => { + response.stream.on('close', mustCall(() => { response.end(mustCall()); })); })); diff --git a/test/parallel/test-http2-compat-socket.js b/test/parallel/test-http2-compat-socket.js index aed74149f7..5d97872dfb 100644 --- a/test/parallel/test-http2-compat-socket.js +++ b/test/parallel/test-http2-compat-socket.js @@ -63,8 +63,8 @@ server.on('request', common.mustCall(function(request, response) { assert.strictEqual(request.socket.connecting, false); // socket events are bound and emitted on Http2Stream - request.socket.on('streamClosed', common.mustCall()); - request.socket.once('streamClosed', common.mustCall()); + request.socket.on('close', common.mustCall()); + request.socket.once('close', common.mustCall()); request.socket.on('testEvent', common.mustCall()); request.socket.emit('testEvent'); })); diff --git a/test/parallel/test-http2-multiheaders-raw.js b/test/parallel/test-http2-multiheaders-raw.js index 5db253da3c..c06bf23bff 100644 --- a/test/parallel/test-http2-multiheaders-raw.js +++ b/test/parallel/test-http2-multiheaders-raw.js @@ -42,7 +42,7 @@ server.on('stream', common.mustCall((stream, headers, flags, rawHeaders) => { server.listen(0, common.mustCall(() => { const client = http2.connect(`http://localhost:${server.address().port}`); const req = client.request(src); - req.on('streamClosed', common.mustCall(() => { + req.on('close', common.mustCall(() => { server.close(); client.destroy(); })); diff --git a/test/parallel/test-http2-multiheaders.js b/test/parallel/test-http2-multiheaders.js index 7a118214e8..5e47710409 100644 --- a/test/parallel/test-http2-multiheaders.js +++ b/test/parallel/test-http2-multiheaders.js @@ -54,7 +54,7 @@ server.listen(0, common.mustCall(() => { const client = http2.connect(`http://localhost:${server.address().port}`); const req = client.request(src); req.on('response', common.mustCall(checkHeaders)); - req.on('streamClosed', common.mustCall(() => { + req.on('close', common.mustCall(() => { server.close(); client.destroy(); })); diff --git a/test/parallel/test-http2-options-max-reserved-streams.js b/test/parallel/test-http2-options-max-reserved-streams.js index 17009a4c11..d54ca6a788 100644 --- a/test/parallel/test-http2-options-max-reserved-streams.js +++ b/test/parallel/test-http2-options-max-reserved-streams.js @@ -34,7 +34,7 @@ server.on('stream', common.mustCall((stream) => { pushedStream.respond({ ':status': 200 }); pushedStream.on('aborted', common.mustCall()); pushedStream.on('error', common.mustNotCall()); - pushedStream.on('streamClosed', + pushedStream.on('close', common.mustCall((code) => assert.strictEqual(code, 8))); })); @@ -67,12 +67,12 @@ server.on('listening', common.mustCall(() => { client.on('stream', common.mustCall((stream) => { stream.resume(); stream.on('end', common.mustCall()); - stream.on('streamClosed', common.mustCall(maybeClose)); + stream.on('close', common.mustCall(maybeClose)); })); req.on('response', common.mustCall()); req.resume(); req.on('end', common.mustCall()); - req.on('streamClosed', common.mustCall(maybeClose)); + req.on('close', common.mustCall(maybeClose)); })); diff --git a/test/parallel/test-http2-respond-file-errors.js b/test/parallel/test-http2-respond-file-errors.js index b57d9b1046..c2c749873c 100644 --- a/test/parallel/test-http2-respond-file-errors.js +++ b/test/parallel/test-http2-respond-file-errors.js @@ -117,7 +117,7 @@ server.listen(0, common.mustCall(() => { const client = http2.connect(`http://localhost:${server.address().port}`); const req = client.request(); - req.on('streamClosed', common.mustCall(() => { + req.on('close', common.mustCall(() => { client.destroy(); server.close(); })); diff --git a/test/parallel/test-http2-respond-file-fd-errors.js b/test/parallel/test-http2-respond-file-fd-errors.js index e5cc280613..9458b2f49a 100644 --- a/test/parallel/test-http2-respond-file-fd-errors.js +++ b/test/parallel/test-http2-respond-file-fd-errors.js @@ -144,7 +144,7 @@ server.listen(0, common.mustCall(() => { const client = http2.connect(`http://localhost:${server.address().port}`); const req = client.request(); - req.on('streamClosed', common.mustCall(() => { + req.on('close', common.mustCall(() => { client.destroy(); server.close(); })); diff --git a/test/parallel/test-http2-respond-file-fd-range.js b/test/parallel/test-http2-respond-file-fd-range.js index fdf9b5e2cd..8479dca518 100644 --- a/test/parallel/test-http2-respond-file-fd-range.js +++ b/test/parallel/test-http2-respond-file-fd-range.js @@ -71,7 +71,7 @@ server.listen(0, () => { req.on('end', common.mustCall(() => { assert.strictEqual(check, data.toString('utf8', 8, 11)); })); - req.on('streamClosed', common.mustCall(maybeClose)); + req.on('close', common.mustCall(maybeClose)); req.end(); } @@ -88,7 +88,7 @@ server.listen(0, () => { req.on('end', common.mustCall(() => { assert.strictEqual(check, data.toString('utf8', 8, 28)); })); - req.on('streamClosed', common.mustCall(maybeClose)); + req.on('close', common.mustCall(maybeClose)); req.end(); } diff --git a/test/parallel/test-http2-respond-no-data.js b/test/parallel/test-http2-respond-no-data.js index 74f85a9cd0..d891fe4e8d 100644 --- a/test/parallel/test-http2-respond-no-data.js +++ b/test/parallel/test-http2-respond-no-data.js @@ -13,7 +13,7 @@ const server = http2.createServer(); const status = [204, 205, 304]; server.on('stream', common.mustCall((stream) => { - stream.on('streamClosed', common.mustCall(() => { + stream.on('close', common.mustCall(() => { assert.strictEqual(stream.destroyed, true); })); stream.respond({ ':status': status.shift() }); diff --git a/test/parallel/test-http2-response-splitting.js b/test/parallel/test-http2-response-splitting.js index 8aae2156e4..1d9b616105 100644 --- a/test/parallel/test-http2-response-splitting.js +++ b/test/parallel/test-http2-response-splitting.js @@ -67,7 +67,7 @@ server.listen(0, common.mustCall(() => { })); req.resume(); req.on('end', common.mustCall()); - req.on('streamClosed', common.mustCall(maybeClose)); + req.on('close', common.mustCall(maybeClose)); } doTest(str, 'location', str); diff --git a/test/parallel/test-http2-server-rst-before-respond.js b/test/parallel/test-http2-server-rst-before-respond.js index 25dfa7e010..47ba68bd29 100644 --- a/test/parallel/test-http2-server-rst-before-respond.js +++ b/test/parallel/test-http2-server-rst-before-respond.js @@ -35,7 +35,7 @@ server.on('listening', common.mustCall(() => { req.on('headers', common.mustNotCall()); - req.on('streamClosed', common.mustCall((code) => { + req.on('close', common.mustCall((code) => { assert.strictEqual(h2.constants.NGHTTP2_NO_ERROR, code); server.close(); client.destroy(); diff --git a/test/parallel/test-http2-server-rst-stream.js b/test/parallel/test-http2-server-rst-stream.js index dd38efb42f..4b04f29c8e 100644 --- a/test/parallel/test-http2-server-rst-stream.js +++ b/test/parallel/test-http2-server-rst-stream.js @@ -43,7 +43,7 @@ server.listen(0, common.mustCall(() => { ':method': 'POST', rstmethod: test[0] }); - req.on('streamClosed', common.mustCall((code) => { + req.on('close', common.mustCall((code) => { assert.strictEqual(code, test[1]); countdown.dec(); })); diff --git a/test/parallel/test-http2-server-socketerror.js b/test/parallel/test-http2-server-socketerror.js index 24945e531a..9f52b9280d 100644 --- a/test/parallel/test-http2-server-socketerror.js +++ b/test/parallel/test-http2-server-socketerror.js @@ -49,7 +49,7 @@ server.listen(0, common.mustCall(() => { const req = client.request(); req.resume(); req.on('end', common.mustCall()); - req.on('streamClosed', common.mustCall(() => { + req.on('close', common.mustCall(() => { client.destroy(); server.close(); })); diff --git a/test/parallel/test-http2-stream-client.js b/test/parallel/test-http2-stream-client.js index 3b802f6e6d..aa722c5ff2 100644 --- a/test/parallel/test-http2-stream-client.js +++ b/test/parallel/test-http2-stream-client.js @@ -21,7 +21,7 @@ server.listen(0, common.mustCall(() => { const client = http2.connect(`http://localhost:${server.address().port}`); const req = client.request(); req.resume(); - req.on('streamClosed', common.mustCall(() => { + req.on('close', common.mustCall(() => { client.destroy(); server.close(); })); diff --git a/test/parallel/test-http2-stream-destroy-event-order.js b/test/parallel/test-http2-stream-destroy-event-order.js index 16bb5e6a62..c375bd80b3 100644 --- a/test/parallel/test-http2-stream-destroy-event-order.js +++ b/test/parallel/test-http2-stream-destroy-event-order.js @@ -11,7 +11,7 @@ let req; const server = http2.createServer(); server.on('stream', common.mustCall((stream) => { stream.on('error', common.mustCall(() => { - stream.on('streamClosed', common.mustCall((code) => { + stream.on('close', common.mustCall((code) => { assert.strictEqual(code, 2); client.destroy(); server.close(); diff --git a/test/parallel/test-http2-too-large-headers.js b/test/parallel/test-http2-too-large-headers.js index fa15b6ea11..f7ac25170b 100644 --- a/test/parallel/test-http2-too-large-headers.js +++ b/test/parallel/test-http2-too-large-headers.js @@ -22,7 +22,7 @@ server.listen(0, common.mustCall(() => { type: Error, message: 'Stream closed with error code 11' })); - req.on('streamClosed', common.mustCall((code) => { + req.on('close', common.mustCall((code) => { assert.strictEqual(code, NGHTTP2_ENHANCE_YOUR_CALM); server.close(); client.destroy(); diff --git a/test/parallel/test-http2-too-many-headers.js b/test/parallel/test-http2-too-many-headers.js index 3d63727ed5..eff0fa9c35 100644 --- a/test/parallel/test-http2-too-many-headers.js +++ b/test/parallel/test-http2-too-many-headers.js @@ -25,7 +25,7 @@ server.listen(0, common.mustCall(() => { type: Error, message: 'Stream closed with error code 11' })); - req.on('streamClosed', common.mustCall((code) => { + req.on('close', common.mustCall((code) => { assert.strictEqual(code, NGHTTP2_ENHANCE_YOUR_CALM); server.close(); client.destroy(); diff --git a/test/parallel/test-http2-write-callbacks.js b/test/parallel/test-http2-write-callbacks.js index e196ca8d3c..44e33573a6 100644 --- a/test/parallel/test-http2-write-callbacks.js +++ b/test/parallel/test-http2-write-callbacks.js @@ -30,7 +30,7 @@ server.listen(0, common.mustCall(() => { req.setEncoding('utf8'); req.on('data', (chunk) => actual += chunk); req.on('end', common.mustCall(() => assert.strictEqual(actual, 'abcxyz'))); - req.on('streamClosed', common.mustCall(() => { + req.on('close', common.mustCall(() => { client.destroy(); server.close(); })); |