add bun idleTimeout = 0

Author: caozhiyuan

src/routes/responses/handler.ts

@@ -52,29 +52,13 @@ export const handleResponses = async (c: Context) => {
   if (isStreamingRequested(payload) && isAsyncIterable(response)) {
     consola.debug("Forwarding native Responses stream")
     return streamSSE(c, async (stream) => {
-      const pingInterval = setInterval(async () => {
-        try {
-          await stream.writeSSE({
-            event: "ping",
-            data: JSON.stringify({ timestamp: Date.now() }),
-          })
-        } catch (error) {
-          consola.warn("Failed to send ping:", error)
-          clearInterval(pingInterval)
-        }
-      }, 3000)
-
-      try {
-        for await (const chunk of response) {
-          consola.debug("Responses stream chunk:", JSON.stringify(chunk))
-          await stream.writeSSE({
-            id: (chunk as { id?: string }).id,
-            event: (chunk as { event?: string }).event,
-            data: (chunk as { data?: string }).data ?? "",
-          })
-        }
-      } finally {
-        clearInterval(pingInterval)
+      for await (const chunk of response) {
+        consola.debug("Responses stream chunk:", JSON.stringify(chunk))
+        await stream.writeSSE({
+          id: (chunk as { id?: string }).id,
+          event: (chunk as { event?: string }).event,
+          data: (chunk as { data?: string }).data ?? "",
+        })
       }
     })
   }

src/start.ts

@@ -111,6 +111,9 @@ export async function runServer(options: RunServerOptions): Promise<void> {
   serve({
     fetch: server.fetch as ServerHandler,
     port: options.port,
+    bun: {
+      idleTimeout: 0,
+    },
   })
 }