Rescue parser error after streaming listener is closed
This commit is contained in:
parent
dd02d2e4e5
commit
cf53d3e861
|
@ -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