0.2.0

.github/CODE_OF_CONDUCT.md

@@ -61,7 +61,7 @@ representative at an online or offline event.
 
 Instances of abusive, harassing, or otherwise unacceptable behavior may be
 reported to the community leaders responsible for enforcement at
-[INSERT CONTACT METHOD].
+willfarrell@proton.me.
 All complaints will be reviewed and investigated promptly and fairly.
 
 All community leaders are obligated to respect the privacy and security of the

.github/CONTRIBUTING.md

@@ -1,10 +1,10 @@
 # Contributing
 
-In the spirit of Open Source Software, everyone is very welcome to contribute to this repository. Feel free to [raise issues](https://github.com/willfarrell/csv-rex/issues) or to [submit Pull Requests](https://github.com/willfarrell/csv-rex/pulls).
+In the spirit of Open Source Software, everyone is very welcome to contribute to this repository. Feel free to [raise issues](https://github.com/willfarrell/datastream/issues) or to [submit Pull Requests](https://github.com/willfarrell/datastream/pulls).
 
 Before contributing to the project, make sure to have a look at our [Code of Conduct](/.github/CODE_OF_CONDUCT.md).
 
 
 ## Licence
 
-Licensed under [MIT Licence](LICENSE). Copyright (c) 2022 [will Farrell](https://github.com/willfarrell), and the [csv-rex team](https://github.com/willfarrell/csv-rex/graphs/contributors).
+Licensed under [MIT Licence](LICENSE). Copyright (c) 2026 [will Farrell](https://github.com/willfarrell), and the [datastream team](https://github.com/willfarrell/datastream/graphs/contributors).

.github/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@datastream/github-workflows",
-	"version": "0.1.6",
+	"version": "0.2.0",
 	"private": true,
 	"engines": {
 		"node": ">=24.0"

.github/workflows/release.yml

@@ -16,7 +16,7 @@ permissions:
 jobs:
   build:
     name: Build
-    if: ${{ github.event.pull_request.merged }}
+    if: ${{ github.event.pull_request.merged && github.event.pull_request.head.repo.full_name == github.repository }}
     runs-on: ubuntu-latest
 
     permissions:

.gitignore

@@ -1,7 +1,9 @@
 *.cjs
 *.cjs.map
+!*.config.cjs
 *.mjs
 *.mjs.map
+!*.config.mjs
 coverage
 
 # Logs
@@ -115,4 +117,4 @@ dist
 .nova
 
 # OS
-.DS_Store
+.DS_Store

bin/esbuild

@@ -10,13 +10,11 @@ for package in packages/*; do
       module="${module#./}"
     fi
     if [ -f ${package}/${module}.js ]; then
-      #node_modules/.bin/esbuild --platform=node    --target=node18 --format=cjs ${package}/${module}.js      --sourcemap=external --allow-overwrite --outfile=${package}/${module}.node.cjs
-      node_modules/.bin/esbuild --platform=node    --target=node18 --format=esm ${package}/${module}.js      --sourcemap=external --allow-overwrite --outfile=${package}/${module}.node.mjs
+      node_modules/.bin/esbuild --platform=node    --target=node24 --format=esm ${package}/${module}.js      --sourcemap=external --allow-overwrite --outfile=${package}/${module}.node.mjs
       node_modules/.bin/esbuild --platform=browser                 --format=esm ${package}/${module}.js      --sourcemap=external --allow-overwrite --outfile=${package}/${module}.web.mjs
     fi
     if [ -f ${package}/${module}.node.js ]; then
-      #node_modules/.bin/esbuild --platform=node    --target=node18 --format=cjs ${package}/${module}.node.js --sourcemap=external --allow-overwrite --outfile=${package}/${module}.node.cjs
-      node_modules/.bin/esbuild --platform=node    --target=node18 --format=esm ${package}/${module}.node.js --sourcemap=external --allow-overwrite --outfile=${package}/${module}.node.mjs
+      node_modules/.bin/esbuild --platform=node    --target=node24 --format=esm ${package}/${module}.node.js --sourcemap=external --allow-overwrite --outfile=${package}/${module}.node.mjs
     fi
     if [ -f ${package}/${module}.web.js ]; then
       node_modules/.bin/esbuild --platform=browser                 --format=esm ${package}/${module}.web.js  --sourcemap=external --allow-overwrite --outfile=${package}/${module}.web.mjs

biome.json

@@ -1,5 +1,5 @@
 {
-	"$schema": "https://biomejs.dev/schemas/2.4.8/schema.json",
+	"$schema": "https://biomejs.dev/schemas/2.4.12/schema.json",
 	"vcs": {
 		"enabled": true,
 		"clientKind": "git",
@@ -20,10 +20,10 @@
 				"noBannedTypes": "off"
 			},
 			"correctness": {
-				"noUnusedFunctionParameters": "off"
+				"noUnusedFunctionParameters": "warn"
 			},
 			"suspicious": {
-				"noExplicitAny": "off"
+				"noExplicitAny": "warn"
 			}
 		}
 	},

commitlint.config.cjs

@@ -0,0 +1,3 @@
+module.exports = {
+	extends: ["@commitlint/config-conventional"],
+};

docs/packages/core.md

@@ -23,6 +23,23 @@
   - `chunkSize`
   - `signal`
 
+## Null handling
+
+Node.js streams use `push(null)` to signal end-of-stream (EOF). To allow `null` values to flow through object-mode pipelines without terminating the stream, datastream wraps them with a sentinel Symbol (`Symbol.for("@datastream/null")`).
+
+This is handled automatically when using datastream's built-in functions (`createReadableStream`, `createTransformStream`, `createPassThroughStream`, `createWritableStream`, `streamToArray`). You only need to be aware of it when reading chunks directly from a stream, such as listening to `data` events or using `for await...of` on a mid-pipeline stream.
+
+```javascript
+// Handled automatically - null values round-trip correctly
+const output = await streamToArray(createReadableStream([1, null, 3]))
+// [1, null, 3]
+
+// Direct access - you may see the sentinel Symbol
+stream.on('data', (chunk) => {
+  // chunk may be Symbol.for("@datastream/null") instead of null
+})
+```
+
 ## Examples
 
 ```javascript