(write: Promise<unknown>)
| 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 |