diff --git a/test/ops/concurrency-fork/async.ts b/test/ops/concurrency-fork/async.ts index 8482b89e..fc1fedac 100644 --- a/test/ops/concurrency-fork/async.ts +++ b/test/ops/concurrency-fork/async.ts @@ -9,7 +9,10 @@ export default () => { }); 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})); + const output = pipe( + _async(input), + concurrencyFork({onAsync: 123 as any}) + ); expect(await _asyncValues(output)).to.eql(input); }); it('must return the result', async () => {