TotalFreedomMC/TF-EssentialsX
1
0
Fork 0
mirror of https://github.com/TotalFreedomMC/TF-EssentialsX.git synced 2025-08-05 12:02:53 +00:00
Code Issues Projects Releases Wiki Activity

Improve scheduler methods to use Java 1.8 lambdas (#2700)

Browse source 
* Update EssentialsPlayerListener.java

* Update Backup.java
This commit is contained in:
montlikadani 2019-12-31 14:58:09 +01:00 • committed by md678685
parent b694e8aaa2
commit e158a65603
2 changed files with 9 additions and 31 deletions
Download patch file Download diff file Expand all files Collapse all files

7
Essentials/src/com/earth2me/essentials/Backup.java
View file

@ -25,12 +25,7 @@ public class Backup implements Runnable {
this.ess = ess; this.ess = ess;
server = ess.getServer(); server = ess.getServer();
if (!ess.getOnlinePlayers().isEmpty()) { if (!ess.getOnlinePlayers().isEmpty()) {
ess.runTaskAsynchronously(new Runnable() { ess.runTaskAsynchronously(this::startTask);
@Override
public void run() {
startTask();
}
});
} }
} }

33
Essentials/src/com/earth2me/essentials/EssentialsPlayerListener.java
View file

@ -192,12 +192,8 @@ public class EssentialsPlayerListener implements Listener {
@EventHandler(priority = EventPriority.HIGHEST) @EventHandler(priority = EventPriority.HIGHEST)
public void onPlayerJoin(final PlayerJoinEvent event) { public void onPlayerJoin(final PlayerJoinEvent event) {
final String joinMessage = event.getJoinMessage(); final String joinMessage = event.getJoinMessage();
ess.runTaskAsynchronously(new Runnable() { ess.runTaskAsynchronously(() -> delayedJoin(event.getPlayer(), joinMessage));
@Override
public void run() {
delayedJoin(event.getPlayer(), joinMessage);
}
});
if (ess.getSettings().allowSilentJoinQuit() || ess.getSettings().isCustomJoinMessage()) { if (ess.getSettings().allowSilentJoinQuit() || ess.getSettings().isCustomJoinMessage()) {
event.setJoinMessage(null); event.setJoinMessage(null);
} }
@ -445,12 +441,7 @@ public class EssentialsPlayerListener implements Listener {
final User user = ess.getUser(event.getPlayer()); final User user = ess.getUser(event.getPlayer());
if (user.hasUnlimited(new ItemStack(event.getBucket()))) { if (user.hasUnlimited(new ItemStack(event.getBucket()))) {
event.getItemStack().setType(event.getBucket()); event.getItemStack().setType(event.getBucket());
ess.scheduleSyncDelayedTask(new Runnable() { ess.scheduleSyncDelayedTask(user.getBase()::updateInventory);
@Override
public void run() {
user.getBase().updateInventory();
}
});
} }
} }
@ -627,6 +618,8 @@ public class EssentialsPlayerListener implements Listener {
case PHYSICAL: case PHYSICAL:
updateActivity = false; updateActivity = false;
break; break;
default:
break;
} }
if (updateActivity) { if (updateActivity) {
@ -746,12 +739,7 @@ public class EssentialsPlayerListener implements Listener {
if (refreshPlayer != null) { if (refreshPlayer != null) {
final Player player = refreshPlayer; final Player player = refreshPlayer;
ess.scheduleSyncDelayedTask(new Runnable() { ess.scheduleSyncDelayedTask(player::updateInventory, 1);
@Override
public void run() {
player.updateInventory();
}
}, 1);
} }
} }
@ -786,19 +774,14 @@ public class EssentialsPlayerListener implements Listener {
if (refreshPlayer != null) { if (refreshPlayer != null) {
final Player player = refreshPlayer; final Player player = refreshPlayer;
ess.scheduleSyncDelayedTask(new Runnable() { ess.scheduleSyncDelayedTask(player::updateInventory, 1);
@Override
public void run() {
player.updateInventory();
}
}, 1);
} }
} }
@EventHandler(priority = EventPriority.LOW, ignoreCancelled = true) @EventHandler(priority = EventPriority.LOW, ignoreCancelled = true)
public void onPlayerFishEvent(final PlayerFishEvent event) { public void onPlayerFishEvent(final PlayerFishEvent event) {
final User user = ess.getUser(event.getPlayer()); final User user = ess.getUser(event.getPlayer());
user.updateActivityOnInteract(true); user.updateActivityOnInteract(true);
} }
private static boolean isEntityPickupEvent() { private static boolean isEntityPickupEvent() {