diff --git a/packages/ditto/storages/DittoRelayStore.ts b/packages/ditto/storages/DittoRelayStore.ts index fc29f1f6..246a9c9d 100644 --- a/packages/ditto/storages/DittoRelayStore.ts +++ b/packages/ditto/storages/DittoRelayStore.ts @@ -354,7 +354,7 @@ export class DittoRelayStore implements NRelay { } if (ids.size) { - for (const event of await pool.query([{ ids: [...ids] }])) { + for (const event of await pool.query([{ ids: [...ids] }], { signal: AbortSignal.timeout(1000) })) { await this.event(event).catch(() => {}); } }