diff --git a/packages/web-runtime/src/container/sse/helpers.ts b/packages/web-runtime/src/container/sse/helpers.ts
index 9c12c9c69a..5ee2ea55f4 100644
--- a/packages/web-runtime/src/container/sse/helpers.ts
+++ b/packages/web-runtime/src/container/sse/helpers.ts
@@ -1,12 +1,12 @@
 import { eventSchema, SseEventWrapperOptions } from './types'
 
-export const sseEventWrapper = (options: SseEventWrapperOptions) => {
+export const sseEventWrapper = async (options: SseEventWrapperOptions) => {
   const { topic, msg, method, ...sseEventOptions } = options
   try {
     const sseData = eventSchema.parse(JSON.parse(msg.data))
     console.debug(`SSE event '${topic}'`, sseData)
 
-    return method({ ...sseEventOptions, sseData })
+    await method({ ...sseEventOptions, sseData })
   } catch (e) {
     console.error(`Unable to process sse event ${topic}`, e)
   }