import { writeAll } from "./write_all.ts";
function isCloser(value: unknown): value is Deno.Closer { return typeof value === "object" && value != null && "close" in value && typeof (value as Record<string, any>)["close"] === "function";}
export interface WritableStreamFromWriterOptions { autoClose?: boolean;}
export function writableStreamFromWriter( writer: Deno.Writer, options: WritableStreamFromWriterOptions = {},): WritableStream<Uint8Array> { const { autoClose = true } = options;
return new WritableStream({ async write(chunk, controller) { try { await writeAll(writer, chunk); } catch (e) { controller.error(e); if (isCloser(writer) && autoClose) { writer.close(); } } }, close() { if (isCloser(writer) && autoClose) { writer.close(); } }, abort() { if (isCloser(writer) && autoClose) { writer.close(); } }, });}