slikts · December 22, 2019 15:42
diff --git a/mapStream.ts b/mapStream.ts
 export const mapStream = <A, B>(f: (a: A) => B, source: Readable) =>
  source.pipe(
    new Transform({
      objectMode: true,
      transform: (chunk, _, callback) => {
        callback(null, f(chunk));
      }
    })
  );
	export const mapStream = <A, B>(f: (a: A) => B, source: Readable) =>
	source.pipe(
	new Transform({
	objectMode: true,
	transform: (chunk, _, callback) => {
	callback(null, f(chunk));
	}
	})
	);