CancellationTests.ts
96 lines
| 2.3 KiB
| video/mp2t
|
TypeScriptLexer
cin
|
r18 | import * as tape from 'tape'; | |
| import { Cancellation } from '@implab/core/Cancellation'; | |||
| import { ICancellation } from '@implab/core/interfaces'; | |||
| import { delay } from './TestTraits'; | |||
| tape('standalone cancellation', async t => { | |||
| let doCancel: (e) => void; | |||
| let ct = new Cancellation(cancel => { | |||
| doCancel = cancel; | |||
| }); | |||
| let counter = 0; | |||
| let reason = "BILL"; | |||
| t.true(ct.isSupported(), "Cancellation must be supported"); | |||
| t.false(ct.isRequested(), "Cancellation shouldn't be requested"); | |||
| ct.throwIfRequested(); | |||
| t.pass("The exception shouldn't be thrown unless the cancellation is requested"); | |||
| ct.register(() => counter++); | |||
| t.equals(counter, 0, "counter should be zero"); | |||
| ct.register(() => counter++).destroy(); | |||
| doCancel(reason); | |||
| t.true(ct.isRequested(), "Cancellation should be requested"); | |||
| t.equals(counter, 1, "The registered callback should be triggered"); | |||
| ct.register(() => counter++); | |||
| t.equals(counter, 2, "The callback should be triggered immediately"); | |||
| let msg; | |||
| ct.register((e) => msg = e); | |||
| t.equals(msg, reason, "The cancellation reason should be passed to callback"); | |||
| try { | |||
| msg = null; | |||
| ct.throwIfRequested(); | |||
| t.fail("The exception should be thrown"); | |||
| } catch (e) { | |||
| msg = e; | |||
| } | |||
| t.equals(msg, reason, "The cancellation reason should be catched"); | |||
| t.end(); | |||
| }); | |||
| tape('async cancellation', async t => { | |||
| let ct = new Cancellation(cancel => { | |||
| cancel("STOP!"); | |||
| }); | |||
| try { | |||
| await delay(0, ct); | |||
| t.fail("Should thow the exception"); | |||
| } catch (e) { | |||
| t.equals(e, "STOP!", "Should throw the cancellation reason"); | |||
| } | |||
| t.end(); | |||
| }); | |||
| tape('cancel with external event', async t => { | |||
| let ct = new Cancellation((cancel) => { | |||
| setTimeout(x => cancel('STOP!'), 0); | |||
| }) | |||
| try { | |||
| await delay(10000, ct); | |||
| t.fail("Should thow the exception"); | |||
| } catch (e) { | |||
| t.equals(e, "STOP!", "Should throw the cancellation reason"); | |||
| } | |||
| t.end(); | |||
| }); | |||
| tape('operation normal flow', async t => { | |||
| let htimeout; | |||
| let ct = new Cancellation((cancel) => { | |||
| htimeout = setTimeout(() => cancel("STOP!"), 1000); | |||
| }); | |||
| try { | |||
| await delay(0, ct); | |||
| t.pass("Should pass"); | |||
| } finally { | |||
| clearTimeout(htimeout); | |||
| } | |||
| t.end(); | |||
| }); |