diff --git a/.github/workflows/check.yml b/.github/workflows/check.yml index b88b7c1..d4c151b 100644 --- a/.github/workflows/check.yml +++ b/.github/workflows/check.yml @@ -6,7 +6,7 @@ on: - main jobs: - publish: + ok: runs-on: ubuntu-latest permissions: diff --git a/xrpc-server/stream/stream.ts b/xrpc-server/stream/stream.ts index b509d8f..458aba6 100644 --- a/xrpc-server/stream/stream.ts +++ b/xrpc-server/stream/stream.ts @@ -114,14 +114,16 @@ export function iterateBinary(ws: WebSocket): AsyncIterable { } /** Iterate by low-level Frame (binary in → Frame out) */ -export async function* byFrame(ws: WebSocket) { +export async function* byFrame(ws: WebSocket): AsyncGenerator { for await (const chunk of iterateBinary(ws)) { yield Frame.fromBytes(chunk); } } /** Iterate by validated MessageFrame (errors throw XRPCError) */ -export async function* byMessage(ws: WebSocket) { +export async function* byMessage( + ws: WebSocket, +): AsyncGenerator> { for await (const chunk of iterateBinary(ws)) { yield ensureChunkIsMessage(chunk); }