/*********************************************************************
* 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)