| var Buffer = require('buffer').Buffer | 
| var fs = require('fs') | 
| var test = require('tape') | 
|   | 
| var http = require('../..') | 
|   | 
| test('abort before response', function (t) { | 
|     var req = http.get('/basic.txt', function (res) { | 
|         t.fail('unexpected response') | 
|     }) | 
|     req.abort() | 
|     t.end() | 
| }) | 
|   | 
| test('abort on response', function (t) { | 
|     var req = http.get('/basic.txt', function (res) { | 
|         req.abort() | 
|         t.end() | 
|   | 
|         res.on('end', function () { | 
|             t.fail('unexpected end') | 
|         }) | 
|   | 
|         res.on('data', function (data) { | 
|             t.fail('unexpected data') | 
|         }) | 
|     }) | 
| }) | 
|   | 
| test('abort on data', function (t) { | 
|     var req = http.get('/browserify.png?copies=5', function (res) { | 
|         var firstData = true | 
|         var failOnData = false | 
|   | 
|         res.on('end', function () { | 
|             t.fail('unexpected end') | 
|         }) | 
|   | 
|         res.on('data', function (data) { | 
|             if (failOnData) | 
|                 t.fail('unexpected data') | 
|             else if (firstData) { | 
|                 firstData = false | 
|                 req.abort() | 
|                 t.end() | 
|                 process.nextTick(function () { | 
|                     // Wait for any data that may have been queued | 
|                     // in the stream before considering data events | 
|                     // as errors | 
|                     failOnData = true | 
|                 }) | 
|             } | 
|         }) | 
|     }) | 
| }) |