diff --git a/stream.js b/stream.js
index 718d3de..eb3380d 100644
--- a/stream.js
+++ b/stream.js
@@ -13,8 +13,16 @@ function parseStream() {
   return stream
 
   function write(data, _, next) {
-    var nodes = parser(data)
-
+    var nodes
+    try {
+        nodes = parser(data)
+    } catch (error) {
+        if (typeof console) {
+          console.log(error)
+        }
+        next(error)
+        return
+    }
     for (var i = 0; i < nodes.length; i++) {
       this.push(nodes[i])
     }