From 619a9b320948a4e666597249fc6b7d65c9cc84de Mon Sep 17 00:00:00 2001
From: TheMode <themode@outlook.fr>
Date: Thu, 23 Sep 2021 11:32:13 +0200
Subject: [PATCH] Use a parallel stream for flushing

Signed-off-by: TheMode <themode@outlook.fr>
---
 src/main/java/net/minestom/server/UpdateManager.java | 11 +++--------
 1 file changed, 3 insertions(+), 8 deletions(-)

diff --git a/src/main/java/net/minestom/server/UpdateManager.java b/src/main/java/net/minestom/server/UpdateManager.java
index cd2b2896c..ae40be2ea 100644
--- a/src/main/java/net/minestom/server/UpdateManager.java
+++ b/src/main/java/net/minestom/server/UpdateManager.java
@@ -1,7 +1,6 @@
 package net.minestom.server;
 
 import net.minestom.server.acquirable.Acquirable;
-import net.minestom.server.entity.Player;
 import net.minestom.server.instance.Chunk;
 import net.minestom.server.instance.Instance;
 import net.minestom.server.instance.InstanceManager;
@@ -9,7 +8,6 @@ import net.minestom.server.monitoring.TickMonitor;
 import net.minestom.server.network.ConnectionManager;
 import net.minestom.server.thread.ThreadDispatcher;
 import net.minestom.server.utils.PacketUtils;
-import net.minestom.server.utils.async.AsyncUtils;
 import org.jetbrains.annotations.NotNull;
 
 import java.util.List;
@@ -201,12 +199,9 @@ public final class UpdateManager {
                     }
 
                     // Flush all waiting packets
-                    AsyncUtils.runAsync(() -> {
-                        PacketUtils.flush();
-                        for (Player player : MinecraftServer.getConnectionManager().getOnlinePlayers()) {
-                            player.getPlayerConnection().flush();
-                        }
-                    });
+                    PacketUtils.flush();
+                    connectionManager.getOnlinePlayers().parallelStream().forEach(player ->
+                            player.getPlayerConnection().flush());
 
                     // Disable thread until next tick
                     LockSupport.parkNanos((long) ((MinecraftServer.TICK_MS * 1e6) - tickTime));