diff --git a/packages/db-client/src/streams/appendToStream/batchAppend.ts b/packages/db-client/src/streams/appendToStream/batchAppend.ts index fd5a5734..a1a62808 100644 --- a/packages/db-client/src/streams/appendToStream/batchAppend.ts +++ b/packages/db-client/src/streams/appendToStream/batchAppend.ts @@ -64,7 +64,13 @@ export const batchAppend = async function ( ) .on("data", (resp: BatchAppendResp) => { const resultingId = parseUUID(resp.getCorrelationId()!); - const [resolve, reject] = promiseBank.get(resultingId)!; + const entry = promiseBank.get(resultingId); + + if (!entry) { + return; + } + + const [resolve, reject] = entry; promiseBank.delete(resultingId);