This commit is contained in:
Harivansh Rathi 2026-03-06 10:13:13 -08:00
parent 5a2172fb9d
commit 2cb87538c4

View file

@ -627,7 +627,6 @@ export class GatewayRuntime {
});
response.write("\n");
const managedSession = await this.ensureSession(sessionKey);
const listener = createVercelStreamListener(response);
let unsubscribe: (() => void) | undefined;
let streamingActive = false;
@ -648,6 +647,7 @@ export class GatewayRuntime {
// Drive the session through the existing queue infrastructure
try {
const managedSession = await this.ensureSession(sessionKey);
const result = await this.enqueueManagedMessage({
request: {
sessionKey,