Skip to content

Commit 45d881c

Browse files
committed
Use setImmediate from node:timers promises
1 parent dac5d92 commit 45d881c

1 file changed

Lines changed: 11 additions & 8 deletions

File tree

workers/loc.api/sync/dao/dao.better.sqlite.js

Lines changed: 11 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,11 @@
11
'use strict'
22

3-
const { setTimeout } = require('node:timers/promises')
4-
const { promisify } = require('util')
5-
const setImmediatePromise = promisify(setImmediate)
3+
const {
4+
setTimeout,
5+
setImmediate
6+
} = require('node:timers/promises')
7+
const { promisify } = require('node:util')
8+
69
const MAIN_DB_WORKER_ACTIONS = require(
710
'bfx-facs-db-better-sqlite/worker/db-worker-actions/db-worker-actions.const'
811
)
@@ -594,7 +597,7 @@ class BetterSqliteDAO extends DAO {
594597
let endId = firstId + chunkLength - 1
595598

596599
while (true) {
597-
await setImmediatePromise()
600+
await setImmediate()
598601

599602
if (
600603
!Number.isFinite(startId) ||
@@ -894,7 +897,7 @@ class BetterSqliteDAO extends DAO {
894897
}
895898

896899
for (const obj of data) {
897-
await setImmediatePromise()
900+
await setImmediate()
898901

899902
const _obj = mixUserIdToArrData(
900903
auth,
@@ -929,7 +932,7 @@ class BetterSqliteDAO extends DAO {
929932

930933
await this._beginTrans(async () => {
931934
for (const { sql, params } of queries) {
932-
await setImmediatePromise()
935+
await setImmediate()
933936

934937
await this.query({
935938
action: MAIN_DB_WORKER_ACTIONS.RUN,
@@ -1242,7 +1245,7 @@ class BetterSqliteDAO extends DAO {
12421245
const params = []
12431246

12441247
for (const obj of data) {
1245-
await setImmediatePromise()
1248+
await setImmediate()
12461249

12471250
const filter = mapObjBySchema(obj, filterPropNames)
12481251
const newItem = mapObjBySchema(obj, upPropNames)
@@ -1267,7 +1270,7 @@ class BetterSqliteDAO extends DAO {
12671270

12681271
await this._beginTrans(async () => {
12691272
for (const [i, paramsItem] of params.entries()) {
1270-
await setImmediatePromise()
1273+
await setImmediate()
12711274

12721275
await this.query({
12731276
action: MAIN_DB_WORKER_ACTIONS.RUN,

0 commit comments

Comments
 (0)