Merge pull request #799 from h3poteto/fix/parserError
Rescue parser error after streaming listener is closed
This commit is contained in:
commit
634f4d7406
|
@ -64,6 +64,9 @@ export default class Streaming {
|
||||||
this.listener.on('error', (e) => {
|
this.listener.on('error', (e) => {
|
||||||
log.error(e)
|
log.error(e)
|
||||||
})
|
})
|
||||||
|
this.listener.on('parser-error', (e) => {
|
||||||
|
log.error(e)
|
||||||
|
})
|
||||||
this.listener.stop()
|
this.listener.stop()
|
||||||
log.info('streaming stopped')
|
log.info('streaming stopped')
|
||||||
}
|
}
|
||||||
|
|
|
@ -75,6 +75,9 @@ export default class WebSocket {
|
||||||
this.listener.on('error', (e) => {
|
this.listener.on('error', (e) => {
|
||||||
log.error(e)
|
log.error(e)
|
||||||
})
|
})
|
||||||
|
this.listener.on('parser-error', (e) => {
|
||||||
|
log.error(e)
|
||||||
|
})
|
||||||
this.listener.stop()
|
this.listener.stop()
|
||||||
log.info('streaming stopped')
|
log.info('streaming stopped')
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue