Fix issues with finish event firing multiple times #10

lib/webhdfs.js

@@ -456,15 +456,15 @@ WebHDFS.prototype.readFile = function readFile (path, callback) {
   var data = [];
   var error = null;
 
-  remoteFileStream.on('error', function onError (err) {
+  remoteFileStream.once('error', function onError (err) {
     error = err;
   });
 
   remoteFileStream.on('data', function onData (chunk) {
     data.push(chunk);
   });
 
-  remoteFileStream.on('finish', function () {
+  remoteFileStream.once('finish', function () {
     if (!error) {
       return callback && callback(null, Buffer.concat(data));
     } else {
@@ -562,7 +562,7 @@ WebHDFS.prototype.createWriteStream = function createWriteStream (path, append,
     }
   });
 
-  req.on('error', function onError (err) {
+  req.once('error', function onError (err) {
     req.emit('finish'); // Request is finished
   });
 
@@ -635,9 +635,6 @@ WebHDFS.prototype.createReadStream = function createReadStream (path, opts) {
   }, this._requestParams);
 
   var req = request(params);
-  req.on('error', function (err) {
-    req.emit('finish');
-  });
 
   req.on('complete', function (err) {
     req.emit('finish');

package.json

@@ -1,6 +1,6 @@
 {
   "name": "webhdfs",
-  "version": "0.3.0",
+  "version": "1.0.0",
   "description": "Node.js WebHDFS REST API client",
   "main": "lib/webhdfs.js",
   "scripts": {

test/webhdfs.js

@@ -95,7 +95,6 @@ describe('WebHDFS', function () {
       done();
     });
   });
-
   it('should open and read a file', function (done) {
     hdfs.readFile(path + '/file-1', function (err, data) {
       demand(err).be.null();