Method Run

src/NodeRTLib/ProjectFiles/node-async.h:159–178

 public:
  template <typename TInput, typename TResult>
  static void __cdecl Run(
      std::shared_ptr<TInput> input,
      std::function<void(Baton<TInput, TResult>*)> doWork,
      std::function<void(Baton<TInput, TResult>*)> afterWork,
      Handle<Function> callback,
      Handle<Value> receiver = Handle<Value>()) {
    HandleScope scope;
    Local<Object> callbackData = CreateCallbackData(callback, receiver);

    Baton<TInput, TResult>* baton = new Baton<TInput, TResult>();
    baton->request.data = baton;
    baton->callbackData.Reset(callbackData);
    baton->error_code = 0;
    baton->data = input;
    baton->doWork = doWork;
    baton->afterWork = afterWork;

    uv_queue_work(uv_default_loop(), &baton->request,
                  AsyncWork<TInput, TResult>, AsyncAfter<TInput, TResult>);
  }

  static uv_async_t* __cdecl GetAsyncToken() {
    return TokenData::NewAsyncToken();