|
|
import tape = require("tape");
|
|
|
import { delay } from "./TestTraits";
|
|
|
import { Cancellation } from "@implab/core/Cancellation";
|
|
|
import { first, isPromise } from "@implab/core/safe";
|
|
|
|
|
|
tape("await delay test", async t => {
|
|
|
// schedule delay
|
|
|
let resolved = false;
|
|
|
let res = delay(0).then(() => resolved = true);
|
|
|
|
|
|
t.false(resolved, "the delay should be async");
|
|
|
|
|
|
await res;
|
|
|
t.pass("await delay");
|
|
|
|
|
|
// create cancellation token
|
|
|
let cancel: (e?: any) => void;
|
|
|
const ct = new Cancellation(c => cancel = c);
|
|
|
|
|
|
// schedule delay
|
|
|
resolved = false;
|
|
|
res = delay(0, ct).then(() => resolved = true);
|
|
|
|
|
|
t.false(resolved, "created delay with ct");
|
|
|
|
|
|
// cancel
|
|
|
cancel();
|
|
|
|
|
|
try {
|
|
|
await res;
|
|
|
t.fail("the delay should fail when it is cancelled");
|
|
|
} catch {
|
|
|
t.pass("the delay is cancelled");
|
|
|
}
|
|
|
|
|
|
let died = false;
|
|
|
|
|
|
// try schedule delay after the cancellation is requested
|
|
|
res = delay(0, ct).then(x => true, () => died = true);
|
|
|
|
|
|
t.false(died, "The delay should be scheduled even if the cancellation is requested");
|
|
|
|
|
|
await res;
|
|
|
t.true(died, "the delay should fail when cancelled");
|
|
|
|
|
|
t.end();
|
|
|
});
|
|
|
|
|
|
tape("sequemce test", async t => {
|
|
|
const sequence = ["a", "b", "c"];
|
|
|
const empty = [];
|
|
|
|
|
|
// synchronous tests
|
|
|
t.equals(first(sequence), "a", "Should return the first element");
|
|
|
|
|
|
let v: string;
|
|
|
let e: Error;
|
|
|
first(sequence, x => v = x);
|
|
|
t.equal(v, "a", "The callback should be called for the first element");
|
|
|
|
|
|
t.throws(() => {
|
|
|
first(empty);
|
|
|
}, "Should throw when the sequence is empty");
|
|
|
|
|
|
t.throws(() => {
|
|
|
first(empty, x => v = x);
|
|
|
}, "Should throw when the sequence is empty");
|
|
|
|
|
|
first(empty, null, x => e = x);
|
|
|
t.true(e, "The errorback should be called for the empty sequence");
|
|
|
|
|
|
// async tests
|
|
|
const asyncSequence = Promise.resolve(sequence);
|
|
|
const asyncEmptySequence = Promise.resolve(empty);
|
|
|
|
|
|
const promise = first(asyncSequence);
|
|
|
t.true(isPromise(promise), "Should return promise");
|
|
|
|
|
|
v = await promise;
|
|
|
t.equal(v, "a", "Should return the first element");
|
|
|
|
|
|
v = await new Promise(resolve => first(asyncSequence, resolve));
|
|
|
t.equal(v, "a", "The callback should be called for the first element");
|
|
|
|
|
|
t.end();
|
|
|
});
|
|
|
|
