Added TS checks.

Author: uhop

ts-check/defs.ts

@@ -1,19 +1,21 @@
 import {
+  none,
   isFinalValue,
   finalValue,
   getFinalValue,
-
   isMany,
   many,
   getManyValues,
-
   isFlushable,
   flushable,
-
   isFunctionList,
   getFunctionList,
   setFunctionList,
-  clearFunctionList
+  clearFunctionList,
+  toMany,
+  normalizeMany,
+  combineMany,
+  combineManyMut
 } from 'stream-chain/defs.js';
 
 {
@@ -94,3 +96,77 @@ import {
 
   void w;
 }
+
+{
+  const x1 = toMany(none),
+    t1 = getManyValues(x1);
+  console.assert(t1.length === 0);
+
+  const x2 = toMany(1),
+    t2 = getManyValues(x2);
+  console.assert(t2.length === 1);
+
+  const x3 = toMany(many([1, 2, 3])),
+    t3 = getManyValues(x3);
+  console.assert(t3.length === 3);
+}
+
+{
+  const x1 = normalizeMany(many([]));
+  console.assert(x1 === none);
+
+  const x2 = normalizeMany(many([1]));
+  console.assert(x2 === 1);
+
+  const x3 = normalizeMany(many([1, 2, 3]));
+  if (isMany(x3)) {
+    console.assert(getManyValues(x3).length === 3);
+  }
+  console.assert(isMany(x3));
+}
+
+{
+  const x1 = combineMany(none, none);
+  console.assert(getManyValues(x1).length === 0);
+
+  const x2 = combineMany(none, many([1, 2, 3]));
+  console.assert(getManyValues(x2).length === 3);
+
+  const x3 = combineMany(many([1, 2, 3]), none);
+  console.assert(getManyValues(x3).length === 3);
+
+  const x4 = combineMany(many([1, 2, 3]), many([4, 5, 6]));
+  console.assert(getManyValues(x4).length === 6);
+
+  const x5 = combineMany(0, many([1, 2, 3]));
+  console.assert(getManyValues(x5).length === 4);
+
+  const x6 = combineMany(many([1, 2, 3]), 4);
+  console.assert(getManyValues(x6).length === 4);
+
+  const x7 = combineMany(1, 2);
+  console.assert(getManyValues(x7).length === 2);
+}
+
+{
+  const x1 = combineManyMut(none, none);
+  console.assert(getManyValues(x1).length === 0);
+
+  const x2 = combineManyMut(none, many([1, 2, 3]));
+  console.assert(getManyValues(x2).length === 3);
+
+  const x3 = combineManyMut(many([1, 2, 3]), none);
+  console.assert(getManyValues(x3).length === 3);
+
+  const x4 = combineManyMut(many([1, 2, 3]), many([4, 5, 6]));
+  console.assert(getManyValues(x4).length === 6);
+
+  const x5 = combineManyMut(0, many([1, 2, 3]));
+  console.assert(getManyValues(x5).length === 4);
+
+  const x6 = combineManyMut(many([1, 2, 3]), 4);
+  console.assert(getManyValues(x6).length === 4);
+
+  const x7 = combineManyMut(1, 2);
+  console.assert(getManyValues(x7).length === 2);
+}

ts-check/demo.ts

@@ -1,4 +1,4 @@
-import chain, {asStream, many, none} from 'stream-chain';
+import chain, {chainUnchecked, asStream, many, none} from 'stream-chain';
 import {TypedTransform} from 'stream-chain/typed-streams.js';
 import readableFrom from 'stream-chain/utils/readableFrom.js';
 
@@ -50,3 +50,45 @@ const c = chain([
 c.on('data', (data: boolean) => output.push(data));
 
 readableFrom([1, 2, 3]).pipe(c);
+
+// unchecked
+
+const c2 = chainUnchecked<number, boolean>([
+    // transforms a value
+    (x: number) => x * x,
+    // returns several values
+    (x: number) => many([x - 1, x, x + 1]),
+    // waits for an asynchronous operation
+    async (x: number) => await getTotalFromDatabaseByKey(x),
+    // or: (x: number) => getTotalFromDatabaseByKey(x),
+    // returns multiple values with a generator
+    function* (x: number) {
+      for (let i = x; i >= 0; --i) {
+        yield i;
+      }
+    },
+    // filters out even values
+    (x: number) => (x % 2 ? x : none),
+    // uses an arbitrary transform stream
+    new Transform({
+      objectMode: true,
+      transform(x, _, callback) {
+        callback(null, x + 1);
+      }
+    }),
+    // can skip falsy values
+    [null, undefined],
+    // uses a typed transform stream
+    new TypedTransform<number, string>({
+      objectMode: true,
+      transform(x, _, callback) {
+        callback(null, String(x + 1));
+      }
+    }),
+    // uses a wrapped function
+    asStream((x: string) => !x)
+  ]),
+  output2: boolean[] = [];
+c2.on('data', (data: boolean) => output2.push(data));
+
+readableFrom([1, 2, 3]).pipe(c2);