Tests: use native pipeline in favor of .pipe

Change-type: patch

Author: Page-

test/docker-event-stream.ts

@@ -14,37 +14,29 @@ describe('parseEventStream', function () {
 	it('should return updated mtimes', async () => {
 		const docker = getDocker({});
 		const streamParser = await parseEventStream(docker);
-		const data = await new Promise<LayerMtimes>(function (resolve, reject) {
-			let mtimes: LayerMtimes;
 
-			return fs
-				.createReadStream(__dirname + '/fixtures/docker-events.json')
-				.pipe(streamParser)
-				.on('error', reject)
-				.pipe(
-					new Stream.Transform({
-						objectMode: true,
-						transform($data: LayerMtimes, _encoding, cb) {
-							mtimes = $data;
-							cb();
-						},
-					}),
-				)
-				.on('end', () => {
-					resolve(mtimes);
-				})
-				.on('error', reject)
-				.resume();
-		});
-		expect(data)
+		let mtimes: LayerMtimes;
+		await Stream.promises.pipeline(
+			fs.createReadStream(__dirname + '/fixtures/docker-events.json'),
+			streamParser,
+			new Stream.Transform({
+				objectMode: true,
+				transform($data: LayerMtimes, _encoding, cb) {
+					mtimes = $data;
+					cb();
+				},
+			}).resume(),
+		);
+
+		expect(mtimes!)
 			.to.have.property('busybox:latest')
 			.that.equals(1448576072937294800);
-		expect(data)
+		expect(mtimes!)
 			.to.have.property(
 				'sha256:6d41a4a0bf8168363e29da8a5ecbf3cd6c37e3f5a043decd5e7da6e427ba869c',
 			)
 			.that.equals(1448576073085559800);
-		expect(data)
+		expect(mtimes!)
 			.to.have.property(
 				'sha256:9a61b6b1315e6b457c31a03346ab94486a2f5397f4a82219bee01eead1c34c2e',
 			)

test/docker-image-tree.ts

@@ -11,27 +11,18 @@ import { getDocker } from '../build/docker';
 const getLayerMtimes = async () => {
 	const docker = getDocker({});
 	const streamParser = await parseEventStream(docker);
-	return await new Promise<LayerMtimes>(function (resolve, reject) {
-		let mtimes: LayerMtimes;
-		return fs
-			.createReadStream(__dirname + '/fixtures/docker-events.json')
-			.pipe(streamParser)
-			.on('error', reject)
-			.pipe(
-				new Stream.Transform({
-					objectMode: true,
-					transform($data: LayerMtimes, _encoding, cb) {
-						mtimes = $data;
-						cb();
-					},
-				}),
-			)
-			.on('end', () => {
-				resolve(mtimes);
-			})
-			.on('error', reject)
-			.resume();
-	});
+	let mtimes: LayerMtimes;
+	await Stream.promises.pipeline(
+		fs.createReadStream(__dirname + '/fixtures/docker-events.json'),
+		new Stream.Transform({
+			objectMode: true,
+			transform($data: LayerMtimes, _encoding, cb) {
+				mtimes = $data;
+				cb();
+			},
+		}).resume(),
+	);
+	return mtimes!;
 };
 
 describe('createTree', function () {