diff --git a/packages/utils/src/split.ts b/packages/utils/src/split.ts index f725636..d7a0296 100644 --- a/packages/utils/src/split.ts +++ b/packages/utils/src/split.ts @@ -57,11 +57,8 @@ export function split( : subject.asObservable()) as GroupedObservable res.key = key - res.subscribe({ - complete() { - groups.delete(key) - }, - }) + const onFinish = () => groups.delete(key) + res.subscribe(undefined, onFinish, onFinish) subject.next(x) subscriber.next(res)