fix Cancelable.Builder if it is cancelled while subscribing

cornerman · Nov 8, 2023 · 9f2e076 · 9f2e076
1 parent 29351ce
commit 9f2e076
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/colibri/src/main/scala/colibri/Cancelable.scala b/colibri/src/main/scala/colibri/Cancelable.scala
@@ -46,7 +46,11 @@ object Cancelable {
 
     def unsafeAdd(subscription: () => Cancelable): Unit = if (buffer != null) {
       val cancelable = subscription()
-      buffer.push(cancelable)
+      if (buffer == null) {
+        cancelable.cancel()
+      } else {
+        buffer.push(cancelable)
+      }
       ()
     }