0.3.0

package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@datastream/monorepo",
-	"version": "0.2.0",
+	"version": "0.3.0",
 	"description": "Streams made easy.",
 	"private": true,
 	"type": "module",

packages/aws/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@datastream/aws",
-	"version": "0.2.0",
+	"version": "0.3.0",
 	"description": "AWS service streaming integrations for CloudWatch Logs, DynamoDB, Kinesis, Lambda, S3, SNS, and SQS",
 	"type": "module",
 	"engines": {
@@ -148,7 +148,7 @@
 	},
 	"homepage": "https://datastream.js.org",
 	"dependencies": {
-		"@datastream/core": "0.2.0"
+		"@datastream/core": "0.3.0"
 	},
 	"peerDependencies": {
 		"@aws-sdk/client-cloudwatch-logs": "^3.0.0",

packages/base64/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@datastream/base64",
-	"version": "0.2.0",
+	"version": "0.3.0",
 	"description": "Base64 encoding and decoding transform streams",
 	"type": "module",
 	"engines": {
@@ -60,6 +60,6 @@
 	},
 	"homepage": "https://datastream.js.org",
 	"dependencies": {
-		"@datastream/core": "0.2.0"
+		"@datastream/core": "0.3.0"
 	}
 }

packages/charset/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@datastream/charset",
-	"version": "0.2.0",
+	"version": "0.3.0",
 	"description": "Character encoding detection, decoding, and conversion streams",
 	"type": "module",
 	"engines": {
@@ -108,7 +108,7 @@
 	},
 	"homepage": "https://datastream.js.org",
 	"dependencies": {
-		"@datastream/core": "0.2.0",
+		"@datastream/core": "0.3.0",
 		"charset-detector": "0.0.2",
 		"iconv-lite": "0.7.2"
 	}

packages/compress/deflate.web.js

@@ -1,6 +1,6 @@
 // Copyright 2026 will Farrell, and datastream contributors.
 // SPDX-License-Identifier: MIT
-/* global CompressionStream, DecompressionStream */
+/* global CompressionStream, DecompressionStream, TransformStream */
 // CompressionStream
 // - https://caniuse.com/?search=CompressionStream
 // - not supported on firefox - https://bugzilla.mozilla.org/show_bug.cgi?id=1586639
@@ -14,7 +14,7 @@
 	const decompressor = new DecompressionStream("deflate");
 	if (maxOutputSize != null) {
 		let outputSize = 0;
-		const limiter = new TransformStream({
+		const transformer = {
 			transform(chunk, controller) {
 				outputSize += chunk.byteLength;
 				if (outputSize > maxOutputSize) {
@@ -27,7 +27,8 @@
 				}
 				controller.enqueue(chunk);
 			},
-		});
+		};
+		const limiter = new TransformStream(transformer);
 		return {
 			readable: decompressor.readable.pipeThrough(limiter),
 			writable: decompressor.writable,

packages/compress/gzip.web.js

@@ -1,6 +1,6 @@
 // Copyright 2026 will Farrell, and datastream contributors.
 // SPDX-License-Identifier: MIT
-/* global CompressionStream, DecompressionStream */
+/* global CompressionStream, DecompressionStream, TransformStream */
 // CompressionStream
 // - https://caniuse.com/?search=CompressionStream
 // - not supported on firefox - https://bugzilla.mozilla.org/show_bug.cgi?id=1586639
@@ -14,7 +14,7 @@
 	const decompressor = new DecompressionStream("gzip");
 	if (maxOutputSize != null) {
 		let outputSize = 0;
-		const limiter = new TransformStream({
+		const transformer = {
 			transform(chunk, controller) {
 				outputSize += chunk.byteLength;
 				if (outputSize > maxOutputSize) {
@@ -27,7 +27,8 @@
 				}
 				controller.enqueue(chunk);
 			},
-		});
+		};
+		const limiter = new TransformStream(transformer);
 		return {
 			readable: decompressor.readable.pipeThrough(limiter),
 			writable: decompressor.writable,

packages/compress/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@datastream/compress",
-	"version": "0.2.0",
+	"version": "0.3.0",
 	"description": "Compression and decompression streams for gzip, deflate, brotli, and zstd",
 	"type": "module",
 	"engines": {
@@ -140,7 +140,7 @@
 	},
 	"homepage": "https://datastream.js.org",
 	"dependencies": {
-		"@datastream/core": "0.2.0"
+		"@datastream/core": "0.3.0"
 	},
 	"peerDependencies": {
 		"brotli-wasm": "^3.0.0",

packages/core/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@datastream/core",
-	"version": "0.2.0",
+	"version": "0.3.0",
 	"description": "Stream creation utilities and pipeline functions for Web Streams API and Node.js streams",
 	"type": "module",
 	"engines": {
@@ -61,6 +61,6 @@
 	"homepage": "https://datastream.js.org",
 	"dependencies": {},
 	"devDependencies": {
-		"@datastream/object": "0.2.0"
+		"@datastream/object": "0.3.0"
 	}
 }

packages/csv/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@datastream/csv",
-	"version": "0.2.0",
+	"version": "0.3.0",
 	"description": "CSV parsing and formatting transform streams",
 	"type": "module",
 	"engines": {
@@ -63,7 +63,7 @@
 	},
 	"homepage": "https://datastream.js.org",
 	"dependencies": {
-		"@datastream/core": "0.2.0",
-		"@datastream/object": "0.2.0"
+		"@datastream/core": "0.3.0",
+		"@datastream/object": "0.3.0"
 	}
 }