File size: 1,514 Bytes
84c1942 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 | import Protocol from '../protocol';
describe('protocol', () => {
beforeAll(() => {
// @ts-ignore
global.Worker = class Worker {};
});
afterAll(() => {
// @ts-ignore
delete global.Worker;
});
it('resolves a promise for a request', async () => {
const p1 = new Protocol('test', () => 'blaat', self);
const p2 = new Protocol('test', () => 'taalb', self);
const [res1, res2] = await Promise.all([p1.sendMessage('koekje'), p2.sendMessage('koekje')]);
expect(res1).toBe('taalb');
expect(res2).toBe('blaat');
p1.dispose();
p2.dispose();
});
it('can read and respond to data', async () => {
const p1 = new Protocol(
'test',
(s: string) =>
s
.split('')
.reverse()
.join(''),
self
);
const p2 = new Protocol('test', () => 'taalb', self);
const res = await p2.sendMessage('ab');
expect(res).toBe('ba');
p1.dispose();
p2.dispose();
});
it('ignores the wrong listener types', async () => {
const p1 = new Protocol(
'test',
(s: string) =>
s
.split('')
.reverse()
.join(''),
self
);
const p2 = new Protocol('aa', () => 'saalp', self);
const p3 = new Protocol(
'test',
() => new Promise(r => setTimeout(() => r('taalb'), 1000)),
self
);
const res = await p1.sendMessage('kk');
expect(res).toBe('taalb');
p1.dispose();
p2.dispose();
p3.dispose();
});
});
|