fix: temporary fix for resumable streams (#1236)
This commit is contained in:
parent
2e5267bc11
commit
fda9f1a322
1 changed files with 8 additions and 8 deletions
|
|
@ -274,15 +274,15 @@ export async function POST(request: Request) {
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
const streamContext = getStreamContext();
|
// const streamContext = getStreamContext();
|
||||||
|
|
||||||
if (streamContext) {
|
// if (streamContext) {
|
||||||
return new Response(
|
// return new Response(
|
||||||
await streamContext.resumableStream(streamId, () =>
|
// await streamContext.resumableStream(streamId, () =>
|
||||||
stream.pipeThrough(new JsonToSseTransformStream())
|
// stream.pipeThrough(new JsonToSseTransformStream())
|
||||||
)
|
// )
|
||||||
);
|
// );
|
||||||
}
|
// }
|
||||||
|
|
||||||
return new Response(stream.pipeThrough(new JsonToSseTransformStream()));
|
return new Response(stream.pipeThrough(new JsonToSseTransformStream()));
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue