diff --git a/package-lock.json b/package-lock.json index 787609d..352c49b 100644 --- a/package-lock.json +++ b/package-lock.json @@ -1,12 +1,12 @@ { "name": "@datastream/monorepo", - "version": "0.2.0", + "version": "0.3.0", "lockfileVersion": 3, "requires": true, "packages": { "": { "name": "@datastream/monorepo", - "version": "0.2.0", + "version": "0.3.0", "license": "MIT", "workspaces": [ "packages/*", @@ -10005,10 +10005,10 @@ }, "packages/aws": { "name": "@datastream/aws", - "version": "0.2.0", + "version": "0.3.0", "license": "MIT", "dependencies": { - "@datastream/core": "0.2.0" + "@datastream/core": "0.3.0" }, "devDependencies": { "@aws-sdk/client-cloudwatch-logs": "^3.0.0", @@ -10068,10 +10068,10 @@ }, "packages/base64": { "name": "@datastream/base64", - "version": "0.2.0", + "version": "0.3.0", "license": "MIT", "dependencies": { - "@datastream/core": "0.2.0" + "@datastream/core": "0.3.0" }, "engines": { "node": ">=24" @@ -10079,10 +10079,10 @@ }, "packages/charset": { "name": "@datastream/charset", - "version": "0.2.0", + "version": "0.3.0", "license": "MIT", "dependencies": { - "@datastream/core": "0.2.0", + "@datastream/core": "0.3.0", "charset-detector": "0.0.2", "iconv-lite": "0.7.2" }, @@ -10092,10 +10092,10 @@ }, "packages/compress": { "name": "@datastream/compress", - "version": "0.2.0", + "version": "0.3.0", "license": "MIT", "dependencies": { - "@datastream/core": "0.2.0" + "@datastream/core": "0.3.0" }, "engines": { "node": ">=24" @@ -10119,10 +10119,10 @@ }, "packages/core": { "name": "@datastream/core", - "version": "0.2.0", + "version": "0.3.0", "license": "MIT", "devDependencies": { - "@datastream/object": "0.2.0" + "@datastream/object": "0.3.0" }, "engines": { "node": ">=24" @@ -10130,11 +10130,11 @@ }, "packages/csv": { "name": "@datastream/csv", - "version": "0.2.0", + "version": "0.3.0", "license": "MIT", "dependencies": { - "@datastream/core": "0.2.0", - "@datastream/object": "0.2.0" + "@datastream/core": "0.3.0", + "@datastream/object": "0.3.0" }, "engines": { "node": ">=24" @@ -10142,10 +10142,10 @@ }, "packages/digest": { "name": "@datastream/digest", - "version": "0.2.0", + "version": "0.3.0", "license": "MIT", "dependencies": { - "@datastream/core": "0.2.0", + "@datastream/core": "0.3.0", "hash-wasm": "4.12.0" }, "engines": { @@ -10154,10 +10154,10 @@ }, "packages/encrypt": { "name": "@datastream/encrypt", - "version": "0.2.0", + "version": "0.3.0", "license": "MIT", "dependencies": { - "@datastream/core": "0.2.0" + "@datastream/core": "0.3.0" }, "engines": { "node": ">=24" @@ -10173,10 +10173,10 @@ }, "packages/fetch": { "name": "@datastream/fetch", - "version": "0.2.0", + "version": "0.3.0", "license": "MIT", "dependencies": { - "@datastream/core": "0.2.0" + "@datastream/core": "0.3.0" }, "engines": { "node": ">=24" @@ -10184,10 +10184,10 @@ }, "packages/file": { "name": "@datastream/file", - "version": "0.2.0", + "version": "0.3.0", "license": "MIT", "dependencies": { - "@datastream/core": "0.2.0" + "@datastream/core": "0.3.0" }, "engines": { "node": ">=24" @@ -10195,10 +10195,10 @@ }, "packages/indexeddb": { "name": "@datastream/indexeddb", - "version": "0.2.0", + "version": "0.3.0", "license": "MIT", "dependencies": { - "@datastream/core": "0.2.0", + "@datastream/core": "0.3.0", "idb": "8.0.3" }, "engines": { @@ -10207,10 +10207,10 @@ }, "packages/ipfs": { "name": "@datastream/ipfs", - "version": "0.2.0", + "version": "0.3.0", "license": "MIT", "dependencies": { - "@datastream/core": "0.2.0" + "@datastream/core": "0.3.0" }, "engines": { "node": ">=24" @@ -10218,10 +10218,10 @@ }, "packages/json": { "name": "@datastream/json", - "version": "0.1.6", + "version": "0.3.0", "license": "MIT", "dependencies": { - "@datastream/core": "0.2.0" + "@datastream/core": "0.3.0" }, "engines": { "node": ">=24" @@ -10229,10 +10229,10 @@ }, "packages/object": { "name": "@datastream/object", - "version": "0.2.0", + "version": "0.3.0", "license": "MIT", "dependencies": { - "@datastream/core": "0.2.0" + "@datastream/core": "0.3.0" }, "engines": { "node": ">=24" @@ -10240,10 +10240,10 @@ }, "packages/string": { "name": "@datastream/string", - "version": "0.2.0", + "version": "0.3.0", "license": "MIT", "dependencies": { - "@datastream/core": "0.2.0" + "@datastream/core": "0.3.0" }, "engines": { "node": ">=24" @@ -10251,10 +10251,10 @@ }, "packages/validate": { "name": "@datastream/validate", - "version": "0.2.0", + "version": "0.3.0", "license": "MIT", "dependencies": { - "@datastream/core": "0.2.0", + "@datastream/core": "0.3.0", "ajv-cmd": "0.11.0" }, "engines": { @@ -10262,7 +10262,7 @@ } }, "websites/datastream.js.org": { - "version": "0.2.0", + "version": "0.3.0", "dependencies": { "@plausible-analytics/tracker": "0.4.4", "@willfarrell-ds/svelte": "0.0.0-alpha.6", diff --git a/package.json b/package.json index 3f49425..3e5bd3e 100644 --- a/package.json +++ b/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", diff --git a/packages/aws/package.json b/packages/aws/package.json index ceffe8b..e7b912e 100644 --- a/packages/aws/package.json +++ b/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", diff --git a/packages/base64/package.json b/packages/base64/package.json index b767fe0..5809708 100644 --- a/packages/base64/package.json +++ b/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" } } diff --git a/packages/charset/package.json b/packages/charset/package.json index d8449e5..dd13be7 100644 --- a/packages/charset/package.json +++ b/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" } diff --git a/packages/compress/deflate.web.js b/packages/compress/deflate.web.js index d770280..1eda13f 100644 --- a/packages/compress/deflate.web.js +++ b/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 @@ export const deflateDecompressStream = (options = {}, _streamOptions = {}) => { 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 @@ export const deflateDecompressStream = (options = {}, _streamOptions = {}) => { } controller.enqueue(chunk); }, - }); + }; + const limiter = new TransformStream(transformer); return { readable: decompressor.readable.pipeThrough(limiter), writable: decompressor.writable, diff --git a/packages/compress/gzip.web.js b/packages/compress/gzip.web.js index 736d3b4..e6a465b 100644 --- a/packages/compress/gzip.web.js +++ b/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 @@ export const gzipDecompressStream = (options = {}, _streamOptions = {}) => { 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 @@ export const gzipDecompressStream = (options = {}, _streamOptions = {}) => { } controller.enqueue(chunk); }, - }); + }; + const limiter = new TransformStream(transformer); return { readable: decompressor.readable.pipeThrough(limiter), writable: decompressor.writable, diff --git a/packages/compress/package.json b/packages/compress/package.json index 50e2693..ddd7ace 100644 --- a/packages/compress/package.json +++ b/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", diff --git a/packages/core/package.json b/packages/core/package.json index f9761c8..1c727fc 100644 --- a/packages/core/package.json +++ b/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" } } diff --git a/packages/csv/package.json b/packages/csv/package.json index b90e749..1cb73e7 100644 --- a/packages/csv/package.json +++ b/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" } } diff --git a/packages/digest/package.json b/packages/digest/package.json index f64b3d4..619a1f6 100644 --- a/packages/digest/package.json +++ b/packages/digest/package.json @@ -1,6 +1,6 @@ { "name": "@datastream/digest", - "version": "0.2.0", + "version": "0.3.0", "description": "Cryptographic hash digest pass-through streams", "type": "module", "engines": { @@ -60,7 +60,7 @@ }, "homepage": "https://datastream.js.org", "dependencies": { - "@datastream/core": "0.2.0", + "@datastream/core": "0.3.0", "hash-wasm": "4.12.0" } } diff --git a/packages/encrypt/package.json b/packages/encrypt/package.json index 639a93d..d602a36 100644 --- a/packages/encrypt/package.json +++ b/packages/encrypt/package.json @@ -1,6 +1,6 @@ { "name": "@datastream/encrypt", - "version": "0.2.0", + "version": "0.3.0", "description": "Symmetric encryption/decryption streams", "type": "module", "engines": { @@ -60,7 +60,7 @@ }, "homepage": "https://datastream.js.org", "dependencies": { - "@datastream/core": "0.2.0" + "@datastream/core": "0.3.0" }, "peerDependencies": { "libsodium-wrappers": ">=0.7.0" diff --git a/packages/fetch/package.json b/packages/fetch/package.json index 246453f..dbe517c 100644 --- a/packages/fetch/package.json +++ b/packages/fetch/package.json @@ -1,6 +1,6 @@ { "name": "@datastream/fetch", - "version": "0.2.0", + "version": "0.3.0", "description": "HTTP fetch-based readable and writable streams with pagination and rate limiting", "type": "module", "engines": { @@ -60,6 +60,6 @@ }, "homepage": "https://datastream.js.org", "dependencies": { - "@datastream/core": "0.2.0" + "@datastream/core": "0.3.0" } } diff --git a/packages/file/package.json b/packages/file/package.json index c1d9cf0..06a04fc 100644 --- a/packages/file/package.json +++ b/packages/file/package.json @@ -1,6 +1,6 @@ { "name": "@datastream/file", - "version": "0.2.0", + "version": "0.3.0", "description": "File system readable and writable streams with extension type enforcement", "type": "module", "engines": { @@ -60,6 +60,6 @@ }, "homepage": "https://datastream.js.org", "dependencies": { - "@datastream/core": "0.2.0" + "@datastream/core": "0.3.0" } } diff --git a/packages/indexeddb/package.json b/packages/indexeddb/package.json index 6f73ab6..d32480c 100644 --- a/packages/indexeddb/package.json +++ b/packages/indexeddb/package.json @@ -1,6 +1,6 @@ { "name": "@datastream/indexeddb", - "version": "0.2.0", + "version": "0.3.0", "description": "IndexedDB readable and writable streams for browser storage", "type": "module", "engines": { @@ -60,7 +60,7 @@ }, "homepage": "https://datastream.js.org", "dependencies": { - "@datastream/core": "0.2.0", + "@datastream/core": "0.3.0", "idb": "8.0.3" } } diff --git a/packages/ipfs/package.json b/packages/ipfs/package.json index 197a4f0..a74b05c 100644 --- a/packages/ipfs/package.json +++ b/packages/ipfs/package.json @@ -1,6 +1,6 @@ { "name": "@datastream/ipfs", - "version": "0.2.0", + "version": "0.3.0", "description": "IPFS get and add streaming operations", "type": "module", "engines": { @@ -61,6 +61,6 @@ }, "homepage": "https://datastream.js.org", "dependencies": { - "@datastream/core": "0.2.0" + "@datastream/core": "0.3.0" } } diff --git a/packages/json/package.json b/packages/json/package.json index bc11be6..ee0b73a 100644 --- a/packages/json/package.json +++ b/packages/json/package.json @@ -1,6 +1,6 @@ { "name": "@datastream/json", - "version": "0.1.6", + "version": "0.3.0", "description": "JSON and NDJSON (JSON Lines) parsing and formatting transform streams", "type": "module", "engines": { @@ -62,6 +62,6 @@ }, "homepage": "https://datastream.js.org", "dependencies": { - "@datastream/core": "0.2.0" + "@datastream/core": "0.3.0" } } diff --git a/packages/object/package.json b/packages/object/package.json index 62105de..81aea1b 100644 --- a/packages/object/package.json +++ b/packages/object/package.json @@ -1,6 +1,6 @@ { "name": "@datastream/object", - "version": "0.2.0", + "version": "0.3.0", "description": "Object transform streams for picking, omitting, pivoting, batching, and key mapping", "type": "module", "engines": { @@ -60,6 +60,6 @@ }, "homepage": "https://datastream.js.org", "dependencies": { - "@datastream/core": "0.2.0" + "@datastream/core": "0.3.0" } } diff --git a/packages/string/package.json b/packages/string/package.json index 2a7c0d3..0507619 100644 --- a/packages/string/package.json +++ b/packages/string/package.json @@ -1,6 +1,6 @@ { "name": "@datastream/string", - "version": "0.2.0", + "version": "0.3.0", "description": "String transform streams for splitting, replacing, counting, and deduplication", "type": "module", "engines": { @@ -60,6 +60,6 @@ }, "homepage": "https://datastream.js.org", "dependencies": { - "@datastream/core": "0.2.0" + "@datastream/core": "0.3.0" } } diff --git a/packages/validate/package.json b/packages/validate/package.json index e17f138..ab1a5a3 100644 --- a/packages/validate/package.json +++ b/packages/validate/package.json @@ -1,6 +1,6 @@ { "name": "@datastream/validate", - "version": "0.2.0", + "version": "0.3.0", "description": "JSON Schema validation transform streams using Ajv", "type": "module", "engines": { @@ -60,7 +60,7 @@ }, "homepage": "https://datastream.js.org", "dependencies": { - "@datastream/core": "0.2.0", + "@datastream/core": "0.3.0", "ajv-cmd": "0.11.0" } } diff --git a/websites/datastream.js.org/package.json b/websites/datastream.js.org/package.json index 2c1722a..7d864dd 100644 --- a/websites/datastream.js.org/package.json +++ b/websites/datastream.js.org/package.json @@ -2,7 +2,7 @@ "name": "datastream.js.org", "description": "SvelteKit SSR", "private": true, - "version": "0.2.0", + "version": "0.3.0", "type": "module", "scripts": { "start": "vite dev",