diff options
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.java | 18 |
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); } } |