MCPcopy Create free account
hub / github.com/bearlyai/OpenADE / enqueue

Function enqueue

projects/openade-module/src/node.ts:1152–1154  ·  view source on GitHub ↗
(write: Promise<unknown>)

Source from the content-addressed store, hash-verified

1150 let finalized = false
1151
1152 const enqueue = (write: Promise<unknown>) => {
1153 pendingWrites.push(write.catch((error) => console.warn("[RuntimeNodeOpenADE] Failed to persist stream event:", error)))
1154 }
1155 const finalize = async (status: "completed" | "failed" | "stopped", error?: string) => {
1156 if (finalized) return
1157 finalized = true

Callers 1

onEventFunction · 0.70

Calls 1

pushMethod · 0.80

Tested by

no test coverage detected