Function idbReq

packages/experimental/src/EventJournal.ts:597–606

(method: string, evaluate: () => IDBRequest<T>)

  )

const idbReq = <T>(method: string, evaluate: () => IDBRequest<T>) =>
  Effect.async<T, EventJournalError>((resume) => {
    const request = evaluate()
    if (request.readyState === "done") {
      resume(Effect.succeed(request.result))
      return
    }
    request.onsuccess = () => resume(Effect.succeed(request.result))
    request.onerror = () => resume(Effect.fail(new EventJournalError({ method, cause: request.error })))
  })