Suite of AT Protocol TypeScript libraries built on web standards
20
fork

Configure Feed

Select the types of activity you want to include in your feed.

fix lint errors

+5 -3
+1 -1
.github/workflows/check.yml
··· 6 6 - main 7 7 8 8 jobs: 9 - publish: 9 + ok: 10 10 runs-on: ubuntu-latest 11 11 12 12 permissions:
+4 -2
xrpc-server/stream/stream.ts
··· 114 114 } 115 115 116 116 /** Iterate by low-level Frame (binary in → Frame out) */ 117 - export async function* byFrame(ws: WebSocket) { 117 + export async function* byFrame(ws: WebSocket): AsyncGenerator<Frame> { 118 118 for await (const chunk of iterateBinary(ws)) { 119 119 yield Frame.fromBytes(chunk); 120 120 } 121 121 } 122 122 123 123 /** Iterate by validated MessageFrame (errors throw XRPCError) */ 124 - export async function* byMessage(ws: WebSocket) { 124 + export async function* byMessage( 125 + ws: WebSocket, 126 + ): AsyncGenerator<MessageFrame<unknown>> { 125 127 for await (const chunk of iterateBinary(ws)) { 126 128 yield ensureChunkIsMessage(chunk); 127 129 }