org.cloudburstmc.protocol.bedrock.netty.codec.compression

Class CompressionCodec

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.ChannelDuplexHandler

io.netty.handler.codec.MessageToMessageCodec<BedrockBatchWrapper,BedrockBatchWrapper>

org.cloudburstmc.protocol.bedrock.netty.codec.compression.CompressionCodec

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler, io.netty.channel.ChannelOutboundHandler

public class CompressionCodec
extends io.netty.handler.codec.MessageToMessageCodec<BedrockBatchWrapper,BedrockBatchWrapper>

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	NAME

Constructor Summary

Constructors

Constructor and Description
CompressionCodec(CompressionStrategy strategy, boolean prefixed)

Method Summary

Modifier and Type	Method and Description
protected void	decode(io.netty.channel.ChannelHandlerContext ctx, BedrockBatchWrapper msg, java.util.List<java.lang.Object> out)
protected void	encode(io.netty.channel.ChannelHandlerContext ctx, BedrockBatchWrapper msg, java.util.List<java.lang.Object> out)
protected org.cloudburstmc.protocol.bedrock.data.CompressionAlgorithm	getCompressionAlgorithm(byte header)
protected org.cloudburstmc.protocol.bedrock.data.CompressionAlgorithm	getCompressionAlgorithm0(byte header)
protected byte	getCompressionHeader(org.cloudburstmc.protocol.bedrock.data.CompressionAlgorithm algorithm)
protected byte	getCompressionHeader0(org.cloudburstmc.protocol.bedrock.data.CompressionAlgorithm algorithm)
CompressionStrategy	getStrategy()
protected void	onCompressed(io.netty.channel.ChannelHandlerContext ctx, BedrockBatchWrapper msg)
protected void	onDecompressed(io.netty.channel.ChannelHandlerContext ctx, BedrockBatchWrapper msg)
protected void	onPassedThrough(io.netty.channel.ChannelHandlerContext ctx, BedrockBatchWrapper msg)

Methods inherited from class io.netty.handler.codec.MessageToMessageCodec

acceptInboundMessage, acceptOutboundMessage, channelRead, write

Methods inherited from class io.netty.channel.ChannelDuplexHandler

bind, close, connect, deregister, disconnect, flush, read

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.ChannelHandler

exceptionCaught, handlerAdded, handlerRemoved

Field Detail

NAME

public static final java.lang.String NAME

See Also:

Constant Field Values

Constructor Detail

CompressionCodec

public CompressionCodec(CompressionStrategy strategy,
                        boolean prefixed)

Method Detail

encode

protected void encode(io.netty.channel.ChannelHandlerContext ctx,
                      BedrockBatchWrapper msg,
                      java.util.List<java.lang.Object> out)
               throws java.lang.Exception

Specified by:

encode in class io.netty.handler.codec.MessageToMessageCodec<BedrockBatchWrapper,BedrockBatchWrapper>

Throws:

java.lang.Exception

decode

protected void decode(io.netty.channel.ChannelHandlerContext ctx,
                      BedrockBatchWrapper msg,
                      java.util.List<java.lang.Object> out)
               throws java.lang.Exception

Specified by:

decode in class io.netty.handler.codec.MessageToMessageCodec<BedrockBatchWrapper,BedrockBatchWrapper>

Throws:

java.lang.Exception

onPassedThrough

protected void onPassedThrough(io.netty.channel.ChannelHandlerContext ctx,
                               BedrockBatchWrapper msg)

onCompressed

protected void onCompressed(io.netty.channel.ChannelHandlerContext ctx,
                            BedrockBatchWrapper msg)

onDecompressed

protected void onDecompressed(io.netty.channel.ChannelHandlerContext ctx,
                              BedrockBatchWrapper msg)

getCompressionHeader

protected final byte getCompressionHeader(org.cloudburstmc.protocol.bedrock.data.CompressionAlgorithm algorithm)

getCompressionAlgorithm

protected final org.cloudburstmc.protocol.bedrock.data.CompressionAlgorithm getCompressionAlgorithm(byte header)

getCompressionHeader0

protected byte getCompressionHeader0(org.cloudburstmc.protocol.bedrock.data.CompressionAlgorithm algorithm)

getCompressionAlgorithm0

protected org.cloudburstmc.protocol.bedrock.data.CompressionAlgorithm getCompressionAlgorithm0(byte header)

getStrategy

public CompressionStrategy getStrategy()