async function waitForStatus()

in packages/azure-kusto-ingest/example.js [79:93]

• 14 lines of code
• 5 McCabe index (conditional complexity)

async function waitForStatus(numberOFIngestions = 1) {
    while ((await statusQueues.failure.isEmpty()) && (await statusQueues.success.isEmpty())) {
        console.log("Waiting for status...");
        await sleep(1000);
    }

    const failures = await statusQueues.failure.pop(numberOFIngestions);
    for (let failure of failures) {
        console.log(`Failed: ${JSON.stringify(failure)}`);
    }
    const successes = await statusQueues.success.pop(numberOFIngestions);
    for (let success of successes) {
        console.log(`Succeeded: ${JSON.stringify(success)}`);
    }
}