adding tests for concurrencyFork

vitaly-t · Aug 2, 2023 · bfe077d · bfe077d
1 parent ace997d
commit bfe077d
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 2 deletions.
diff --git a/test/ops/concurrency-fork/async.ts b/test/ops/concurrency-fork/async.ts
@@ -2,11 +2,16 @@ import {_async, _asyncValues, expect} from '../../header';
 import {pipe, concurrencyFork} from '../../../src';
 
 export default () => {
-    it('must default to the source', async () => {
+    it('must default to the source on missing handlers', async () => {
         const input = [1, 2, 3];
         const output = pipe(_async(input), concurrencyFork({}));
         expect(await _asyncValues(output)).to.eql(input);
     });
+    it('must default to the source on invalid handlers', async () => {
+        const input = [1, 2, 3];
+        const output = pipe(_async(input), concurrencyFork({onAsync: 123 as any}));
+        expect(await _asyncValues(output)).to.eql(input);
+    });
     it('must return the result', async () => {
         const input = [1, 2, 3];
         const output = pipe(

diff --git a/test/ops/concurrency-fork/sync.ts b/test/ops/concurrency-fork/sync.ts
@@ -2,11 +2,16 @@ import {expect} from '../../header';
 import {pipe, concurrencyFork} from '../../../src';
 
 export default () => {
-    it('must default to the source', () => {
+    it('must default to the source on missing handlers', () => {
         const input = [1, 2, 3];
         const output = pipe(input, concurrencyFork({}));
         expect([...output]).to.eql(input);
     });
+    it('must default to the source on invalid handlers', () => {
+        const input = [1, 2, 3];
+        const output = pipe(input, concurrencyFork({onSync: 123 as any}));
+        expect([...output]).to.eql(input);
+    });
     it('must return the result', () => {
         const input = [1, 2, 3];
         const output = pipe(