minor refactoring

cornerman · Nov 8, 2023 · 6021446 · 6021446
1 parent de02047
commit 6021446
Showing 1 changed file with 3 additions and 6 deletions.
diff --git a/reactive/src/main/scala/colibri/reactive/Reactive.scala b/reactive/src/main/scala/colibri/reactive/Reactive.scala
@@ -189,12 +189,9 @@ object Rx extends RxPlatform {
           .subscribing(owner.liveObservable.dropSyncAll.head.via(subject))
           .tapCancel(owner.cancelable.unsafeCancel)
       } catch {
-        case NonFatal(t) =>
-          owner.cancelable.unsafeCancel()
-          Observable.raiseError(t)
-        case t: Throwable =>
-          owner.cancelable.unsafeCancel()
-          throw t
+        case NonFatal(t) => Observable.raiseError(t)
+      } finally {
+        owner.cancelable.unsafeCancel()
       }
     }