From 56f2ec46df6fb68d8626f214336fd4b5cec83ef4 Mon Sep 17 00:00:00 2001 From: mworzala Date: Thu, 23 Nov 2023 10:46:53 +0000 Subject: [PATCH] chore: experiment with publishing snapshots from PR branches (cherry picked from commit 390579f3ba536debc8422fb9f9afb217d0c4b848) --- .../minestom/server/network/ConnectionManager.java | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/src/main/java/net/minestom/server/network/ConnectionManager.java b/src/main/java/net/minestom/server/network/ConnectionManager.java index 58ef4f5b1..4901e0fcd 100644 --- a/src/main/java/net/minestom/server/network/ConnectionManager.java +++ b/src/main/java/net/minestom/server/network/ConnectionManager.java @@ -18,6 +18,7 @@ import net.minestom.server.utils.debug.DebugUtils; import net.minestom.server.utils.validate.Check; import org.jctools.queues.MessagePassingQueue; import org.jctools.queues.MpscUnboundedArrayQueue; +import org.jetbrains.annotations.ApiStatus; import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.Nullable; @@ -167,6 +168,14 @@ public final class ConnectionManager { return playerProvider; } + /** + * Adds a {@link Player} to the players list. + *

+ * Used during connection, you shouldn't have to do it manually. + * + * @param player the player + */ + @ApiStatus.Internal public synchronized void registerPlayer(@NotNull Player player) { this.players.add(player); this.connectionPlayerMap.put(player.getPlayerConnection(), player); @@ -180,12 +189,14 @@ public final class ConnectionManager { * @param connection the player connection * @see PlayerConnection#disconnect() to properly disconnect a player */ + @ApiStatus.Internal public synchronized void removePlayer(@NotNull PlayerConnection connection) { final Player player = this.connectionPlayerMap.remove(connection); if (player == null) return; this.players.remove(player); } + @ApiStatus.Internal public @NotNull Player startConfigurationState(@NotNull PlayerConnection connection, @NotNull UUID uuid, @NotNull String username) { final Player player = playerProvider.createPlayer(uuid, username, connection); @@ -193,6 +204,7 @@ public final class ConnectionManager { return player; } + @ApiStatus.Internal public CompletableFuture startConfigurationState(@NotNull Player player) { return AsyncUtils.runAsync(() -> { final PlayerConnection playerConnection = player.getPlayerConnection(); @@ -224,6 +236,7 @@ public final class ConnectionManager { }); } + @ApiStatus.Internal public void startPlayState(@NotNull Player player, @NotNull Instance instance) { this.waitingPlayers.relaxedOffer(new PendingPlayer(player, instance)); }