@@ -35,7 +35,7 @@
|
||||
@@ -257,9 +270,9 @@
|
||||
}).forEach((completablefuture) -> {
|
||||
if (flag) {
|
||||
this.executor.c(completablefuture::isDone);
|
||||
this.executor.awaitTasks(completablefuture::isDone);
|
||||
- ((Either) completablefuture.join()).ifLeft(this::saveChunk);
|
||||
+ (completablefuture.join()).ifLeft(this::saveChunk); // CraftBukkit - decompile error
|
||||
} else {
|
||||
@@ -108,7 +108,7 @@
|
||||
if (this.h.remove(i) && ichunkaccess instanceof Chunk) {
|
||||
Chunk chunk = (Chunk) ichunkaccess;
|
||||
|
||||
@@ -388,7 +428,7 @@
|
||||
@@ -394,7 +434,7 @@
|
||||
return CompletableFuture.completedFuture(Either.right(playerchunk_failure));
|
||||
});
|
||||
}, (runnable) -> {
|
||||
@@ -117,7 +117,7 @@
|
||||
});
|
||||
}
|
||||
}
|
||||
@@ -448,7 +488,10 @@
|
||||
@@ -454,7 +494,10 @@
|
||||
while (iterator.hasNext()) {
|
||||
Entity entity = (Entity) iterator.next();
|
||||
|
||||
@@ -129,7 +129,7 @@
|
||||
if (list == null) {
|
||||
list = Lists.newArrayList(new Entity[] { entity});
|
||||
} else {
|
||||
@@ -470,7 +513,7 @@
|
||||
@@ -476,7 +519,7 @@
|
||||
long i = playerchunk.h().pair();
|
||||
|
||||
playerchunk.getClass();
|
||||
@@ -138,7 +138,7 @@
|
||||
});
|
||||
}
|
||||
|
||||
@@ -487,7 +530,7 @@
|
||||
@@ -493,7 +536,7 @@
|
||||
return Either.left(chunk);
|
||||
});
|
||||
}, (runnable) -> {
|
||||
@@ -147,7 +147,7 @@
|
||||
});
|
||||
|
||||
completablefuture1.thenAcceptAsync((either) -> {
|
||||
@@ -501,7 +544,7 @@
|
||||
@@ -507,7 +550,7 @@
|
||||
return Either.left(chunk);
|
||||
});
|
||||
}, (runnable) -> {
|
||||
@@ -156,7 +156,7 @@
|
||||
});
|
||||
return completablefuture1;
|
||||
}
|
||||
@@ -511,8 +554,14 @@
|
||||
@@ -517,8 +560,14 @@
|
||||
}
|
||||
|
||||
public void saveChunk(IChunkAccess ichunkaccess) {
|
||||
@@ -172,7 +172,7 @@
|
||||
try {
|
||||
this.world.checkSession();
|
||||
} catch (ExceptionWorldConflict exceptionworldconflict) {
|
||||
@@ -563,9 +612,10 @@
|
||||
@@ -569,9 +618,10 @@
|
||||
ChunkCoordIntPair chunkcoordintpair = playerchunk.h();
|
||||
Packet<?>[] apacket = new Packet[2];
|
||||
|
||||
@@ -184,7 +184,7 @@
|
||||
boolean flag1 = i1 <= this.A;
|
||||
|
||||
this.sendChunk(entityplayer, chunkcoordintpair, apacket, flag, flag1);
|
||||
@@ -620,7 +670,7 @@
|
||||
@@ -626,7 +676,7 @@
|
||||
private NBTTagCompound f(ChunkCoordIntPair chunkcoordintpair) throws IOException {
|
||||
NBTTagCompound nbttagcompound = this.read(chunkcoordintpair);
|
||||
|
||||
@@ -193,7 +193,7 @@
|
||||
}
|
||||
|
||||
boolean d(ChunkCoordIntPair chunkcoordintpair) {
|
||||
@@ -940,7 +990,7 @@
|
||||
@@ -946,7 +996,7 @@
|
||||
public final Set<EntityPlayer> trackedPlayers = Sets.newHashSet();
|
||||
|
||||
public EntityTracker(Entity entity, int i, int j, boolean flag) {
|
||||
@@ -202,7 +202,7 @@
|
||||
this.tracker = entity;
|
||||
this.trackingDistance = i;
|
||||
this.e = SectionPosition.a(entity);
|
||||
@@ -1009,6 +1059,17 @@
|
||||
@@ -1015,6 +1065,17 @@
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user