Uses of Class
org.drasyl.handler.stream.MessageChunk
Packages that use MessageChunk
Package
Description
Codecs, Channel Handlers, and Messages for sending large data streams asynchronously neither
spending a lot of memory nor getting
OutOfMemoryError
-
Uses of MessageChunk in org.drasyl.handler.stream
Subclasses of MessageChunk in org.drasyl.handler.streamModifier and TypeClassDescriptionclass
Represents the very last chunk of a message that is too large to be transmitted as a whole.Methods in org.drasyl.handler.stream that return MessageChunkModifier and TypeMethodDescriptionMessageChunksBufferInputList.get
(int index) ChunkedMessageInput.readChunk
(io.netty.buffer.ByteBufAllocator allocator) ChunkedMessageInput.readChunk
(io.netty.channel.ChannelHandlerContext ctx) MessageChunksBufferInputList.remove
(int index) MessageChunk.replace
(io.netty.buffer.ByteBuf content) MessageChunksBufferInputList.set
(int index, MessageChunk element) Methods in org.drasyl.handler.stream that return types with arguments of type MessageChunkModifier and TypeMethodDescriptionMessageChunksBufferInputList.iterator()
MessageChunksBufferInputList.listIterator()
MessageChunksBufferInputList.listIterator
(int index) MessageChunksBufferInputList.subList
(int fromIndex, int toIndex) Methods in org.drasyl.handler.stream with parameters of type MessageChunkModifier and TypeMethodDescriptionvoid
MessageChunksBufferInputList.add
(int index, MessageChunk element) boolean
MessageChunksBufferInputList.add
(MessageChunk e) protected ReassembledMessage
ChunkedMessageAggregator.beginAggregation
(MessageChunk start, io.netty.buffer.ByteBuf content) protected void
MessageChunksBuffer.decode
(io.netty.channel.ChannelHandlerContext ctx, MessageChunk msg, List<Object> out) protected void
MessageChunkEncoder.encode
(io.netty.channel.ChannelHandlerContext ctx, MessageChunk msg, io.netty.buffer.ByteBuf out) protected boolean
ChunkedMessageAggregator.isAggregated
(MessageChunk msg) protected boolean
ChunkedMessageAggregator.isContentLengthInvalid
(MessageChunk start, int maxContentLength) protected boolean
ChunkedMessageAggregator.isContentMessage
(MessageChunk msg) protected boolean
ChunkedMessageAggregator.isLastContentMessage
(MessageChunk msg) protected boolean
ChunkedMessageAggregator.isStartMessage
(MessageChunk msg) protected Object
ChunkedMessageAggregator.newContinueResponse
(MessageChunk start, int maxContentLength, io.netty.channel.ChannelPipeline pipeline) MessageChunksBufferInputList.set
(int index, MessageChunk element) Method parameters in org.drasyl.handler.stream with type arguments of type MessageChunkModifier and TypeMethodDescriptionboolean
MessageChunksBufferInputList.addAll
(int index, Collection<? extends MessageChunk> c) boolean
MessageChunksBufferInputList.addAll
(Collection<? extends MessageChunk> c)