summaryrefslogtreecommitdiff
path: root/test/parallel/test-http-agent-timeout-option.js
diff options
context:
space:
mode:
Diffstat (limited to 'test/parallel/test-http-agent-timeout-option.js')
-rw-r--r--test/parallel/test-http-agent-timeout-option.js38
1 files changed, 16 insertions, 22 deletions
diff --git a/test/parallel/test-http-agent-timeout-option.js b/test/parallel/test-http-agent-timeout-option.js
index 3c694a0ef7..d0c05827f2 100644
--- a/test/parallel/test-http-agent-timeout-option.js
+++ b/test/parallel/test-http-agent-timeout-option.js
@@ -1,29 +1,23 @@
'use strict';
-const { expectsError, mustCall } = require('../common');
-const { Agent, get, createServer } = require('http');
+const { mustCall } = require('../common');
+const { strictEqual } = require('assert');
+const { Agent, get } = require('http');
-// Test that the `'timeout'` event is emitted on the `ClientRequest` instance
-// when the socket timeout set via the `timeout` option of the `Agent` expires.
+// Test that the listener that forwards the `'timeout'` event from the socket to
+// the `ClientRequest` instance is added to the socket when the `timeout` option
+// of the `Agent` is set.
-const server = createServer(mustCall(() => {
- // Never respond.
-}));
+const request = get({
+ agent: new Agent({ timeout: 50 }),
+ lookup: () => {}
+});
-server.listen(() => {
- const request = get({
- agent: new Agent({ timeout: 500 }),
- port: server.address().port
- });
+request.on('socket', mustCall((socket) => {
+ strictEqual(socket.timeout, 50);
- request.on('error', expectsError({
- type: Error,
- code: 'ECONNRESET',
- message: 'socket hang up'
- }));
+ const listeners = socket.listeners('timeout');
- request.on('timeout', mustCall(() => {
- request.abort();
- server.close();
- }));
-});
+ strictEqual(listeners.length, 1);
+ strictEqual(listeners[0], request.timeoutCb);
+}));