diff --git a/packages/utils/src/split.ts b/packages/utils/src/split.ts index b08ab31..20a2646 100644 --- a/packages/utils/src/split.ts +++ b/packages/utils/src/split.ts @@ -45,12 +45,12 @@ export function split( subscriber.next(res) }, (e) => { - groups.forEach((g) => g.error(e)) subscriber.error(e) + groups.forEach((g) => g.error(e)) }, () => { - groups.forEach((g) => g.complete()) subscriber.complete() + groups.forEach((g) => g.complete()) }, )