simulate SSE in nextjs route handlers?

[hp8wvvvgnj6asjm7]

Summary

Hi, I went through various questions here to patch this together, but I get request aborted error on the server.
is there any way to make this work?

app\api\sse\route.ts

export async function GET(request:Request) {

    const stream = new TransformStream()
    const writer = stream.writable.getWriter()
    const encoder = new TextEncoder()
    
    writer.ready
    .then(() => writer.write(encoder.encode("{balance: 1000}")))
    .catch((e) => console.log("--->writer.ready error", e))
    
    writer.closed.catch((e) => console.log("--->writer.closed error", e))
    
    setInterval(() =>  writer.write(encoder.encode("{balance: 1000}")), 5000)
    
    return new Response(stream.readable, {
        headers: {
            "Content-Type": "text/event-stream",
            "Cache-Control": "no-cache",
            "Connection": "keep-alive",
        }
    }
    )
}

Additional information

In some other thread it was suggested to use onAbort signals, but they don't work either.

TypeError: Cannot read private member #signal from an object whose class did not declare it
    at Reflect.get (<anonymous>)
    at GET (app\api\sse\route.ts:13:13)
  11 |     const encoder = new TextEncoder()
  12 |
> 13 |     request.signal.onabort = () => {
     |             ^
  14 |         console.log('abort');
  15 |         // (...other operations like closing connections to where your data comes from)
  16 |         writer.close();

Example

No response

[icyJoseph]

Hi, I went through various questions here to patch this together, but I get request aborted error on the server.
is there any way to make this work?

Does it write data at all? or is just closing after a while? Is it working locally but not when deployed?

[hp8wvvvgnj6asjm7]

Hi, I went through various questions here to patch this together, but I get request aborted error on the server.
is there any way to make this work?

Does it write data at all? or is just closing after a while? Is it working locally but not when deployed?

It does an initial 1 time response 200 with the payload (another code example i did). And after that it shows Request Aborted at the interval.

[icyJoseph]

I'll give this a go later, but I remember trying this one https://nextjs.org/docs/app/api-reference/file-conventions/route#streaming (the one that uses generators)

could you verify with it?