From 94baef6cccb987f2259f5d679aae9103ffa1e1b2 Mon Sep 17 00:00:00 2001
From: Josep M Sobrepere <josepot@gmail.com>
Date: Thu, 10 Sep 2020 11:43:55 +0200
Subject: [PATCH] fix(utils-split): dismiss inner observable on error

---
 packages/utils/src/split.ts | 7 ++-----
 1 file changed, 2 insertions(+), 5 deletions(-)

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<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)