Class CsvStringifyStream<TOptions>

Convert each chunk to a CSV record.

Example: Write CSV to a file

import { CsvStringifyStream } from "@std/csv/stringify-stream";
import { assertEquals } from "@std/assert/equals";

async function writeCsvToTempFile(): Promise<string> {
  const path = await Deno.makeTempFile();
  using file = await Deno.open(path, { write: true });

  const readable = ReadableStream.from([
    { id: 1, name: "one" },
    { id: 2, name: "two" },
    { id: 3, name: "three" },
  ]);

  await readable
    .pipeThrough(new CsvStringifyStream({ columns: ["id", "name"] }))
    .pipeThrough(new TextEncoderStream())
    .pipeTo(file.writable);

  return path;
}

const path = await writeCsvToTempFile();
const content = await Deno.readTextFile(path);
assertEquals(content, "id,name\r\n1,one\r\n2,two\r\n3,three\r\n");

Example: Write TSV to a file

import { CsvStringifyStream } from "@std/csv/stringify-stream";
import { assertEquals } from "@std/assert/equals";

async function writeTsvToTempFile(): Promise<string> {
  const path = await Deno.makeTempFile();
  using file = await Deno.open(path, { write: true });

  const readable = ReadableStream.from([
    { id: 1, name: "one" },
    { id: 2, name: "two" },
    { id: 3, name: "three" },
  ]);

  await readable
    .pipeThrough(
      new CsvStringifyStream({
        columns: ["id", "name"],
        separator: "\t",
      }),
    )
    .pipeThrough(new TextEncoderStream())
    .pipeTo(file.writable);

  return path;
}

const path = await writeTsvToTempFile();
const content = await Deno.readTextFile(path);
assertEquals(content, "id\tname\r\n1\tone\r\n2\ttwo\r\n3\tthree\r\n");

Type Parameters

Hierarchy
  • TransformStream<TOptions["columns"] extends string[]
        ? Record<string, unknown>
        : unknown[], string>
    • CsvStringifyStream

Constructors

constructor

Properties

readable writable

Constructors

constructor

Properties

Readonlyreadable

readable: ReadableStream<string>

MDN Reference

Readonlywritable

writable: WritableStream<TOptions["columns"] extends string[]
    ? Record<string, unknown>
    : unknown[]>

MDN Reference

Settings

Member Visibility

On This Page

Constructors
Properties