aboutsummaryrefslogtreecommitdiff
path: root/packages/integrations/node/src/response-iterator.ts
diff options
context:
space:
mode:
Diffstat (limited to 'packages/integrations/node/src/response-iterator.ts')
-rw-r--r--packages/integrations/node/src/response-iterator.ts7
1 files changed, 3 insertions, 4 deletions
diff --git a/packages/integrations/node/src/response-iterator.ts b/packages/integrations/node/src/response-iterator.ts
index 01624d81d..84080e5d1 100644
--- a/packages/integrations/node/src/response-iterator.ts
+++ b/packages/integrations/node/src/response-iterator.ts
@@ -6,7 +6,6 @@
import type { ReadableStreamDefaultReadResult } from 'node:stream/web';
import { Readable as NodeReadableStream } from 'stream';
-import type { Response as NodeResponse } from 'undici';
interface NodeStreamIterator<T> {
next(): Promise<IteratorResult<T, boolean | undefined>>;
@@ -35,8 +34,8 @@ function isBuffer(value: any): value is Buffer {
);
}
-function isNodeResponse(value: any): value is NodeResponse {
- return !!(value as NodeResponse).body;
+function isNodeResponse(value: any): value is Response {
+ return !!(value as Response).body;
}
function isReadableStream(value: any): value is ReadableStream<any> {
@@ -202,7 +201,7 @@ function asyncIterator<T>(source: AsyncIterableIterator<T>): AsyncIterableIterat
}
export function responseIterator<T>(
- response: Response | NodeResponse | Buffer
+ response: Response | Buffer
): AsyncIterableIterator<T> {
let body: unknown = response;