Function WaitChange

webiojs/src/models/pin.ts:38–62

(names: string[], timeout: number)

let resident_onchange_callbacks: { [name: string]: ((val: any) => void)[] } = {}; // name->[]

export function WaitChange(names: string[], timeout: number) {
    let promises = [];
    let callback_ids: { [name: string]: string } = {};
    for (let name of names) {
        promises.push(new Promise(resolve => {
            callback_ids[name] = register_on_change(name, value => {
                resolve({'name': name, 'value': value})
            });
        }));
    }
    if (timeout) {
        promises.push(new Promise(resolve => {
            setTimeout(() => {
                resolve(null);
            }, timeout * 1000);
        }));
    }
    return Promise.race(promises).then((val) => {
        for (let name of names) {
            let callback_id = callback_ids[name];
            delete disposable_onchange_callbacks[name][callback_id];
        }
        return val;
    });
}

export function PinChangeCallback(name: string, callback: null | ((val: any) => void), clear: boolean) {
    if (!(name in resident_onchange_callbacks) || clear)