94 lines
2.0 KiB
TypeScript
Raw Normal View History

2018-09-19 15:36:56 -04:00
import { queueJob, nextTick } from '../src/index'
2018-09-19 17:45:19 -04:00
describe('scheduler', () => {
2018-09-20 11:43:14 -04:00
it('queueJob', async () => {
2018-09-19 17:45:19 -04:00
const calls: any = []
const job1 = () => {
calls.push('job1')
}
const job2 = () => {
calls.push('job2')
}
queueJob(job1)
2018-09-19 15:36:56 -04:00
queueJob(job2)
2018-09-19 17:45:19 -04:00
expect(calls).toEqual([])
await nextTick()
2018-09-19 15:36:56 -04:00
expect(calls).toEqual(['job1', 'job2'])
2018-09-19 17:45:19 -04:00
})
2018-09-19 15:36:56 -04:00
2018-09-20 11:43:14 -04:00
it('queueJob while already flushing', async () => {
2018-09-19 17:45:19 -04:00
const calls: any = []
const job1 = () => {
calls.push('job1')
// job1 queues job2
queueJob(job2)
}
const job2 = () => {
calls.push('job2')
}
queueJob(job1)
expect(calls).toEqual([])
await nextTick()
expect(calls).toEqual(['job1', 'job2'])
})
2018-09-19 15:36:56 -04:00
2018-09-20 11:43:14 -04:00
it('queueJob w/ postFlushCb', async () => {
2018-09-19 17:45:19 -04:00
const calls: any = []
const job1 = () => {
calls.push('job1')
}
const job2 = () => {
calls.push('job2')
}
const cb1 = () => {
calls.push('cb1')
}
const cb2 = () => {
calls.push('cb2')
}
queueJob(job1, cb1)
2018-09-19 15:36:56 -04:00
queueJob(job2, cb2)
2018-09-19 17:45:19 -04:00
await nextTick()
expect(calls).toEqual(['job1', 'job2', 'cb1', 'cb2'])
})
2018-09-20 11:43:14 -04:00
it('queueJob w/ postFlushCb while flushing', async () => {
2018-09-19 17:45:19 -04:00
const calls: any = []
const job1 = () => {
calls.push('job1')
// job1 queues job2
queueJob(job2, cb2)
}
const job2 = () => {
calls.push('job2')
}
const cb1 = () => {
calls.push('cb1')
}
const cb2 = () => {
calls.push('cb2')
}
queueJob(job1, cb1)
expect(calls).toEqual([])
await nextTick()
expect(calls).toEqual(['job1', 'job2', 'cb1', 'cb2'])
})
2018-09-20 11:43:14 -04:00
it('should dedupe queued tasks', async () => {
const calls: any = []
const job1 = () => {
calls.push('job1')
}
const job2 = () => {
calls.push('job2')
}
queueJob(job1)
queueJob(job2)
queueJob(job1)
queueJob(job2)
expect(calls).toEqual([])
await nextTick()
expect(calls).toEqual(['job1', 'job2'])
})
2018-09-19 15:36:56 -04:00
})