From 690fed62a1615ad974926b7329f972e9505457fd Mon Sep 17 00:00:00 2001 From: johannes karoff 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..e43e6002 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.cancel() + else buffer.push(cancelable) () }