Fix createWriteStream error emitting (send error to original stream o…

…bject)
harrisiirak · Apr 19, 2014 · c680d9d · c680d9d
1 parent ec5b7d8
commit c680d9d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/lib/webhdfs.js b/lib/webhdfs.js
@@ -551,7 +551,7 @@ WebHDFS.prototype.createWriteStream = function createWriteStream (path, append,
  req.on('data', function onError (data) {
  var error = self._parseError(data.toString());
  if (error) {
- req.end();
+ stream.emit('error', error);
  req.emit('error', error);
  }
  });

diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
  "name": "webhdfs",
- "version": "0.1.9",
+ "version": "0.1.10",
  "description": "Node.js WebHDFS REST API client",
  "main": "lib/webhdfs.js",
  "scripts": {