firehose: catch pipeline crash
This commit is contained in:
parent
0f70f5c76f
commit
85345bc157
|
@ -21,5 +21,8 @@ pool.subscribe(
|
||||||
/** Handle events through the firehose pipeline. */
|
/** Handle events through the firehose pipeline. */
|
||||||
function handleEvent(event: Event): Promise<void> {
|
function handleEvent(event: Event): Promise<void> {
|
||||||
console.info(`firehose: Event<${event.kind}> ${event.id}`);
|
console.info(`firehose: Event<${event.kind}> ${event.id}`);
|
||||||
return pipeline.handleEvent(event);
|
|
||||||
|
return pipeline
|
||||||
|
.handleEvent(event)
|
||||||
|
.catch(() => {});
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue