Skip to content

Commit 18d5d40

Browse files
Clément Pasquierjvanbruegge
authored andcommitted
prevent calling merge if one sink (#7)
1 parent 9a6657d commit 18d5d40

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/index.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ export function mergeSinks(
4848
const merged = Object.keys(combinedSinks)
4949
.filter(name => Object.keys(exceptions).indexOf(name) === -1)
5050
.map(s => [s, combinedSinks[s]])
51-
.map(([s, arr]) => ({ [s]: xs.merge(...arr) }));
51+
.map(([s, arr]) => ({ [s]: arr.length === 1 ? arr[0] : xs.merge(...arr) }));
5252

5353
const special = Object.keys(exceptions)
5454
.map(key => [key, combinedSinks[key]])

0 commit comments

Comments
 (0)