diff options
author | 2023-08-28 17:19:04 +0100 | |
---|---|---|
committer | 2023-08-28 17:19:04 +0100 | |
commit | c7921e9e1b2953e211e506cee4a50f0cc0bf6569 (patch) | |
tree | 1ab0c31bfcc5c98fa21e4bad79567fc03f17f630 /packages/integrations/node/src/response-iterator.ts | |
parent | 52f0837bdeca0b54e07cbf76a7570bd042b98922 (diff) | |
download | astro-c7921e9e1b2953e211e506cee4a50f0cc0bf6569.tar.gz astro-c7921e9e1b2953e211e506cee4a50f0cc0bf6569.tar.zst astro-c7921e9e1b2953e211e506cee4a50f0cc0bf6569.zip |
refactor: use new Astro internals (#8254)
* refactor: use new Astro internals
* chore: update tests
---------
Co-authored-by: Matthew Phillips <matthew@skypack.dev>
Diffstat (limited to 'packages/integrations/node/src/response-iterator.ts')
-rw-r--r-- | packages/integrations/node/src/response-iterator.ts | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/packages/integrations/node/src/response-iterator.ts b/packages/integrations/node/src/response-iterator.ts index 0dd6e63af..ef7a42c40 100644 --- a/packages/integrations/node/src/response-iterator.ts +++ b/packages/integrations/node/src/response-iterator.ts @@ -6,6 +6,7 @@ import type { ReadableStreamDefaultReadResult } from 'node:stream/web'; import { Readable as NodeReadableStream } from 'stream'; +import { AstroError } from 'astro/errors'; interface NodeStreamIterator<T> { next(): Promise<IteratorResult<T, boolean | undefined>>; @@ -221,5 +222,7 @@ export function responseIterator<T>(response: Response | Buffer): AsyncIterableI if (isNodeReadableStream(body)) return nodeStreamIterator<T>(body); - throw new Error('Unknown body type for responseIterator. Please pass a streamable response.'); + throw new AstroError( + 'Unknown body type for responseIterator. Please pass a streamable response.' + ); } |