Skip to content

Commit 18192f5

Browse files
committed
Prevent dispatches from being rescheduled
1 parent ae33379 commit 18192f5

File tree

2 files changed

+3
-9
lines changed

2 files changed

+3
-9
lines changed

src/main/kotlin/com/lambda/event/listener/SafeListener.kt

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -122,9 +122,7 @@ class SafeListener<T : Event>(
122122
alwaysListen: Boolean = false,
123123
noinline function: SafeContext.(T) -> Unit = {}
124124
): SafeListener<T> {
125-
val listener = SafeListener<T>(priority, this, alwaysListen) { event ->
126-
runGameScheduled { function(event) }
127-
}
125+
val listener = SafeListener<T>(priority, this, alwaysListen) { function(it) }
128126

129127
EventFlow.syncListeners.subscribe(listener)
130128

@@ -167,9 +165,7 @@ class SafeListener<T : Event>(
167165
alwaysListen: Boolean = false,
168166
function: SafeContext.(T) -> Unit = {},
169167
): SafeListener<T> {
170-
val listener = SafeListener<T>(priority, this, alwaysListen) { event ->
171-
runGameScheduled { function(event) }
172-
}
168+
val listener = SafeListener<T>(priority, this, alwaysListen) { function(it) }
173169

174170
EventFlow.syncListeners.subscribe(kClass, listener)
175171

src/main/kotlin/com/lambda/event/listener/UnsafeListener.kt

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -111,9 +111,7 @@ class UnsafeListener<T : Event>(
111111
alwaysListen: Boolean = false,
112112
noinline function: (T) -> Unit = {},
113113
): UnsafeListener<T> {
114-
val listener = UnsafeListener<T>(priority, this, alwaysListen) { event ->
115-
function(event)
116-
}
114+
val listener = UnsafeListener<T>(priority, this, alwaysListen) { function(it) }
117115

118116
EventFlow.syncListeners.subscribe(listener)
119117

0 commit comments

Comments
 (0)