Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/nodejs/node.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--doc/api/http.markdown7
-rw-r--r--lib/_http_client.js6
-rw-r--r--test/parallel/test-http-client-abort-event.js28
3 files changed, 41 insertions, 0 deletions
diff --git a/doc/api/http.markdown b/doc/api/http.markdown
index f5811e4a476..49ad0160ec2 100644
--- a/doc/api/http.markdown
+++ b/doc/api/http.markdown
@@ -859,6 +859,13 @@ Emitted when the server sends a '100 Continue' HTTP response, usually because
the request contained 'Expect: 100-continue'. This is an instruction that
the client should send the request body.
+### Event: 'abort'
+
+`function () { }`
+
+Emitted when the request has been aborted by the client. This event is only
+emitted on the first call to `abort()`.
+
### request.flush()
Flush the request headers.
diff --git a/lib/_http_client.js b/lib/_http_client.js
index b02ab66b294..5e722b4abc6 100644
--- a/lib/_http_client.js
+++ b/lib/_http_client.js
@@ -166,6 +166,12 @@ ClientRequest.prototype._implicitHeader = function() {
};
ClientRequest.prototype.abort = function() {
+ var self = this;
+ if (this.aborted === undefined) {
+ process.nextTick(function() {
+ self.emit('abort');
+ });
+ }
// Mark as aborting so we can avoid sending queued request data
// This is used as a truthy flag elsewhere. The use of Date.now is for
// debugging purposes only.
diff --git a/test/parallel/test-http-client-abort-event.js b/test/parallel/test-http-client-abort-event.js
new file mode 100644
index 00000000000..1549d06101a
--- /dev/null
+++ b/test/parallel/test-http-client-abort-event.js
@@ -0,0 +1,28 @@
+var assert = require('assert');
+var http = require('http');
+var common = require('../common');
+var server = http.createServer(function(req, res) {
+ res.end();
+});
+var count = 0;
+server.listen(common.PORT, function() {
+ var req = http.request({
+ port: common.PORT
+ }, function() {
+ assert(false, 'should not receive data');
+ });
+
+ req.on('abort', function() {
+ // should only be emitted once
+ count++;
+ server.close();
+ });
+
+ req.end();
+ req.abort();
+ req.abort();
+});
+
+process.on('exit', function() {
+ assert.equal(count, 1);
+})