|
1 | 1 | #include "node.h"
|
2 | 2 | #include "v8.h"
|
| 3 | +#include "uv.h" |
3 | 4 |
|
4 | 5 | #include <assert.h>
|
5 | 6 | #include <vector>
|
@@ -30,8 +31,39 @@ void RunInCallbackScope(const v8::FunctionCallbackInfo<v8::Value>& args) {
|
30 | 31 | args.GetReturnValue().Set(ret.ToLocalChecked());
|
31 | 32 | }
|
32 | 33 |
|
| 34 | +static v8::Persistent<v8::Promise::Resolver> persistent; |
| 35 | + |
| 36 | +static void Callback(uv_work_t* req, int ignored) { |
| 37 | + v8::Isolate* isolate = v8::Isolate::GetCurrent(); |
| 38 | + v8::HandleScope scope(isolate); |
| 39 | + node::CallbackScope callback_scope(isolate, v8::Object::New(isolate), {0, 0}); |
| 40 | + |
| 41 | + v8::Local<v8::Promise::Resolver> local = |
| 42 | + v8::Local<v8::Promise::Resolver>::New(isolate, persistent); |
| 43 | + local->Resolve(v8::Undefined(isolate)); |
| 44 | + delete req; |
| 45 | +} |
| 46 | + |
| 47 | +static void TestResolveAsync(const v8::FunctionCallbackInfo<v8::Value>& args) { |
| 48 | + v8::Isolate* isolate = args.GetIsolate(); |
| 49 | + |
| 50 | + if (persistent.IsEmpty()) { |
| 51 | + persistent.Reset(isolate, v8::Promise::Resolver::New(isolate)); |
| 52 | + |
| 53 | + uv_work_t* req = new uv_work_t; |
| 54 | + |
| 55 | + uv_queue_work(uv_default_loop(), req, [](uv_work_t*) {}, Callback); |
| 56 | + } |
| 57 | + |
| 58 | + v8::Local<v8::Promise::Resolver> local = |
| 59 | + v8::Local<v8::Promise::Resolver>::New(isolate, persistent); |
| 60 | + |
| 61 | + args.GetReturnValue().Set(local->GetPromise()); |
| 62 | +} |
| 63 | + |
33 | 64 | void Initialize(v8::Local<v8::Object> exports) {
|
34 | 65 | NODE_SET_METHOD(exports, "runInCallbackScope", RunInCallbackScope);
|
| 66 | + NODE_SET_METHOD(exports, "testResolveAsync", TestResolveAsync); |
35 | 67 | }
|
36 | 68 |
|
37 | 69 | } // namespace
|
|
0 commit comments