diff --git a/examples/pg/index.ts b/examples/pg/index.ts index 254f3fa..a67f0c2 100644 --- a/examples/pg/index.ts +++ b/examples/pg/index.ts @@ -1,8 +1,8 @@ import http from 'node:http'; import { randomUUID } from 'node:crypto'; import { Client } from 'pg'; -import { processEvents } from 'txob'; -import { createEventProcessorClient } from 'txob/pg'; +import { processEvents } from '../../src/processor'; +import { createProcessorClient } from '../../src/pg/client'; import dotenv from 'dotenv'; dotenv.config(); @@ -42,7 +42,7 @@ const main = async () => { const ab = new AbortController(); - const processorClient = createEventProcessorClient(client); + const processorClient = createProcessorClient(client); const processorTick = () => { if (ab.signal.aborted) return; diff --git a/examples/pg/package.json b/examples/pg/package.json index dd052e5..d2293d8 100644 --- a/examples/pg/package.json +++ b/examples/pg/package.json @@ -7,8 +7,7 @@ "dev": "nodemon index.ts" }, "dependencies": { - "pg": "^8.11.3", - "txob": "^0.0.5" + "pg": "^8.11.3" }, "devDependencies": { "@types/node": "^20.10.4", diff --git a/examples/pg/yarn.lock b/examples/pg/yarn.lock index 28d5de7..71a59d4 100644 --- a/examples/pg/yarn.lock +++ b/examples/pg/yarn.lock @@ -420,11 +420,6 @@ readdirp@~3.6.0: dependencies: picomatch "^2.2.1" -retry@^0.13.1: - version "0.13.1" - resolved "https://registry.yarnpkg.com/retry/-/retry-0.13.1.tgz#185b1587acf67919d63b357349e03537b2484658" - integrity sha512-XQBQ3I8W1Cge0Seh+6gjj03LbmRFWuoszgK9ooCpwYIrhhoO80pfq4cUkU5DkknwfOfFteRwlZ56PYOGYyFWdg== - semver@^7.5.3: version "7.5.4" resolved "https://registry.yarnpkg.com/semver/-/semver-7.5.4.tgz#483986ec4ed38e1c6c48c34894a9182dbff68a6e" @@ -484,13 +479,6 @@ ts-node@^10.9.2: v8-compile-cache-lib "^3.0.1" yn "3.1.1" -txob@^0.0.5: - version "0.0.5" - resolved "https://registry.yarnpkg.com/txob/-/txob-0.0.5.tgz#36092a25f862af84cf3347dbb7e48a1794d7d08c" - integrity sha512-UICvMTT2eLMm0vc1NmsZDS3hNL9nhV7XiMqKfSo8RfLGujjrljjCtoTGV2oRk9pwnPUNOjh7pybJHpzrXsDMfw== - dependencies: - retry "^0.13.1" - typescript@^5.3.3: version "5.3.3" resolved "https://registry.yarnpkg.com/typescript/-/typescript-5.3.3.tgz#b3ce6ba258e72e6305ba66f5c9b452aaee3ffe37"