diff --git a/core/src/main/kotlin/me/rhunk/snapenhance/core/event/EventBus.kt b/core/src/main/kotlin/me/rhunk/snapenhance/core/event/EventBus.kt index 04218aab..5d74b370 100644 --- a/core/src/main/kotlin/me/rhunk/snapenhance/core/event/EventBus.kt +++ b/core/src/main/kotlin/me/rhunk/snapenhance/core/event/EventBus.kt @@ -1,6 +1,7 @@ package me.rhunk.snapenhance.core.event import me.rhunk.snapenhance.core.ModContext +import java.util.concurrent.ConcurrentHashMap import kotlin.reflect.KClass abstract class Event { @@ -15,7 +16,7 @@ interface IListener { class EventBus( val context: ModContext ) { - private val subscribers = mutableMapOf, MutableMap>>() + private val subscribers = ConcurrentHashMap, MutableMap>>() fun subscribe(event: KClass, listener: IListener, priority: Int? = null) { synchronized(subscribers) {