Function test

test/threadsafe_function/threadsafe_function_sum.js:36–59

(binding)

const sum = (N) => N.reduce((sum, n) => sum + n, 0);

function test (binding) {
  async function check (bindingFunction) {
    const calls = [];
    const result = await bindingFunction(THREAD_COUNT, Array.prototype.push.bind(calls));
    assert.ok(result);
    assert.equal(sum(calls), EXPECTED_SUM);
  }

  async function checkAcquire () {
    const calls = [];
    const { promise, createThread, stopThreads } = binding.threadsafe_function_sum.testAcquire(Array.prototype.push.bind(calls));
    for (let i = 0; i < THREAD_COUNT; i++) {
      createThread();
    }
    stopThreads();
    const result = await promise;
    assert.ok(result);
    assert.equal(sum(calls), EXPECTED_SUM);
  }

  return check(binding.threadsafe_function_sum.testDelayedTSFN)
    .then(() => check(binding.threadsafe_function_sum.testWithTSFN))
    .then(() => checkAcquire());
}