Go to Latest
function readerFromIterable
import { readerFromIterable } from "https://dotland.deno.dev/std@0.116.0/streams/conversion.ts";

Create a Deno.Reader from an iterable of Uint8Arrays.

     import { readerFromIterable } from "./conversion.ts";
     import { serve } from "../http/server_legacy.ts";

     for await (const request of serve({ port: 8000 })) {
       // Server-sent events: Send runtime metrics to the client every second.
       request.respond({
         headers: new Headers({ "Content-Type": "text/event-stream" }),
         body: readerFromIterable((async function* () {
           while (true) {
             await new Promise((r) => setTimeout(r, 1000));
             const message = `data: ${JSON.stringify(Deno.metrics())}\n\n`;
             yield new TextEncoder().encode(message);
           }
         })()),
       });
     }

Parameters

iterable: Iterable<Uint8Array> | AsyncIterable<Uint8Array>

Returns

Deno.Reader