diff options
Diffstat (limited to 'packages/integrations/node/src/response-iterator.ts')
| -rw-r--r-- | packages/integrations/node/src/response-iterator.ts | 11 |
1 files changed, 4 insertions, 7 deletions
diff --git a/packages/integrations/node/src/response-iterator.ts b/packages/integrations/node/src/response-iterator.ts index 01624d81d..0dd6e63af 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> { @@ -121,7 +120,7 @@ function nodeStreamIterator<T>(stream: NodeReadableStream): AsyncIterableIterato | IteratorResult<T, boolean | undefined> | PromiseLike<IteratorResult<T, boolean | undefined>> ) => void, - (reason?: any) => void + (reason?: any) => void, ][] = []; function onData(chunk: any) { @@ -201,9 +200,7 @@ function asyncIterator<T>(source: AsyncIterableIterator<T>): AsyncIterableIterat }; } -export function responseIterator<T>( - response: Response | NodeResponse | Buffer -): AsyncIterableIterator<T> { +export function responseIterator<T>(response: Response | Buffer): AsyncIterableIterator<T> { let body: unknown = response; if (isNodeResponse(response)) body = response.body; |