api dump

mirego · Jan 14, 2025 · 66f129f · 66f129f
1 parent b930239
commit 66f129f
Show file tree

Hide file tree

Showing 3 changed files with 19 additions and 5 deletions.
diff --git a/trikot-streams/streams/api/android/streams.api b/trikot-streams/streams/api/android/streams.api
@@ -23,17 +23,24 @@ public abstract interface class com/mirego/trikot/streams/cancellable/Cancellabl
 	public abstract fun cancel ()V
 }
 
-public final class com/mirego/trikot/streams/cancellable/CancellableManager : com/mirego/trikot/streams/cancellable/Cancellable {
+public final class com/mirego/trikot/streams/cancellable/CancellableManager : com/mirego/trikot/streams/cancellable/Cancellable, com/mirego/trikot/streams/cancellable/VerifiableCancelledState {
 	public fun <init> ()V
 	public final fun add (Lcom/mirego/trikot/streams/cancellable/Cancellable;)Lcom/mirego/trikot/streams/cancellable/Cancellable;
 	public final fun add (Lkotlin/jvm/functions/Function0;)V
 	public fun cancel ()V
+	public final fun cleanCancelledChildren ()V
+	public fun isCancelled ()Z
 }
 
-public final class com/mirego/trikot/streams/cancellable/CancellableManagerProvider : com/mirego/trikot/streams/cancellable/Cancellable {
+public final class com/mirego/trikot/streams/cancellable/CancellableManagerProvider : com/mirego/trikot/streams/cancellable/Cancellable, com/mirego/trikot/streams/cancellable/VerifiableCancelledState {
 	public fun <init> ()V
 	public fun cancel ()V
 	public final fun cancelPreviousAndCreate ()Lcom/mirego/trikot/streams/cancellable/CancellableManager;
+	public fun isCancelled ()Z
+}
+
+public abstract interface class com/mirego/trikot/streams/cancellable/VerifiableCancelledState {
+	public abstract fun isCancelled ()Z
 }
 
 public final class com/mirego/trikot/streams/reactive/AndroidPublisherExtensionsKt {

diff --git a/trikot-streams/streams/api/jvm/streams.api b/trikot-streams/streams/api/jvm/streams.api
@@ -23,17 +23,24 @@ public abstract interface class com/mirego/trikot/streams/cancellable/Cancellabl
 	public abstract fun cancel ()V
 }
 
-public final class com/mirego/trikot/streams/cancellable/CancellableManager : com/mirego/trikot/streams/cancellable/Cancellable {
+public final class com/mirego/trikot/streams/cancellable/CancellableManager : com/mirego/trikot/streams/cancellable/Cancellable, com/mirego/trikot/streams/cancellable/VerifiableCancelledState {
 	public fun <init> ()V
 	public final fun add (Lcom/mirego/trikot/streams/cancellable/Cancellable;)Lcom/mirego/trikot/streams/cancellable/Cancellable;
 	public final fun add (Lkotlin/jvm/functions/Function0;)V
 	public fun cancel ()V
+	public final fun cleanCancelledChildren ()V
+	public fun isCancelled ()Z
 }
 
-public final class com/mirego/trikot/streams/cancellable/CancellableManagerProvider : com/mirego/trikot/streams/cancellable/Cancellable {
+public final class com/mirego/trikot/streams/cancellable/CancellableManagerProvider : com/mirego/trikot/streams/cancellable/Cancellable, com/mirego/trikot/streams/cancellable/VerifiableCancelledState {
 	public fun <init> ()V
 	public fun cancel ()V
 	public final fun cancelPreviousAndCreate ()Lcom/mirego/trikot/streams/cancellable/CancellableManager;
+	public fun isCancelled ()Z
+}
+
+public abstract interface class com/mirego/trikot/streams/cancellable/VerifiableCancelledState {
+	public abstract fun isCancelled ()Z
 }
 
 public abstract interface class com/mirego/trikot/streams/reactive/BehaviorSubject : com/mirego/trikot/streams/reactive/MutablePublisher {

diff --git a/...streams/src/commonMain/kotlin/com/mirego/trikot/streams/cancellable/CancellableManager.kt b/...streams/src/commonMain/kotlin/com/mirego/trikot/streams/cancellable/CancellableManager.kt
@@ -9,7 +9,7 @@ class CancellableManager : Cancellable, VerifiableCancelledState {
     private val queueList = AtomicListReference<Cancellable>()
 
     private var isCancelledDelegate = atomic(false)
-    override var isCancelled: Boolean by isCancelledDelegate
+    override val isCancelled: Boolean by isCancelledDelegate
 
     fun <T : Cancellable> add(cancellable: T): T {
         queueList.add(cancellable)