fix: prevent process exit on parse error

AxisCommunications · Oct 7, 2020 · ed7bad0 · ed7bad0
1 parent 4bcee86
commit ed7bad0
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/lib/components/rtsp-parser/index.ts b/lib/components/rtsp-parser/index.ts
@@ -24,8 +24,12 @@ export class RtspParser extends Tube {
       objectMode: true,
       transform: function (msg: Message, encoding, callback) {
         if (msg.type === MessageType.RAW) {
-          parser.parse(msg.data).forEach((message) => incoming.push(message))
-          callback()
+          try {
+            parser.parse(msg.data).forEach((message) => incoming.push(message))
+            callback()
+          } catch (e) {
+            callback(e)
+          }
         } else {
           // Not a message we should handle
           callback(undefined, msg)