handle async onmessage hook

fabio-sassi-spotview · web-flow · commit 2b54a54ce931 · 2025-09-11T14:37:10.000+02:00
diff --git a/src/server/sse.ts b/src/server/sse.ts
@@ -191,7 +191,7 @@ export class SSEServerTransport implements Transport {
       throw error;
     }
 
-    this.onmessage?.(parsedMessage, extra);
+    await this.onmessage?.(parsedMessage, extra);
   }
 
   async close(): Promise<void> {

Original file line number	Diff line number	Diff line change
`@@ -191,7 +191,7 @@ export class SSEServerTransport implements Transport {`
`191`	`191`	`throw error;`
`192`	`192`	`}`
`193`	`193`
`194`		`- this.onmessage?.(parsedMessage, extra);`
	`194`	`+ await this.onmessage?.(parsedMessage, extra);`
`195`	`195`	`}`
`196`	`196`
`197`	`197`	`async close(): Promise<void> {`