Events: Use Set to store channels (to improve 'remove' perf)

Author: sellmair

evas/src/commonMain/kotlin/io/sellmair/evas/AtomicSnapshot.kt

@@ -7,7 +7,7 @@ import kotlinx.atomicfu.atomic
 import kotlinx.atomicfu.loop
 import kotlin.concurrent.Volatile
 
-internal fun <T> AtomicSnapshotList(initial: MutableList<T> = mutableListOf()): AtomicSnapshot<MutableList<T>, List<T>> =
+internal fun <T> AtomicSnapshotList(initial: MutableCollection<T> = mutableListOf()): AtomicSnapshot<MutableCollection<T>, List<T>> =
     AtomicSnapshot(initial, { it.toList() })
 
 internal fun <K, V> AtomicSnapshotMap(initial: MutableMap<K, V> = mutableMapOf()): AtomicSnapshot<MutableMap<K, V>, Map<K, V>> =

evas/src/commonMain/kotlin/io/sellmair/evas/Events.kt

@@ -312,7 +312,7 @@ Implementation!
 internal class EventsImpl : Events {
     private val unconfinedScope = CoroutineScope(Dispatchers.Unconfined)
 
-    internal val typedChannels = AtomicSnapshotMap<KClass<*>, AtomicSnapshot<MutableList<Channel<Dispatch<*>>>, List<Channel<Dispatch<*>>>>>()
+    internal val typedChannels = AtomicSnapshotMap<KClass<*>, AtomicSnapshot<MutableCollection<Channel<Dispatch<*>>>, List<Channel<Dispatch<*>>>>>()
 
     internal class Dispatch<out T>(val event: T, val job: CompletableJob?)
 
@@ -322,7 +322,7 @@ internal class EventsImpl : Events {
 
             /* Register Channel in this even bus */
             typedChannels.write { mutableTypedChannels ->
-                val channels = mutableTypedChannels.getOrPut(clazz) { AtomicSnapshotList() }
+                val channels = mutableTypedChannels.getOrPut(clazz) { AtomicSnapshotList(mutableSetOf()) }
 
                 channels.write { mutableChannels ->
                     @Suppress("UNCHECKED_CAST")