123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126
import { Evt, compose } from "../lib/index.ts";import { assert } from "../tools/typeSafety/index.ts";import { getPromiseAssertionApi } from "../tools/testing/getPromiseAssertionApi.ts";import { getHandlerPr } from "./getHandlerPr.ts";
const { mustResolve, mustStayPending } = getPromiseAssertionApi();
{    //Test type only    const evtText = new Evt<string>();
    evtText.$attach(        compose(            text => [text.toUpperCase(), { "DETACH": Evt.newCtx<boolean>(), "res": true }],            text => [text.length, { "DETACH": Evt.newCtx<number>(), "res": 3 }],            n => [`=>${n}<=`, { "DETACH": Evt.newCtx() }],            str => [str.toUpperCase(), { "DETACH": Evt.newCtx(), "err": new Error() }],            str => [str.toUpperCase(), { "DETACH": Evt.newCtx<boolean>(), "err": new Error() }]        ),        str => str.toUpperCase()    );


}

{
    const evtText = new Evt<string>();
    mustResolve({        "promise":            getHandlerPr(evtText, () =>                evtText.$attach(                    compose(                        text => [text, "DETACH"],                        text => [text]                    ),                    text => text.toLowerCase()                ))    });
    evtText.post("foo");
    assert(evtText.getHandlers().length === 0)
}
{
    const evtText = new Evt<string>();
    const ctx = Evt.newCtx();
    mustResolve({        "promise":            getHandlerPr(evtText, () =>                evtText.$attach(                    compose(                        text => [text, { "DETACH": ctx }],                        text => [text]                    ),                    ctx,                    text => text.toLowerCase()                ))    });
    evtText.post("foo");
    assert(evtText.getHandlers().length === 0)
}
{
    const evtText = new Evt<string>();

    mustStayPending(        getHandlerPr(evtText, () =>            evtText.$attach(                compose(                    text => [text, "DETACH"],                    () => null                ),                () => { }            ))    );
    evtText.post("foo");
    assert(evtText.getHandlers().length === 0)
}
{
    const evtText = new Evt<string>();
    const ctx = Evt.newCtx();
    mustStayPending(        getHandlerPr(            evtText, () =>
            evtText.$attach(                compose(                    text => [text, { "DETACH": ctx }],                    str => { str.toLowerCase(); return null; }                ),                ctx,                () => { }            )        )    );
    evtText.post("foo");
    assert(evtText.getHandlers().length === 0)
}
console.log("PASS");