Function countAll

integration-tests/tasks_get_del_bucket.ts:84–105

(bucket?: Tasks.TaskBucket)

}

async function countAll(bucket?: Tasks.TaskBucket): Promise<number> {
    let last = 0;
    let n = 0;
    while (true) {
        const batch = bucket
            ? await bucket.getMany({
                afterId: last,
            })
            : await Tasks.getMany({
                afterId: last,
            });

        if (batch && batch.length > 0) {
            last = batch[batch.length - 1].id;
            n += batch.length;
        } else {
            break;
        }
    }

    return n
}

async function testDelSingular() {
    let task1 = await bucket.schedule({ executeAt: new Date(Date.now() + 1000000), key: "1" });