1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
// Copyright 2018-2024 the Deno authors. All rights reserved. MIT license.// This module is browser compatible.import { stringify } from "./stringify.ts";
/** Options for {@linkcode CsvStringifyStream}. */export interface CsvStringifyStreamOptions {  /**   * Delimiter used to separate values.   *   * @default {","}   */  readonly separator?: string;
  /**   * A list of columns to be included in the output.   *   * If you want to stream objects, this option is required.   */  readonly columns?: Array<string>;}
/** * Convert each chunk to a CSV record. * * @example * ```ts * import { CsvStringifyStream } from "https://deno.land/std@$STD_VERSION/csv/csv_stringify_stream.ts"; * * const file = await Deno.open("data.csv", { create: true, 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); * ```` */export class CsvStringifyStream<TOptions extends CsvStringifyStreamOptions>  extends TransformStream<    TOptions["columns"] extends Array<string> ? Record<string, unknown>      : Array<unknown>,    string  > {  /** Construct a new instance. */  constructor(options?: TOptions) {    const {      separator,      columns = [],    } = options ?? {};
    super(      {        start(controller) {          if (columns && columns.length > 0) {            try {              controller.enqueue(                stringify([columns], { separator, headers: false }),              );            } catch (error) {              controller.error(error);            }          }        },        transform(chunk, controller) {          try {            controller.enqueue(              stringify([chunk], { separator, headers: false, columns }),            );          } catch (error) {            controller.error(error);          }        },      },    );  }}