From ddbb96565c8feada619629947b2558eae565c267 Mon Sep 17 00:00:00 2001 From: kuroppoi <68156848+kuroppoi@users.noreply.github.com> Date: Mon, 15 Nov 2021 03:06:41 +0100 Subject: [PATCH] Replaced anonymous classes with lambda expressions --- .../gameserver/server/pipeline/Connection.java | 14 ++------------ .../gameserver/zone/gen/AsyncZoneGenerator.java | 7 +------ 2 files changed, 3 insertions(+), 18 deletions(-) diff --git a/gameserver/src/main/java/brainwine/gameserver/server/pipeline/Connection.java b/gameserver/src/main/java/brainwine/gameserver/server/pipeline/Connection.java index ae07aab..dc68d8a 100644 --- a/gameserver/src/main/java/brainwine/gameserver/server/pipeline/Connection.java +++ b/gameserver/src/main/java/brainwine/gameserver/server/pipeline/Connection.java @@ -41,22 +41,12 @@ public class Connection extends SimpleChannelInboundHandler { return; } - GameServer.getInstance().queueSynchronousTask(new Runnable() { - @Override - public void run() { - player.onDisconnect(); - } - }); + GameServer.getInstance().queueSynchronousTask(player::onDisconnect); } @Override protected void channelRead0(ChannelHandlerContext ctx, Request request) throws Exception { - GameServer.getInstance().queueSynchronousTask(new Runnable() { - @Override - public void run() { - request.process(Connection.this); - } - }); + GameServer.getInstance().queueSynchronousTask(() -> request.process(this)); } @Override diff --git a/gameserver/src/main/java/brainwine/gameserver/zone/gen/AsyncZoneGenerator.java b/gameserver/src/main/java/brainwine/gameserver/zone/gen/AsyncZoneGenerator.java index 40c333b..dbaefe0 100644 --- a/gameserver/src/main/java/brainwine/gameserver/zone/gen/AsyncZoneGenerator.java +++ b/gameserver/src/main/java/brainwine/gameserver/zone/gen/AsyncZoneGenerator.java @@ -47,12 +47,7 @@ public class AsyncZoneGenerator extends Thread { Consumer callback = task.getCallback(); if(callback != null) { - GameServer.getInstance().queueSynchronousTask(new Runnable() { - @Override - public void run() { - callback.accept(generated); - } - }); + GameServer.getInstance().queueSynchronousTask(() -> callback.accept(generated)); } } });