c++ Lambda函数中的NAPI调用Emit

Question

我正在制作一个N-API插件，使用windows图形捕获API捕获视频帧，提取帧字节并将其发送回JavaScript。我已经尝试了事件发射器，但我无法获得数据。

下面是我的c++代码:

#include <napi.h>
// my other include
Napi::Value startCapture(const Napi::CallbackInfo &info){
Napi::Env env = info.Env();
Napi::Function emit = info[0].As<Napi::Function>();
emit.Call({Napi::String::New(env, "start")});
auto framePool = winrt::Direct3D11CaptureFramePool::Create(
device, //d3d device
winrt::DirectXPixelFormat::B8G8R8A8UIntNormalized,
2,
itemSize);
// capture session
auto session = framePool.CreateCaptureSession(item);
// Lambda Function 
framePool.FrameArrived([session, d3dDevice, d3dContext, &emit, &env](auto &framePool, auto &) {
auto frame = framePool.TryGetNextFrame();
auto frameTexture = GetDXGIInterfaceFromObject<ID3D11Texture2D>(frame.Surface());
// Extraction the byte and so on ...
emit.Call({Napi::String::New(env, "data"), Napi::String::New(env, "data ...")});
}

session.StartCapture();
emit.Call({Napi::String::New(env, "end")});
return Napi::String::New(env, "OK");
}

这里是我调用start capture函数的JavaScript代码

<!-- language-all: js -->
const EventEmitter = require('events').EventEmitter
const addon = require('./build/myaddon.node')
const emitter = new EventEmitter()
emitter.on('start', () => {
console.log('Start Recording ...')
})
emitter.on('data', (evt) => {
console.log(evt);
})
emitter.on('end', () => {
console.log('Stop Recording ...')
})
addon.startCapture(emitter.emit.bind(emitter))

通常我的输出应该是一个数据消息的无限循环，直到我停止它

开始录音…数据的数据．．．数据

在查看lambda函数framePool之后。FrameArrived似乎它运行在一个不同的线程比startCapture函数，如果我理解lambda函数的概念正确，我只是想找到一种方法，我如何可以使用事件发射器或任何其他推荐流这些消息到JavaScript是非常欢迎的。

Answer 1

//instead of
Napi::Env env = info.Env();
Napi::Function emit = info[0].As<Napi::Function>();    
emit.Call({Napi::String::New(env, "data"), Napi::String::New(env, "data ...")});
//try
Napi::Env env = info.Env();
Napi::Function fn = info[0].As<Napi::Function>();
emit = Persistent(fn);
emit.SuppressDestruct();
emit.Value().Call({Napi::String::New(env, "data"), Napi::String::New(env, "data ...")});