|
|
@@ -134,12 +134,17 @@ function setupHttp(uri, options, dst) {
|
|
|
if (err || failed) return failOrRetry(err);
|
|
|
debug('done fetching uri', uri);
|
|
|
dst.push(null);
|
|
|
+
|
|
|
+ dst.closed = true;
|
|
|
+ dst.emit('close');
|
|
|
});
|
|
|
|
|
|
// allow aborting the request
|
|
|
- dst.abort = function() {
|
|
|
- tries = 0;
|
|
|
- req.abort();
|
|
|
+ dst.abort = function(reason) {
|
|
|
+ if (!dst.closed) {
|
|
|
+ tries = 0;
|
|
|
+ req.abort();
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
// forward all future errors to response stream
|