Skip to content

Commit

Permalink
refactor(async-utils): rename timeoutSignal to timeoutController
Browse files Browse the repository at this point in the history
  • Loading branch information
mpeyper committed Aug 31, 2021
1 parent 42efb8c commit 4a6a8d5
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 11 deletions.
6 changes: 3 additions & 3 deletions src/core/asyncUtils.ts
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ import {
AsyncUtils
} from '../types'

import { createTimeoutSignal } from '../helpers/createTimeoutSignal'
import { createTimeoutController } from '../helpers/createTimeoutController'
import { TimeoutError } from '../helpers/error'

const DEFAULT_INTERVAL = 50
Expand All @@ -20,11 +20,11 @@ function asyncUtils(act: Act, addResolver: (callback: () => void) => void): Asyn
return callbackResult ?? callbackResult === undefined
}

const timeoutSignal = createTimeoutSignal(timeout)
const timeoutSignal = createTimeoutController(timeout)

const waitForResult = async () => {
while (true) {
const intervalSignal = createTimeoutSignal(interval)
const intervalSignal = createTimeoutController(interval)
timeoutSignal.onTimeout(() => intervalSignal.cancel())

await intervalSignal.wrap(new Promise<void>(addResolver))
Expand Down
Original file line number Diff line number Diff line change
@@ -1,21 +1,21 @@
import { WaitOptions } from '../types'

function createTimeoutSignal(timeout: WaitOptions['timeout']) {
function createTimeoutController(timeout: WaitOptions['timeout']) {
let timeoutId: NodeJS.Timeout
const timeoutCallbacks: Array<() => void> = []

const timeoutSignal = {
const timeoutController = {
onTimeout(callback: () => void) {
timeoutCallbacks.push(callback)
},
wrap(promise: Promise<void>) {
return new Promise<void>((resolve, reject) => {
timeoutSignal.timedOut = false
timeoutSignal.onTimeout(resolve)
timeoutController.timedOut = false
timeoutController.onTimeout(resolve)

if (timeout) {
timeoutId = setTimeout(() => {
timeoutSignal.timedOut = true
timeoutController.timedOut = true
timeoutCallbacks.forEach((callback) => callback())
resolve()
}, timeout)
Expand All @@ -24,7 +24,7 @@ function createTimeoutSignal(timeout: WaitOptions['timeout']) {
promise
.then(resolve)
.catch(reject)
.finally(() => timeoutSignal.cancel())
.finally(() => timeoutController.cancel())
})
},
cancel() {
Expand All @@ -33,7 +33,7 @@ function createTimeoutSignal(timeout: WaitOptions['timeout']) {
timedOut: false
}

return timeoutSignal
return timeoutController
}

export { createTimeoutSignal }
export { createTimeoutController }

0 comments on commit 4a6a8d5

Please sign in to comment.