From b3dab261e7022275dc1414cd81007268dea29e58 Mon Sep 17 00:00:00 2001
From: fuzhenn <fuzhen@maptalks.org>
Date: Fri, 17 Jul 2020 12:20:47 +0800
Subject: [PATCH 1/2] add error handling in stream.js

---
 stream.js | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

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

From 23ad3151d358f77115a03fabf0ed22dd94c39b1c Mon Sep 17 00:00:00 2001
From: fuzhenn <fuzhen@maptalks.org>
Date: Fri, 17 Jul 2020 12:40:16 +0800
Subject: [PATCH 2/2] print error

---
 stream.js | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

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