rondomoon/rondo-framework
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Fix TaskManager.test.ts

Browse Source
This commit is contained in:
Jerko Steiner 2019-09-02 11:11:21 +07:00
parent 03c53e3a00
commit d74faf7c0f
1 changed files with 20 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
packages/tasq/src/TaskManager.test.ts
View File

@ -10,7 +10,7 @@ describe('TaskManager', () => {
describe('post', () => {
it('posts new tasks and executes asynchronously', async () => {
const results: number[] = []
const te = new TaskManager<number>(
const te = new TaskManager<number, void>(
1,
() => new PromiseExecutor(async task => {
await delay(task.definition)
@ -25,7 +25,7 @@ describe('TaskManager', () => {
})
it('executes tasks in different order', async () => {
const results: number[] = []
const te = new TaskManager<number>(
const te = new TaskManager<number, void>(
2,
() => new PromiseExecutor(async task => {
await delay(task.definition)
@ -42,7 +42,7 @@ describe('TaskManager', () => {
it('returns promises when job posted', async () => {
const results: number[] = []
const te = new TaskManager<number>(
const te = new TaskManager<number, void>(
2,
() => new PromiseExecutor(async task => {
await delay(task.definition)
@ -58,6 +58,22 @@ describe('TaskManager', () => {
expect(results).toEqual([50, 100, 10, 85])
})
it('can return values from promises', async () => {
interface IParams {
a: number,
b: number,
delay: number
}
const te = new TaskManager<IParams, number>(
2,
() => new PromiseExecutor(async task => {
const {definition} = task
await delay(definition.delay)
return definition.a + definition.b
}),
)
})
})
async function getError(p: Promise<unknown>): Promise<Error> {
@ -73,7 +89,7 @@ describe('TaskManager', () => {
describe('error handling', () => {
it('does not fail on error', async () => {
const tm = new TaskManager<number>(2,
const tm = new TaskManager<number, void>(2,
() => new PromiseExecutor(async task => {
await delay(task.definition)
if (task.definition % 2 === 0) {