import { writeAll } from "./write_all.ts";import type { Closer, Writer } from "../types.d.ts";
function isCloser(value: unknown): value is 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: 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(); } }, });}