Interface StreamHelper<T>

interface StreamHelper<T extends keyof OutputTypes> {
    accumulate(
        updateCallback?: (metadata: ProgressMetadata) => void,
    ): Promise<OutputTypes[T]>;
    on(
        event: "data",
        callback: (data: OutputTypes[T], metadata: ProgressMetadata) => void,
    ): void;
    on(event: "end", callback: () => void): void;
    on(event: "error", callback: (error: Error) => void): void;
    pause(): void;
    resume(): void;
}