romtuck/openclaw
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

make twitch message processing non blocking

Browse Source
This commit is contained in:
jaydenfyi 2026-01-26 00:29:33 +08:00
parent fab430da57
commit c078621935
1 changed files with 12 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
extensions/twitch/src/monitor.ts
View File

@ -206,7 +206,7 @@ export async function monitorTwitchProvider(
throw error; throw error;
} }
const unregisterHandler = clientManager.onMessage(account, async (message) => { const unregisterHandler = clientManager.onMessage(account, (message) => {
if (stopped) return; if (stopped) return;
// Access control check // Access control check
@ -228,19 +228,18 @@ export async function monitorTwitchProvider(
statusSink?.({ lastInboundAt: Date.now() }); statusSink?.({ lastInboundAt: Date.now() });
try { // Fire-and-forget: process message without blocking
await processTwitchMessage({ void processTwitchMessage({
message, message,
account, account,
accountId, accountId,
config, config,
runtime, runtime,
core, core,
statusSink, statusSink,
}); }).catch((err) => {
} catch (err) {
runtime.error?.(`Message processing failed: ${String(err)}`); runtime.error?.(`Message processing failed: ${String(err)}`);
} });
}); });
const stop = () => { const stop = () => {