diff --git a/src/pipeline.ts b/src/pipeline.ts index f28b886d..3eb8913d 100644 --- a/src/pipeline.ts +++ b/src/pipeline.ts @@ -186,7 +186,7 @@ async function fetchRelatedEvents(event: DittoEvent) { if (!event.author) { const signal = AbortSignal.timeout(3000); Storages.reqmeister.query([{ kinds: [0], authors: [event.pubkey] }], { signal }) - .then((events) => events.forEach((event) => handleEvent(event, signal))) + .then((events) => Promise.allSettled(events.map((event) => handleEvent(event, signal)))) .catch(() => {}); } @@ -196,7 +196,7 @@ async function fetchRelatedEvents(event: DittoEvent) { if (!count) { const signal = AbortSignal.timeout(3000); Storages.reqmeister.query([{ ids: [id] }], { signal }) - .then((events) => events.forEach((event) => handleEvent(event, signal))) + .then((events) => Promise.allSettled(events.map((event) => handleEvent(event, signal)))) .catch(() => {}); } }