Handle parsing error over streams.

mqttjs · Nov 1, 2014 · 3b07ee5 · 3b07ee5
1 parent 60bd4d0
commit 3b07ee5
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 1 deletion.
diff --git a/lib/parseStream.js b/lib/parseStream.js
@@ -7,6 +7,7 @@ function parseStream(opts) {
     , stream  = through.obj(process)
 
   parser.on('packet', push)
+  parser.on('error', stream.emit.bind(stream, 'error'))
 
   function process(chunk, enc, cb) {
     parser.parse(chunk)

diff --git a/test.js b/test.js
@@ -97,14 +97,25 @@ function testParseError(expected, fixture) {
     t.plan(1)
 
     var parser = mqtt.parser()
-      , rest
 
     parser.on('error', function(err) {
       t.equal(err.message, expected, 'expected error message')
     })
 
     parser.parse(fixture)
   })
+
+  test(expected + ' over parseStream', function(t) {
+    t.plan(1)
+
+    var parser = mqtt.parseStream()
+
+    parser.on('error', function(err) {
+      t.equal(err.message, expected, 'expected error message')
+    })
+
+    parser.end(fixture)
+  })
 }
 
 function testGenerateError(expected, fixture) {