How to escalate stream error when throwing?

[charnould]

Hello,

I'm using Hono with Vercel AI SDK.
It works perfectly using function(s) below when the stream is a success, but I'd like to handle errors.

If I'm able to throw (using either onError callback or catch()), it does not escalate to the last catch() and c.html(view()) does not display either.

Do you know what I'm missing?
Thanks

try {
    // .... Logic ....
    c.header('X-Vercel-AI-Data-Stream', 'v1')
    c.header('Content-Type', 'text/event-stream; charset=utf-8')

    return stream(c, (stream) =>
      stream
        .pipe((answer as StreamTextResult<Record<string, CoreTool>, unknown>).textStream)
        .catch(() => { throw new Error('Streaming error') })
    )
  } catch (e) {
    console.log('DOES NOT PRINT')
    console.error(e)
    return c.html(view())
  }

try {
    // .... Logic ....
    c.header("X-Vercel-AI-Data-Stream", "v1");
    c.header("Content-Type", "text/event-stream; charset=utf-8");

    return stream(
      c,
      (stream) => stream.pipe(answer.textStream),
      async (e, stream) => {
        throw new Error("streaming error");
      }
    )
  } catch (e) {
    console.log('DOES NOT PRINT')
    console.error(e);
    return c.html(view());
  }
}

[EdamAme-x]

Please try to use this

app.get('/stream', (c) => {
  return stream(
    c,
    async (stream) => {
      // Write a process to be executed when aborted.
      stream.onAbort(() => {
        console.log('Aborted!')
      })
      // Write a Uint8Array.
      await stream.write(
        new Uint8Array([0x48, 0x65, 0x6c, 0x6c, 0x6f])
      )
      // Pipe a readable stream.
      await stream.pipe(anotherReadableStream)
    },
    (err, stream) => {
      // return error page here
      stream.writeln('An error occurred!')
      console.error(err)
    }
  )
})