Function transformContentsStreaming

src/transformContentsStreaming.ts:8–43

(
    context: Context,
    input: Readable,
    output: Writable
)

import { iterWithNewlines } from './iterWithNewlines';

export function transformContentsStreaming(
    context: Context,
    input: Readable,
    output: Writable
): Promise<void> {
    return new Promise((resolve, reject) => {
        const transformedInput = Readable.from(
            iterWithNewlines(
                context,
                iterSideBySideDiffs(
                    context,
                    iterReplaceTabsWithSpaces(
                        context,
                        iterlinesFromReadable(input)
                    )
                )
            )
        );

        stream.pipeline(transformedInput, output, (err) => {
            if (err) {
                switch (err.code) {
                    case 'EPIPE':
                        // This can happen if the process exits while we are still
                        // processing the input and writing to stdout.
                        resolve();
                        return;
                    default:
                        reject(err);
                        return;
                }
            }
            resolve();
        });
    });
}