Update tÃests

src/api-request-manager.ts

@@ -74,7 +74,6 @@ class APIRequestManager {
 		var requestConfig = this.config.extend({
 			request: options,
 		});
-		var passThrough = new PassThrough();
 
 		// Make the request
 		var apiRequest = new APIRequest(requestConfig, this.eventBus);
@@ -86,6 +85,7 @@ class APIRequestManager {
 		// If the stream is undefined, then the request failed and we should
 		// propagate the error.
 		if (stream) {
+			var passThrough = new PassThrough();
 			stream.pipe(passThrough);
 			return passThrough;
 		}

tests/integration_test/__tests__/file.test.js

@@ -120,7 +120,7 @@ test('test get file by stream with delay read', async() => {
 		let stream = await context.client.files.getReadStream(testFile.id);
 		// delay 3s to read the stream
 		// eslint-disable-next-line promise/avoid-new
-		await new Promise(resolve => setTimeout(resolve, 3000));
+		await new Promise(resolve => setTimeout(resolve, 500));
 		// eslint-disable-next-line promise/avoid-new
 		let buffer = await new Promise((resolve, reject) => {
 			let chunks = [];