diff --git a/src/core/co_initialize/co_stub.cc b/src/core/co_initialize/co_stub.cc index 37712593..5fbaa088 100644 --- a/src/core/co_initialize/co_stub.cc +++ b/src/core/co_initialize/co_stub.cc @@ -373,14 +373,16 @@ void OnBackendLoad(uint16_t ftpPort, uint16_t ipcPort) Logger.Log("Frontend notifier finished!"); } -const void CoInitializer::InjectFrontendShims(uint16_t ftpPort, uint16_t ipcPort) { +const void CoInitializer::InjectFrontendShims(uint16_t ftpPort, uint16_t ipcPort) +{ std::mutex mtx; std::condition_variable cv; bool hasSuccess = false, hasPaused = false; Logger.Log("Preparing to inject frontend shims..."); - JavaScript::SharedJSMessageEmitter::InstanceRef().OnMessage("msg", [&](const nlohmann::json& eventMessage, int listenerId) { + JavaScript::SharedJSMessageEmitter::InstanceRef().OnMessage("msg", [&](const nlohmann::json& eventMessage, int listenerId) + { std::lock_guard lock(mtx); if (eventMessage.value("id", -1) == 65756) diff --git a/src/core/ffi/ffi.h b/src/core/ffi/ffi.h index ff98fda0..69d2681c 100644 --- a/src/core/ffi/ffi.h +++ b/src/core/ffi/ffi.h @@ -84,7 +84,7 @@ namespace JavaScript { auto it = missedMessages.find(event); if (it != missedMessages.end()) { for (const auto message : it->second) { - std::thread([handler, message, listenerId] { handler(message, listenerId); }).detach(); + handler(message, listenerId); } missedMessages.erase(it); // Clear missed messages once delivered }