diff --git a/core/src/main/java/com/boydti/fawe/example/MappedFaweQueue.java b/core/src/main/java/com/boydti/fawe/example/MappedFaweQueue.java index 356b6761..241dc6d0 100644 --- a/core/src/main/java/com/boydti/fawe/example/MappedFaweQueue.java +++ b/core/src/main/java/com/boydti/fawe/example/MappedFaweQueue.java @@ -206,6 +206,7 @@ public abstract class MappedFaweQueue extends FaweQueue { public void end(FaweChunk chunk) { chunk.end(); + sendChunk(chunk); } @Override diff --git a/core/src/main/java/com/boydti/fawe/regions/general/plot/FaweLocalBlockQueue.java b/core/src/main/java/com/boydti/fawe/regions/general/plot/FaweLocalBlockQueue.java index 3cae8669..b88e38c9 100644 --- a/core/src/main/java/com/boydti/fawe/regions/general/plot/FaweLocalBlockQueue.java +++ b/core/src/main/java/com/boydti/fawe/regions/general/plot/FaweLocalBlockQueue.java @@ -25,7 +25,7 @@ public class FaweLocalBlockQueue extends LocalBlockQueue { @Override public boolean next() { - return IMP.next(); + return IMP.size() > 0; } @Override @@ -97,6 +97,12 @@ public class FaweLocalBlockQueue extends LocalBlockQueue { IMP.flush(); } + @Override + public void enqueue() { + super.enqueue(); + IMP.enqueue(); + } + @Override public void refreshChunk(int x, int z) { IMP.sendChunk(IMP.getFaweChunk(x, z)); diff --git a/core/src/main/java/com/boydti/fawe/regions/general/plot/PlotSquaredFeature.java b/core/src/main/java/com/boydti/fawe/regions/general/plot/PlotSquaredFeature.java index 1b2aa981..4185e6fc 100644 --- a/core/src/main/java/com/boydti/fawe/regions/general/plot/PlotSquaredFeature.java +++ b/core/src/main/java/com/boydti/fawe/regions/general/plot/PlotSquaredFeature.java @@ -31,7 +31,7 @@ public class PlotSquaredFeature extends FaweMaskManager { try { // If it's going to fail, throw an error now rather than later QueueProvider provider = QueueProvider.of(FaweLocalBlockQueue.class, null); - GlobalBlockQueue.IMP = new GlobalBlockQueue(provider, 1); + GlobalBlockQueue.IMP.setProvider(provider); HybridPlotManager.REGENERATIVE_CLEAR = false; Fawe.debug(" - QueueProvider: " + FaweLocalBlockQueue.class); Fawe.debug(" - HybridPlotManager.REGENERATIVE_CLEAR: " + HybridPlotManager.REGENERATIVE_CLEAR);