Function TestAcquire

test/threadsafe_function/threadsafe_function_sum.cc:202–229

}

static Value TestAcquire(const CallbackInfo& info) {
  Function cb = info[0].As<Function>();
  Napi::Env env = info.Env();

  // We pass the test data to the Finalizer for cleanup. The finalizer is
  // responsible for deleting this data as well.
  TestData* testData = new TestData(Promise::Deferred::New(info.Env()));

  testData->tsfn =
      ThreadSafeFunction::New(env,
                              cb,
                              "Test",
                              0,
                              1,
                              testData,
                              std::function<decltype(AcquireFinalizerCallback)>(
                                  AcquireFinalizerCallback),
                              testData);

  Object result = Object::New(env);
  result["createThread"] =
      Function::New(env, CreateThread, "createThread", testData);
  result["stopThreads"] =
      Function::New(env, StopThreads, "stopThreads", testData);
  result["promise"] = testData->deferred.Promise();

  return result;
}
}  // namespace

Object InitThreadSafeFunctionSum(Env env) {