import org.spongepowered.api.network.ChannelBuf; //导入依赖的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.ChannelBuf; //导入依赖的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.ChannelBuf; //导入依赖的package包/类
private static void addListener(Predicate<ChannelBuf> predicate, Consumer<ChannelBuf> consumer) {
    listener.map.put(predicate, consumer);
}
 

import org.spongepowered.api.network.ChannelBuf; //导入依赖的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.ChannelBuf; //导入依赖的package包/类
@Override
public void readFrom(ChannelBuf buf) {
	buf.readUTF();
}
 

import org.spongepowered.api.network.ChannelBuf; //导入依赖的package包/类
@Override
public void writeTo(ChannelBuf buf) {
	buf.writeUTF(text);
}
 

import org.spongepowered.api.network.ChannelBuf; //导入依赖的package包/类
@Override
public void sendTo(Player player, Consumer<ChannelBuf> payload) {
    checkState(this.bound);
    getRegistrar().sendPayload(player, getName(), payload::accept);
}
 

import org.spongepowered.api.network.ChannelBuf; //导入依赖的package包/类
@Override
public void sendToServer(Consumer<ChannelBuf> payload) {
    checkState(this.bound);
    checkNotNull(payload, "payload");
}
 

import org.spongepowered.api.network.ChannelBuf; //导入依赖的package包/类
@Override
public void sendToAll(Consumer<ChannelBuf> payload) {
    checkState(this.bound);
    getRegistrar().sendPayloadToAll(getName(), payload::accept);
}
 

import org.spongepowered.api.network.ChannelBuf; //导入依赖的package包/类
public ChannelBufInputStream(ChannelBuf channelBuf) {
    this.channelBuf = channelBuf;
}