transform-stream

import { Writable } from "node:stream";
import type { Pool } from "pg";

interface Row {
  email: string;
  name: string;

'use strict';

const { Transform } = require('stream');

class LineSplitter extends Transform {
  constructor(options = {}) {