style: add await to all writeSSE calls
This commit is contained in:
@@ -127,7 +127,7 @@ app.openapi(route, async (c) => {
|
||||
return streamSSE(
|
||||
c,
|
||||
async (stream) => {
|
||||
stream.writeSSE({ event: "user", data: JSON.stringify(user) });
|
||||
await stream.writeSSE({ event: "user", data: JSON.stringify(user) });
|
||||
|
||||
let currentPage = 1;
|
||||
let hasNextPage = true;
|
||||
@@ -143,7 +143,7 @@ app.openapi(route, async (c) => {
|
||||
}
|
||||
|
||||
if (!(pageInfo?.hasNextPage ?? false) && (pageInfo?.total ?? 0) > 0) {
|
||||
stream.writeSSE({
|
||||
await stream.writeSSE({
|
||||
event: "count",
|
||||
data: pageInfo!.total.toString(),
|
||||
});
|
||||
@@ -196,7 +196,7 @@ app.openapi(route, async (c) => {
|
||||
return;
|
||||
}
|
||||
|
||||
stream.writeSSE({
|
||||
return stream.writeSSE({
|
||||
event: "title",
|
||||
data: JSON.stringify({ title: media, episodes }),
|
||||
id: media.id.toString(),
|
||||
|
||||
Reference in New Issue
Block a user