aboutsummaryrefslogtreecommitdiff
path: root/spark-sponge/src/main/java/me/lucko/spark/sponge/SpongeTickCounter.java
diff options
context:
space:
mode:
Diffstat (limited to 'spark-sponge/src/main/java/me/lucko/spark/sponge/SpongeTickCounter.java')
-rw-r--r--spark-sponge/src/main/java/me/lucko/spark/sponge/SpongeTickCounter.java18
1 files changed, 8 insertions, 10 deletions
diff --git a/spark-sponge/src/main/java/me/lucko/spark/sponge/SpongeTickCounter.java b/spark-sponge/src/main/java/me/lucko/spark/sponge/SpongeTickCounter.java
index 14b30b8..187f301 100644
--- a/spark-sponge/src/main/java/me/lucko/spark/sponge/SpongeTickCounter.java
+++ b/spark-sponge/src/main/java/me/lucko/spark/sponge/SpongeTickCounter.java
@@ -20,18 +20,16 @@
package me.lucko.spark.sponge;
-import me.lucko.spark.sampler.TickCounter;
-
-import org.spongepowered.api.scheduler.Task;
+import me.lucko.spark.common.sampler.TickCounter;
import java.util.HashSet;
import java.util.Set;
public class SpongeTickCounter implements TickCounter, Runnable {
private final SparkSpongePlugin plugin;
- private Task task;
+ private org.spongepowered.api.scheduler.Task task;
- private final Set<Runnable> tasks = new HashSet<>();
+ private final Set<TickTask> tasks = new HashSet<>();
private int tick = 0;
public SpongeTickCounter(SparkSpongePlugin plugin) {
@@ -40,15 +38,15 @@ public class SpongeTickCounter implements TickCounter, Runnable {
@Override
public void run() {
- for (Runnable r : this.tasks){
- r.run();
+ for (TickTask r : this.tasks){
+ r.onTick(this);
}
this.tick++;
}
@Override
public void start() {
- this.task = Task.builder().intervalTicks(1).name("spark-ticker").execute(this).submit(this.plugin);
+ this.task = org.spongepowered.api.scheduler.Task.builder().intervalTicks(1).name("spark-ticker").execute(this).submit(this.plugin);
}
@Override
@@ -62,12 +60,12 @@ public class SpongeTickCounter implements TickCounter, Runnable {
}
@Override
- public void addTickTask(Runnable runnable) {
+ public void addTickTask(TickTask runnable) {
this.tasks.add(runnable);
}
@Override
- public void removeTickTask(Runnable runnable) {
+ public void removeTickTask(TickTask runnable) {
this.tasks.remove(runnable);
}
}