@@ -9,6 +9,7 @@ import type { TYPED_STREAM_KEY } from './shared.ts'
99/**
1010 * Splits a text stream into individual lines using newline delimiters.
1111 * @example
12+ * ```ts
1213 * const readable = new ReadableStream({
1314 * start(controller) {
1415 * const encoder = new TextEncoder()
@@ -22,6 +23,7 @@ import type { TYPED_STREAM_KEY } from './shared.ts'
2223 * for await (const line of lines) {
2324 * console.log(line) // "one", then "two"
2425 * }
26+ * ```
2527 */
2628export class TextLineSplitterStream extends TransformStream < string , string > {
2729 constructor ( ) {
@@ -49,6 +51,7 @@ export class TextLineSplitterStream extends TransformStream<string, string> {
4951/**
5052 * Parses newline-delimited JSON chunks into strongly typed objects.
5153 * @example
54+ * ```ts
5255 * const readable = new ReadableStream({
5356 * start(controller) {
5457 * controller.enqueue(JSON.stringify({ ok: true }))
@@ -60,6 +63,7 @@ export class TextLineSplitterStream extends TransformStream<string, string> {
6063 * for await (const result of objects) {
6164 * console.log(result.ok) // true
6265 * }
66+ * ```
6367 */
6468export class JSONParserStream < T > extends TransformStream < string , T > {
6569 constructor ( ) {
@@ -81,11 +85,13 @@ export class JSONParserStream<T> extends TransformStream<string, T> {
8185 * @param res Response returned by the Hono client request.
8286 * @returns Readable stream of typed JSON objects.
8387 * @example
88+ * ```ts
8489 * const res = await client.api.events.$get()
8590 * const dataStream = receiveTypedStream(res)
8691 * for await (const payload of dataStream) {
8792 * console.log(payload.type)
8893 * }
94+ * ```
8995 */
9096export const receiveTypedStream = < T > (
9197 res : ClientResponse < T , StatusCode , TYPED_STREAM_KEY >
0 commit comments