Add stream online players method (#2457)

* Add stream online players method * run spotless apply
SpongePowered · Apr 22, 2023 · f69db9f · f69db9f
1 parent 5bafc99
commit f69db9f
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 2 deletions.
diff --git a/src/main/java/org/spongepowered/api/Server.java b/src/main/java/org/spongepowered/api/Server.java
@@ -57,6 +57,7 @@
 import java.util.Collection;
 import java.util.Optional;
 import java.util.UUID;
+import java.util.stream.Stream;
 
 /**
  * Represents a typical Minecraft Server.
@@ -225,6 +226,13 @@ public interface Server extends ForwardingAudience, Engine, LocaleSource {
      */
     TeleportHelper teleportHelper();
 
+    /**
+     * Gets a {@link Stream} of all the {@link ServerPlayer}s currently online.
+     *
+     * @return The stream of online players
+     */
+    Stream<ServerPlayer> streamOnlinePlayers();
+
     /**
      * Gets the {@link ServerPlayer}s currently online.
      *

diff --git a/src/main/java/org/spongepowered/api/network/channel/packet/PacketDispatcher.java b/src/main/java/org/spongepowered/api/network/channel/packet/PacketDispatcher.java
@@ -58,7 +58,7 @@ public interface PacketDispatcher {
      * @param packet The packet to send
      */
     default void sendToAllPlayers(final Packet packet) {
-        Sponge.server().onlinePlayers().forEach(player -> this.sendTo(player, packet));
+        Sponge.server().streamOnlinePlayers().forEach(player -> this.sendTo(player, packet));
     }
 
     /**

diff --git a/src/main/java/org/spongepowered/api/network/channel/raw/play/RawPlayDataChannel.java b/src/main/java/org/spongepowered/api/network/channel/raw/play/RawPlayDataChannel.java
@@ -124,7 +124,7 @@ public interface RawPlayDataChannel {
      * @param payload A consumer to write the data to
      */
     default void sendToAllPlayers(final Consumer<ChannelBuf> payload) {
-        Sponge.server().onlinePlayers().forEach(player -> this.sendTo(player, payload));
+        Sponge.server().streamOnlinePlayers().forEach(player -> this.sendTo(player, payload));
     }
 
     /**