82c43ba2e3
Remove convention where Async suffix is added to functions that returns a Promise. It was a habit from C#, but is not widely used in JavaScript / TypeScript world, also bloats the code. The code is more consistent with third party dependencies/frameworks without the suffix.
82 lines
2.5 KiB
TypeScript
82 lines
2.5 KiB
TypeScript
import 'mocha';
|
|
import { expect } from 'chai';
|
|
import { sleep, SchedulerType } from '@/infrastructure/Threading/AsyncSleep';
|
|
|
|
describe('AsyncSleep', () => {
|
|
describe('sleep', () => {
|
|
it('fulfills after delay', async () => {
|
|
// arrange
|
|
const delayInMs = 10;
|
|
const scheduler = new SchedulerMock();
|
|
// act
|
|
const promise = sleep(delayInMs, scheduler.mock);
|
|
const promiseState = watchPromiseState(promise);
|
|
scheduler.tickNext(delayInMs);
|
|
await flushPromiseResolutionQueue();
|
|
// assert
|
|
const actual = promiseState.isFulfilled();
|
|
expect(actual).to.equal(true);
|
|
});
|
|
it('pending before delay', async () => {
|
|
// arrange
|
|
const delayInMs = 10;
|
|
const scheduler = new SchedulerMock();
|
|
// act
|
|
const promise = sleep(delayInMs, scheduler.mock);
|
|
const promiseState = watchPromiseState(promise);
|
|
scheduler.tickNext(delayInMs / 5);
|
|
await flushPromiseResolutionQueue();
|
|
// assert
|
|
const actual = promiseState.isPending();
|
|
expect(actual).to.equal(true);
|
|
});
|
|
});
|
|
});
|
|
|
|
function flushPromiseResolutionQueue() {
|
|
return Promise.resolve();
|
|
}
|
|
|
|
class SchedulerMock {
|
|
public readonly mock: SchedulerType;
|
|
private currentTime = 0;
|
|
private scheduledActions = new Array<{time: number, action: (...args: any[]) => void}>();
|
|
constructor() {
|
|
this.mock = (callback: (...args: any[]) => void, ms: number) => {
|
|
this.scheduledActions.push({ time: this.currentTime + ms, action: callback });
|
|
};
|
|
}
|
|
public tickNext(ms: number) {
|
|
const newTime = this.currentTime + ms;
|
|
let newActions = this.scheduledActions;
|
|
for (const action of this.scheduledActions) {
|
|
if (newTime >= action.time) {
|
|
newActions = newActions.filter((a) => a !== action);
|
|
action.action();
|
|
}
|
|
}
|
|
this.scheduledActions = newActions;
|
|
}
|
|
}
|
|
|
|
function watchPromiseState<T>(promise: Promise<T>) {
|
|
let isPending = true;
|
|
let isRejected = false;
|
|
let isFulfilled = false;
|
|
promise.then(
|
|
() => {
|
|
isFulfilled = true;
|
|
isPending = false;
|
|
},
|
|
() => {
|
|
isRejected = true;
|
|
isPending = false;
|
|
},
|
|
);
|
|
return {
|
|
isFulfilled: () => isFulfilled,
|
|
isPending: () => isPending,
|
|
isRejected: () => isRejected,
|
|
};
|
|
}
|