Skip to content

Commit b3dab26

Browse files
committed
add error handling in stream.js
1 parent 2fd07f6 commit b3dab26

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

stream.js

+7-2
Original file line numberDiff line numberDiff line change
@@ -13,8 +13,13 @@ function parseStream() {
1313
return stream
1414

1515
function write(data, _, next) {
16-
var nodes = parser(data)
17-
16+
var nodes
17+
try {
18+
nodes = parser(data)
19+
} catch (error) {
20+
next(error)
21+
return;
22+
}
1823
for (var i = 0; i < nodes.length; i++) {
1924
this.push(nodes[i])
2025
}

0 commit comments

Comments
 (0)