diff --git a/src/firehose.ts b/src/firehose.ts index 8510a70a..57cc1022 100644 --- a/src/firehose.ts +++ b/src/firehose.ts @@ -21,5 +21,8 @@ pool.subscribe( /** Handle events through the firehose pipeline. */ function handleEvent(event: Event): Promise { console.info(`firehose: Event<${event.kind}> ${event.id}`); - return pipeline.handleEvent(event); + + return pipeline + .handleEvent(event) + .catch(() => {}); }