[ Web Proxy ]
URL:
Viewing: https://raw.githubusercontent.com/nodejs/nan/main/test/cpp/callbackcontext.cpp [Back]  [Original]

/*********************************************************************
 * NAN - Native Abstractions for Node.js
 *
 * Copyright (c) 2018 NAN contributors
 *
 * MIT License 
 ********************************************************************/

#include 

#include "sleep.h"  // NOLINT(build/include_subdir)

using namespace Nan;  // NOLINT(build/namespaces)

class DelayRequest : public AsyncResource {
 public:
  DelayRequest(int milliseconds_, v8::Local callback_)
    : AsyncResource("nan:test.DelayRequest"),
      callback(callback_),
      milliseconds(milliseconds_) {
      request.data = this;
    }
  ~DelayRequest() {}

  Callback callback;
  uv_work_t request;
  int milliseconds;
};

void Delay(uv_work_t* req) {
  DelayRequest *delay_request = static_cast(req->data);
  Sleep(delay_request->milliseconds);
}

void AfterDelay(uv_work_t* req, int status) {
  HandleScope scope;

  DelayRequest *delay_request = static_cast(req->data);

  v8::Local target = New();

  // Run the callback in the async context.
  delay_request->callback.Call(target, 0, NULL, delay_request);

  delete delay_request;
}

NAN_METHOD(Delay) {
  int delay = To(info[0]).FromJust();
  v8::Local cb = To(info[1]).ToLocalChecked();

  DelayRequest* delay_request = new DelayRequest(delay, cb);

  uv_queue_work(
      GetCurrentEventLoop()
    , &delay_request->request
    , Delay
    , reinterpret_cast(AfterDelay));
}

NAN_MODULE_INIT(Init) {
  Set(target, New("delay").ToLocalChecked(),
    GetFunction(New(Delay)).ToLocalChecked());
}

NODE_MODULE(asyncresource, Init)

Web Proxy Viewer  |  New URL  |  Original Page