2006-Scape/apollo
1
0
Fork 0
mirror of https://github.com/2006-Scape/apollo.git synced 2026-07-05 00:38:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add an await function to the AsyncActionRunner trait

Browse Source
This commit is contained in:
Gary Tierney
2017-09-16 22:34:24 +01:00
parent f23114d511
commit 3a9e435189
4 changed files with 63 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
game/src/main/kotlin/org/apollo/game/action/AsyncActionRunner.kt
+14 -3
View File
@@ -1,10 +1,10 @@
package org.apollo.game.action
import kotlinx.coroutines.experimental.*
import kotlinx.coroutines.experimental.CommonPool
import kotlinx.coroutines.experimental.Job
import kotlinx.coroutines.experimental.channels.Channel
import kotlinx.coroutines.experimental.launch
import kotlinx.coroutines.experimental.selects.select
import org.apollo.game.model.entity.Mob
import java.util.function.Supplier
class AsyncActionRunner(val actionSupplier: () -> Action<*>, val callback: suspend () -> Unit) {
var job: Job? = null
@@ -53,4 +53,15 @@ class AsyncActionRunner(val actionSupplier: () -> Action<*>, val callback: suspe
remainingPulses -= numPulses
}
}
suspend fun await(condition: () -> Boolean, timeout: Int = 15) {
var remainingPulsesBeforeTimeout = timeout
while (!condition.invoke()) {
remainingPulsesBeforeTimeout -= pulseChannel.receive()
if (remainingPulsesBeforeTimeout <= 0) {
break
}
}
}
}