Package net.minecraftforge.fmllegacy.network.simple

Class SimpleChannel

java.lang.Object

net.minecraftforge.fmllegacy.network.simple.SimpleChannel

public class SimpleChannel
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SimpleChannel.MessageBuilder<MSG>

Field Summary

Fields

Modifier and Type	Field	Description
private IndexedMessageCodec	indexedCodec
private NetworkInstance	instance
private List<Function<Boolean,? extends List<? extends org.apache.commons.lang3.tuple.Pair<String,?>>>>	loginPackets
private Optional<Consumer<NetworkEvent.ChannelRegistrationChangeEvent>>	registryChangeConsumer

Constructor Summary

Constructors

Modifier	Constructor	Description
	SimpleChannel(NetworkInstance instance)
	SimpleChannel(NetworkInstance instance, Consumer<NetworkEvent.ChannelRegistrationChangeEvent> registryChangeNotify)
private	SimpleChannel(NetworkInstance instance, Optional<Consumer<NetworkEvent.ChannelRegistrationChangeEvent>> registryChangeNotify)

Method Summary

Modifier and Type	Method	Description
<MSG> int	encodeMessage(MSG message, FriendlyByteBuf target)
boolean	isRemotePresent(Connection manager)	Returns true if the channel is present in the given connection.
<M> SimpleChannel.MessageBuilder<M>	messageBuilder(Class<M> type, int id)	Build a new MessageBuilder.
<M> SimpleChannel.MessageBuilder<M>	messageBuilder(Class<M> type, int id, NetworkDirection direction)	Build a new MessageBuilder.
private void	networkEventListener(NetworkEvent networkEvent)
private void	networkLoginGather(NetworkEvent.GatherLoginPayloadsEvent gatherEvent)
<MSG> IndexedMessageCodec.MessageHandler<MSG>	registerMessage(int index, Class<MSG> messageType, BiConsumer<MSG,FriendlyByteBuf> encoder, Function<FriendlyByteBuf,MSG> decoder, BiConsumer<MSG,Supplier<NetworkEvent.Context>> messageConsumer)
<MSG> IndexedMessageCodec.MessageHandler<MSG>	registerMessage(int index, Class<MSG> messageType, BiConsumer<MSG,FriendlyByteBuf> encoder, Function<FriendlyByteBuf,MSG> decoder, BiConsumer<MSG,Supplier<NetworkEvent.Context>> messageConsumer, Optional<NetworkDirection> networkDirection)
<MSG> void	reply(MSG msgToReply, NetworkEvent.Context context)
<MSG> void	send(PacketDistributor.PacketTarget target, MSG message)	Send a message to the PacketDistributor.PacketTarget from a PacketDistributor instance.
<MSG> void	sendTo(MSG message, Connection manager, NetworkDirection direction)
<MSG> void	sendToServer(MSG message)
private <MSG> org.apache.commons.lang3.tuple.Pair<FriendlyByteBuf,Integer>	toBuffer(MSG msg)
<MSG> Packet<?>	toVanillaPacket(MSG message, NetworkDirection direction)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

instance

private final NetworkInstance instance

indexedCodec

private final IndexedMessageCodec indexedCodec

registryChangeConsumer

private final Optional<Consumer<NetworkEvent.ChannelRegistrationChangeEvent>> registryChangeConsumer

loginPackets

private List<Function<Boolean,? extends List<? extends org.apache.commons.lang3.tuple.Pair<String,?>>>> loginPackets

Constructor Details

SimpleChannel

public SimpleChannel(NetworkInstance instance)

SimpleChannel

private SimpleChannel(NetworkInstance instance,
 Optional<Consumer<NetworkEvent.ChannelRegistrationChangeEvent>> registryChangeNotify)

SimpleChannel

public SimpleChannel(NetworkInstance instance,
 Consumer<NetworkEvent.ChannelRegistrationChangeEvent> registryChangeNotify)

Method Details

networkLoginGather

private void networkLoginGather(NetworkEvent.GatherLoginPayloadsEvent gatherEvent)

networkEventListener

private void networkEventListener(NetworkEvent networkEvent)

encodeMessage

public <MSG> int encodeMessage(MSG message,
 FriendlyByteBuf target)

registerMessage

public <MSG>
IndexedMessageCodec.MessageHandler<MSG> registerMessage(int index,
 Class<MSG> messageType,
 BiConsumer<MSG,FriendlyByteBuf> encoder,
 Function<FriendlyByteBuf,MSG> decoder,
 BiConsumer<MSG,Supplier<NetworkEvent.Context>> messageConsumer)

registerMessage

public <MSG>
IndexedMessageCodec.MessageHandler<MSG> registerMessage(int index,
 Class<MSG> messageType,
 BiConsumer<MSG,FriendlyByteBuf> encoder,
 Function<FriendlyByteBuf,MSG> decoder,
 BiConsumer<MSG,Supplier<NetworkEvent.Context>> messageConsumer,
 Optional<NetworkDirection> networkDirection)

toBuffer

private <MSG>
org.apache.commons.lang3.tuple.Pair<FriendlyByteBuf,Integer> toBuffer(MSG msg)

sendToServer

public <MSG> void sendToServer(MSG message)

sendTo

public <MSG> void sendTo(MSG message,
 Connection manager,
 NetworkDirection direction)

send

public <MSG> void send(PacketDistributor.PacketTarget target,
 MSG message)

Send a message to the PacketDistributor.PacketTarget from a PacketDistributor instance.

     channel.send(PacketDistributor.PLAYER.with(()->player), message)
 

Type Parameters:

MSG - The type of the message

Parameters:

target - The curried target from a PacketDistributor

message - The message to send

toVanillaPacket

public <MSG> Packet<?> toVanillaPacket(MSG message,
 NetworkDirection direction)

reply

public <MSG> void reply(MSG msgToReply,
 NetworkEvent.Context context)

isRemotePresent

public boolean isRemotePresent(Connection manager)

Returns true if the channel is present in the given connection.

messageBuilder

public <M> SimpleChannel.MessageBuilder<M> messageBuilder(Class<M> type,
 int id)

Build a new MessageBuilder. The type should implement IntSupplier if it is a login packet.

Type Parameters:

M - Type of type

Parameters:

type - Type of message

id - id in the indexed codec

Returns:

a MessageBuilder

messageBuilder

public <M> SimpleChannel.MessageBuilder<M> messageBuilder(Class<M> type,
 int id,
 NetworkDirection direction)

Build a new MessageBuilder. The type should implement IntSupplier if it is a login packet.

Type Parameters:

M - Type of type

Parameters:

type - Type of message

id - id in the indexed codec

direction - a network direction which will be asserted before any processing of this message occurs. Use to enforce strict sided handling to prevent spoofing.

Returns:

a MessageBuilder