test: wip tests for observer

This commit is contained in:
Evan You
2018-09-19 17:45:19 -04:00
parent 7350d41f92
commit 26ff9b29f9
11 changed files with 891 additions and 74 deletions

View File

@@ -1,78 +1,80 @@
import { queueJob, nextTick } from '../src/index'
test('queueJob', async () => {
const calls: any = []
const job1 = () => {
calls.push('job1')
}
const job2 = () => {
calls.push('job2')
}
queueJob(job1)
queueJob(job2)
expect(calls).toEqual([])
await nextTick()
expect(calls).toEqual(['job1', 'job2'])
})
test('queueJob while already flushing', async () => {
const calls: any = []
const job1 = () => {
calls.push('job1')
// job1 queues job2
describe('scheduler', () => {
test('queueJob', async () => {
const calls: any = []
const job1 = () => {
calls.push('job1')
}
const job2 = () => {
calls.push('job2')
}
queueJob(job1)
queueJob(job2)
// should be called sync
expect(calls).toEqual([])
await nextTick()
expect(calls).toEqual(['job1', 'job2'])
}
const job2 = () => {
calls.push('job2')
}
queueJob(job1)
expect(calls).toEqual([])
await nextTick()
expect(calls).toEqual(['job1', 'job2'])
})
})
test('queueJob w/ postFlushCb', async () => {
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)
queueJob(job2, cb2)
await nextTick()
expect(calls).toEqual(['job1', 'job2', 'cb1', 'cb2'])
})
test('queueJob while already flushing', async () => {
const calls: any = []
const job1 = () => {
calls.push('job1')
// job1 queues job2
queueJob(job2)
// should be called sync
expect(calls).toEqual(['job1', 'job2'])
}
const job2 = () => {
calls.push('job2')
}
queueJob(job1)
expect(calls).toEqual([])
await nextTick()
expect(calls).toEqual(['job1', 'job2'])
})
test('queueJob w/ postFlushCb while flushing', async () => {
const calls: any = []
const job1 = () => {
calls.push('job1')
// job1 queues job2
test('queueJob w/ postFlushCb', async () => {
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)
queueJob(job2, cb2)
// should be called sync
expect(calls).toEqual(['job1', 'job2'])
}
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'])
await nextTick()
expect(calls).toEqual(['job1', 'job2', 'cb1', 'cb2'])
})
test('queueJob w/ postFlushCb while flushing', async () => {
const calls: any = []
const job1 = () => {
calls.push('job1')
// job1 queues job2
queueJob(job2, cb2)
// should be called sync
expect(calls).toEqual(['job1', 'job2'])
}
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'])
})
})