From 4383662ee078d3807912f2d4e8496db56d0306ee Mon Sep 17 00:00:00 2001
From: johannes karoff <johannes@karoff.net>
Date: Wed, 8 Nov 2023 01:16:30 +0100
Subject: [PATCH] fix Cancelable.Builder if it is cancelled while subscribing

---
 colibri/src/main/scala/colibri/Cancelable.scala | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/colibri/src/main/scala/colibri/Cancelable.scala b/colibri/src/main/scala/colibri/Cancelable.scala
index adc9e074..977b8896 100644
--- 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)
       ()
     }