Do not crash on big streams

index.js

@@ -1,8 +1,6 @@
-import {Buffer, constants as BufferConstants} from 'node:buffer';
+import {Buffer} from 'node:buffer';
 import {compose, PassThrough as PassThroughStream} from 'node:stream';
 
-const maxHighWaterMark = 2_147_483_647;
-
 export class MaxBufferError extends Error {
 	name = 'MaxBufferError';
 
@@ -19,7 +17,7 @@ export default async function getStream(inputStream, options = {}) {
 	const {maxBuffer = Number.POSITIVE_INFINITY, encoding = 'utf8'} = options;
 	const isBuffer = encoding === 'buffer';
 
-	const stream = new PassThroughStream({highWaterMark: maxHighWaterMark, encoding: isBuffer ? undefined : encoding});
+	const stream = new PassThroughStream({encoding: isBuffer ? undefined : encoding});
 
 	const newStream = compose(inputStream, stream);
 
@@ -40,9 +38,11 @@ export default async function getStream(inputStream, options = {}) {
 
 		return getBufferedValue();
 	} catch (error) {
-		if (length <= BufferConstants.MAX_LENGTH) {
+		try {
 			error.bufferedData = getBufferedValue();
-		}
+			// This throws when the buffered data is larger than the maximum length
+			// for a string or buffer
+		} catch {}
 
 		throw error;
 	}

test.js

@@ -1,4 +1,4 @@
-import {Buffer} from 'node:buffer';
+import {Buffer, constants as BufferConstants} from 'node:buffer';
 import {setTimeout} from 'node:timers/promises';
 import {compose} from 'node:stream';
 import {text, buffer} from 'node:stream/consumers';
@@ -88,6 +88,22 @@ test('handles infinite stream', async t => {
 	await t.throwsAsync(setup(infiniteIteration(), {maxBuffer: 1}), {instanceOf: MaxBufferError});
 });
 
+test('handles streams larger than buffer max length', async t => {
+	const chunkSize = 2 ** 16;
+	const chunkCount = Math.floor(BufferConstants.MAX_LENGTH / chunkSize * 2);
+	const chunk = Buffer.alloc(chunkSize);
+	const chunks = Array.from({length: chunkCount}, () => chunk);
+	await t.throwsAsync(setupBuffer(chunks));
+});
+
+test('handles streams larger than string max length', async t => {
+	const chunkSize = 2 ** 16;
+	const chunkCount = Math.floor(BufferConstants.MAX_STRING_LENGTH / chunkSize * 2);
+	const chunk = '.'.repeat(chunkSize);
+	const chunks = Array.from({length: chunkCount}, () => chunk);
+	await t.throwsAsync(setup(chunks));
+});
+
 test('native string', async t => {
 	const result = await text(compose(fixtureString));
 	t.is(result, fixtureString);