diff --git a/src/renderer/components/+extensions/__tests__/extensions.test.tsx b/src/renderer/components/+extensions/__tests__/extensions.test.tsx index 40a523d8a3..e092949ab7 100644 --- a/src/renderer/components/+extensions/__tests__/extensions.test.tsx +++ b/src/renderer/components/+extensions/__tests__/extensions.test.tsx @@ -36,7 +36,7 @@ jest.mock("fs-extra"); jest.mock("../../notifications"); jest.mock("../../../../common/utils", () => ({ - ...jest.requireActual("../../../../common/utils"), + ...jest.requireActual("../../../../common/utils"), downloadFile: jest.fn(() => ({ promise: Promise.resolve() })), diff --git a/src/renderer/utils/readableStream.ts b/src/renderer/utils/readableStream.ts index 82cd5dad0e..9cd91f6ccb 100644 --- a/src/renderer/utils/readableStream.ts +++ b/src/renderer/utils/readableStream.ts @@ -21,6 +21,18 @@ import { Readable } from "readable-stream"; +type TypeArray = Int8Array + | Uint8Array + | Uint8ClampedArray + | Int16Array + | Uint16Array + | Int32Array + | Uint32Array + | Float32Array + | Float64Array + | BigInt64Array + | BigUint64Array; + /** * ReadableWebToNodeStream * @@ -29,7 +41,7 @@ import { Readable } from "readable-stream"; * Adds read error handler * * */ -export class ReadableWebToNodeStream extends Readable { +export class ReadableWebToNodeStream extends Readable { public bytesRead = 0; public released = false; @@ -38,14 +50,14 @@ export class ReadableWebToNodeStream extends Readable { * Default web API stream reader * https://developer.mozilla.org/en-US/docs/Web/API/ReadableStreamDefaultReader */ - private reader: ReadableStreamReader; - private pendingRead: Promise; + private reader: ReadableStreamReader; + private pendingRead: Promise>; /** * * @param stream Readable​Stream: https://developer.mozilla.org/en-US/docs/Web/API/ReadableStream */ - constructor(stream: ReadableStream) { + constructor(stream: ReadableStream) { super(); this.reader = stream.getReader(); } @@ -78,7 +90,7 @@ export class ReadableWebToNodeStream extends Readable { this.bytesRead += data.value.length; this.push(data.value); // Push new data to the queue } - } catch(error) { + } catch (error) { this.push(null); // Signal EOF } }