apunkt/rowboat
1
0
Fork 0
mirror of https://github.com/rowboatlabs/rowboat.git synced 2026-04-26 00:46:23 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

add describe for /stream

Browse source
This commit is contained in:
Ramnique Singh 2025-12-08 12:33:49 +05:30
parent 9ad6331fbc
commit 1822deadc1
1 changed files with 4 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

17
apps/cli/src/server.ts
View file

@ -573,6 +573,10 @@ const routes = new Hono()
)
.get(
'/stream',
describeRoute({
summary: 'Subscribe to run events',
description: 'Subscribe to run events',
}),
async (c) => {
return streamSSE(c, async (stream) => {
const bus = container.resolve<IBus>('bus');
@ -607,19 +611,6 @@ const routes = new Hono()
});
}
)
.get('/sse', async (c) => {
return streamSSE(c, async (stream) => {
while (true) {
const message = `It is ${new Date().toISOString()}`
await stream.writeSSE({
data: message,
event: 'time-update',
id: String(id++),
})
await stream.sleep(1000)
}
})
})
;
const app = new Hono()