Run closeWith() logic in the event loop

2020-06-04 01:35:32 -04:00
parent ee4bae60a9
commit 456b4b217f
1 changed files with 4 additions and 2 deletions
--- a/proxy/src/main/java/com/velocitypowered/proxy/connection/MinecraftConnection.java
+++ b/proxy/src/main/java/com/velocitypowered/proxy/connection/MinecraftConnection.java
@@ -205,8 +205,10 @@ public class MinecraftConnection extends ChannelInboundHandlerAdapter {
   */
  public void closeWith(Object msg) {
    if (channel.isActive()) {
-      knownDisconnect = true;
-      channel.writeAndFlush(msg).addListener(ChannelFutureListener.CLOSE);
+      channel.eventLoop().execute(() -> {
+        knownDisconnect = true;
+        channel.writeAndFlush(msg).addListener(ChannelFutureListener.CLOSE);
+      });
    }
  }