summaryrefslogtreecommitdiffhomepage
path: root/packages/kernel/src/bus/pure.ts
diff options
context:
space:
mode:
Diffstat (limited to 'packages/kernel/src/bus/pure.ts')
-rw-r--r--packages/kernel/src/bus/pure.ts8
1 files changed, 4 insertions, 4 deletions
diff --git a/packages/kernel/src/bus/pure.ts b/packages/kernel/src/bus/pure.ts
index 7cd9143..4d90fc6 100644
--- a/packages/kernel/src/bus/pure.ts
+++ b/packages/kernel/src/bus/pure.ts
@@ -12,11 +12,11 @@ export function dispatchEventSync<T>(
const result = handler(payload);
if (result instanceof Promise) {
result.catch((err: unknown) => {
- logger.error(`Event hook "${hookId}" handler rejected`, err);
+ logger.error(`Event hook "${hookId}" handler rejected`, { err });
});
}
} catch (err) {
- logger.error(`Event hook "${hookId}" handler threw`, err);
+ logger.error(`Event hook "${hookId}" handler threw`, { err });
}
}
}
@@ -32,7 +32,7 @@ export async function dispatchEventAsync<T>(
try {
await handler(payload);
} catch (err) {
- logger.error(`Event hook "${hookId}" handler threw`, err);
+ logger.error(`Event hook "${hookId}" handler threw`, { err });
}
});
@@ -76,7 +76,7 @@ export async function applyFilterChain<T>(
current = await fn(current);
} catch (err) {
if (failClosed) throw err;
- logger.error(`Filter "${hookId}" handler threw (fail-open, passing through)`, err);
+ logger.error(`Filter "${hookId}" handler threw (fail-open, passing through)`, { err });
}
}
return current;