Skip to content

Instantly share code, notes, and snippets.

@softwareperson
softwareperson / MergeStream.ts
Last active November 3, 2022 06:14
Merge Stream
import { Duplex, DuplexOptions, Readable, TransformCallback, Writable } from 'stream';
import { BufferList } from './internal/streams/BufferList';
declare type StreamCallback = (error?: Error | null) => void;
interface MergingState {
callback: StreamCallback;
highWaterMark: number;
size: number;