123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159
import { Evt } from "../lib/index.ts";
export interface Person {    name: string;    age: number;    [prom: string]: any;}
export interface TypedPerson extends Person {    sex: "male" | "female";}
export function isTyped(p: Person): p is TypedPerson {    return p.sex ? true : false;}
let testCount = 0;
export class TypedPersonIntro {

    private intro = "this person is ";
    public introduce(tp: TypedPerson): void {
        console.assert(this.intro + tp.sex === "this person is female" && tp === sourceEvt[1]);
        testCount++;
    }}
let tpi = new TypedPersonIntro();
let evt = new Evt<Person>();
//evt.enableTrace("evt");
let sourceEvt: Person[] = [    {        "name": "Joseph",        "age": 26    },    {        "name": "Sienna",        "age": 22,        "sex": "female"    },    {        "name": "Antonin",        "age": 22,        "sex": "male"    },    {        "name": "Joseph",        "age": 26    },    {        "name": "Jean-Marc",        "age": 53,        "sex": "male"    }];

console.assert(evt.getHandlers().length === 0);console.assert(evt.getHandlers().filter(({ once, async }) => once && !async).length === 0);console.assert(evt.getHandlers().filter(({ once }) => !once).length === 0);console.assert(evt.getHandlers().filter(({ async }) => async).length === 0);
evt.attachOnce(isTyped, person=> tpi.introduce(person));
console.assert(evt.getHandlers().length === 1);console.assert(evt.getHandlers().filter(({ once, async }) => once && !async).length === 1);console.assert(evt.getHandlers().filter(({ once }) => !once).length === 0);console.assert(evt.getHandlers().filter(({ async }) => async).length === 0);
let resultAttach: Person[] = [];
evt.attach(person => resultAttach.push(person));
console.assert(evt.getHandlers().length === 2);console.assert(evt.getHandlers().filter(({ once, async }) => once && !async).length === 1);console.assert(evt.getHandlers().filter(({ once }) => !once).length === 1);console.assert(evt.getHandlers().filter(({ async }) => async).length === 0);

setTimeout(() => {
    console.assert(evt.postCount === 0);
    evt.post(sourceEvt[0]);    evt.post(sourceEvt[1]);
    console.assert(evt.getHandlers().length === 1);    console.assert(evt.getHandlers().filter(({ once, async }) => once && !async).length === 0);    console.assert(evt.getHandlers().filter(({ once }) => !once).length === 1);    console.assert(evt.getHandlers().filter(({ async }) => async).length === 0);

    evt.post(sourceEvt[2]);
}, 0);
setTimeout(() => {
    console.assert(evt.getHandlers().length === 2);    console.assert(evt.getHandlers().filter(({ once, async }) => once && !async).length === 0);    console.assert(evt.getHandlers().filter(({ once }) => !once).length === 1);    console.assert(evt.getHandlers().filter(({ async }) => async).length === 1);

    evt.post(sourceEvt[3]);    evt.post(sourceEvt[4]);
    console.assert(evt.postCount === 5);
    console.assert(testCount === 1);
    for (let i = 0; i < resultAttach.length; i++)        console.assert(resultAttach[i] === sourceEvt[i]);    }, 200);

let success= false;
(async () => {
    let personCount = 0;    let arr: TypedPerson[] = [];
    while (true) {
        let typedPerson = await evt.waitFor(isTyped);
        console.assert(evt.getHandlers().filter(({ async }) => async).length === 0);
        arr.push(typedPerson);
        if (++personCount === 3) break;
    }
    console.assert(arr[0] === sourceEvt[1] && arr[1] === sourceEvt[2] && arr[2] === sourceEvt[4], "m");
    success= true;
})();


setTimeout(()=>{
    console.assert(success);
    console.log("PASS");
}, 2000);