fix Cancelable.Builder if it is cancelled while subscribing

cornerman · Nov 8, 2023 · 4383662 · 4383662
1 parent 29351ce
commit 4383662
Showing 1 changed file with 2 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,8 @@ object Cancelable {
 
     def unsafeAdd(subscription: () => Cancelable): Unit = if (buffer != null) {
       val cancelable = subscription()
-      buffer.push(cancelable)
+      if (buffer == null) cancelable.unsafeCancel()
+      else buffer.push(cancelable)
       ()
     }