(event: any)
| 287 | yield* Scope.addFinalizer(scope, Effect.sync(() => postMessage(["close"]))) |
| 288 | |
| 289 | const onMessage = (event: any) => { |
| 290 | const [id, error, results] = event.data |
| 291 | if (id === "ready") { |
| 292 | Deferred.unsafeDone(readyDeferred, Exit.void) |
| 293 | return |
| 294 | } else if (id === "update_hook") { |
| 295 | reactivity.unsafeInvalidate({ [error]: [results] }) |
| 296 | return |
| 297 | } else { |
| 298 | const resume = pending.get(id) |
| 299 | if (!resume) return |
| 300 | pending.delete(id) |
| 301 | if (error) { |
| 302 | resume(Exit.fail(new SqlError({ cause: error as string, message: "Failed to execute statement" }))) |
| 303 | } else { |
| 304 | resume(Exit.succeed(results)) |
| 305 | } |
| 306 | } |
| 307 | } |
| 308 | port.addEventListener("message", onMessage) |
| 309 | |
| 310 | function onError() { |
nothing calls this directly
no test coverage detected