import org.spongepowered.api.network.RemoteConnection; //导入依赖的package包/类
@Override
public void handlePayload(ChannelBuf data, RemoteConnection connection, Platform.Type side) {
    for (Map.Entry<Predicate<ChannelBuf>, Consumer<ChannelBuf>> entry : map.entrySet()) {
       if (entry.getKey().test(data)) {
           entry.getValue().accept(data);
           map.remove(entry.getKey());
           return;
       }
    }
}
 

import org.spongepowered.api.network.RemoteConnection; //导入依赖的package包/类
@Override
public void handleMessage(Message message, RemoteConnection connection, Type side) {
	if(!(connection instanceof PlayerConnection)){
		CustomSkinServer.logger.warning("[CustomSkinServer] RemoteConnection not instanceof PlayerConnection.");
		return;
	}
	PlayerConnection pc=(PlayerConnection) connection;
	Player p=pc.getPlayer();
	CustomSkinServer.onPluginMessage(new SpongePlayer(p),message.text);
}
 

import org.spongepowered.api.network.RemoteConnection; //导入依赖的package包/类
@Override
void handlePayload(ByteBuffer buf, RemoteConnection connection) {
    for (RawDataListener listener : this.serverDataListeners) {
        // We slice the buffer, to preserve the reader index for all the listeners,
        // the buffer shouldn't be modified in any way
        listener.handlePayload(buf.slice(), connection, Platform.Type.SERVER);
    }
}
 

import org.spongepowered.api.network.RemoteConnection; //导入依赖的package包/类
@Override
public void handlePayload(ChannelBuf channelBuf, RemoteConnection remoteConnection, Platform.Type type) {
    try {
        String message = new String(channelBuf.array(), StandardCharsets.UTF_8);
        JSONObject jsonObject = new JSONObject(message);
        Vote v = new Vote(jsonObject);
        listener.onForward(v);
    } catch (Exception e) {
        p.getLogger().error("There was an unknown error when processing a forwarded vote.", e);
    }
}
 

import org.spongepowered.api.network.RemoteConnection; //导入依赖的package包/类
@Override
public void handlePayload(@Nonnull ChannelBuf buf, @Nonnull RemoteConnection connection, @Nonnull Platform.Type type) {
    String msg = buf.readUTF();
    onMessage(msg, null);
}
 

import org.spongepowered.api.network.RemoteConnection; //导入依赖的package包/类
public void handlePayload(ByteBuffer buf, String channel, RemoteConnection connection) {
    final LanternChannelBinding binding = this.bindings.get(channel);
    if (binding != null) {
        binding.handlePayload(buf, connection);
    }
}
 

import org.spongepowered.api.network.RemoteConnection; //导入依赖的package包/类
public WrappedRemoteConnection(RemoteConnection remoteConnection) {
    this.remoteConnection = remoteConnection;
}
 

import org.spongepowered.api.network.RemoteConnection; //导入依赖的package包/类
public ApiCommandSource(RemoteConnection connection, ObjectMapper mapper)
{
    this.connection = connection;
    this.mapper = mapper;
}
 

import org.spongepowered.api.network.RemoteConnection; //导入依赖的package包/类
@Override
public RemoteConnection getConnection()
{
    return connection;
}
 

import org.spongepowered.api.network.RemoteConnection; //导入依赖的package包/类
public ApiUser(RemoteConnection connection, ObjectMapper mapper, User user)
{
    super(connection, mapper);
    this.user = user;
}
 

import org.spongepowered.api.network.RemoteConnection; //导入依赖的package包/类
public ApiServerSender(RemoteConnection connection, ObjectMapper mapper, ConsoleSource source)
{
    super(connection, mapper);
    this.source = source;
}
 

import org.spongepowered.api.network.RemoteConnection; //导入依赖的package包/类
public RemoteConnection getConnection()
{
    return this.connection;
}
 

import org.spongepowered.api.network.RemoteConnection; //导入依赖的package包/类
abstract void handlePayload(ByteBuffer buf, RemoteConnection connection);