mirror of
https://github.com/oven-sh/bun
synced 2026-02-16 05:42:43 +00:00
addressing some pr feedback
This commit is contained in:
@@ -366,34 +366,34 @@ ScriptExecutionContext* executionContext(JSC::JSGlobalObject* globalObject)
|
||||
void ScriptExecutionContext::postTaskConcurrently(Function<void(ScriptExecutionContext&)>&& lambda)
|
||||
{
|
||||
auto* task = new EventLoopTask(WTFMove(lambda));
|
||||
reinterpret_cast<Zig::GlobalObject*>(m_globalObject)->queueTaskConcurrently(task);
|
||||
static_cast<Zig::GlobalObject*>(m_globalObject)->queueTaskConcurrently(task);
|
||||
}
|
||||
// Executes the task on context's thread asynchronously.
|
||||
void ScriptExecutionContext::postTask(Function<void(ScriptExecutionContext&)>&& lambda)
|
||||
{
|
||||
auto* task = new EventLoopTask(WTFMove(lambda));
|
||||
reinterpret_cast<Zig::GlobalObject*>(m_globalObject)->queueTask(task);
|
||||
static_cast<Zig::GlobalObject*>(m_globalObject)->queueTask(task);
|
||||
}
|
||||
// Executes the task on context's thread asynchronously.
|
||||
void ScriptExecutionContext::postTask(EventLoopTask* task)
|
||||
{
|
||||
reinterpret_cast<Zig::GlobalObject*>(m_globalObject)->queueTask(task);
|
||||
static_cast<Zig::GlobalObject*>(m_globalObject)->queueTask(task);
|
||||
}
|
||||
// Executes the task on context's thread immediately.
|
||||
void ScriptExecutionContext::postImmediateCppTask(Function<void(ScriptExecutionContext&)>&& lambda)
|
||||
{
|
||||
auto* task = new EventLoopTask(WTFMove(lambda));
|
||||
reinterpret_cast<Zig::GlobalObject*>(m_globalObject)->queueImmediateCppTask(task);
|
||||
static_cast<Zig::GlobalObject*>(m_globalObject)->queueImmediateCppTask(task);
|
||||
}
|
||||
// Executes the task on context's thread immediately.
|
||||
void ScriptExecutionContext::postImmediateCppTask(EventLoopTask* task)
|
||||
{
|
||||
reinterpret_cast<Zig::GlobalObject*>(m_globalObject)->queueImmediateCppTask(task);
|
||||
static_cast<Zig::GlobalObject*>(m_globalObject)->queueImmediateCppTask(task);
|
||||
}
|
||||
// Executes the task on context's thread asynchronously.
|
||||
void ScriptExecutionContext::postTaskOnTimeout(EventLoopTask* task, Seconds timeout)
|
||||
{
|
||||
reinterpret_cast<Zig::GlobalObject*>(m_globalObject)->queueTaskOnTimeout(task, static_cast<int>(timeout.milliseconds()));
|
||||
static_cast<Zig::GlobalObject*>(m_globalObject)->queueTaskOnTimeout(task, static_cast<int>(timeout.milliseconds()));
|
||||
}
|
||||
// Executes the task on context's thread asynchronously.
|
||||
void ScriptExecutionContext::postTaskOnTimeout(Function<void(ScriptExecutionContext&)>&& lambda, Seconds timeout)
|
||||
|
||||
@@ -313,7 +313,7 @@ void MessagePort::dispatchMessages()
|
||||
auto messagesTakenHandler = [this, protectedThis = Ref { *this }](Vector<MessageWithMessagePorts>&& messages, CompletionHandler<void()>&& completionCallback) mutable {
|
||||
RefPtr<ScriptExecutionContext> context = scriptExecutionContext();
|
||||
if (!context || !context->globalObject()) {
|
||||
WTFMove(completionCallback)();
|
||||
completionCallback();
|
||||
return;
|
||||
}
|
||||
|
||||
|
||||
@@ -121,7 +121,7 @@ pub fn drainMicrotasksWithGlobal(this: *EventLoop, globalObject: *JSC.JSGlobalOb
|
||||
|
||||
// this exists because while we're inside a spawnSync call, some tasks can actually
|
||||
// still complete which leads to a case where module resolution can partially complete and
|
||||
// some modules are only partialy evaluated which causes reference errors.
|
||||
// some modules are only partially evaluated which causes reference errors.
|
||||
// TODO: A better fix here could be a second event loop so we can come off the main one
|
||||
// while processing spawnSync, then resume back to here afterwards
|
||||
if (this.is_inside_spawn_sync) {
|
||||
|
||||
Reference in New Issue
Block a user