fix(utils-split): dismiss inner observable on error

2025-12-08 18:01:51 +00:00 · 2020-09-10 11:43:55 +02:00 · 2020-09-10 11:43:55 +02:00 · 94baef6ccc
commit 94baef6ccc
parent fc20321d9b
1 changed files with 2 additions and 5 deletions
--- a/packages/utils/src/split.ts
+++ b/packages/utils/src/split.ts
@ -57,11 +57,8 @@ export function split<T, K, R>(
            : subject.asObservable()) as GroupedObservable<K, R>

          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)