Uses of Class
org.drasyl.handler.stream.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
Modifier and TypeClassDescriptionclass
Represents the very last chunk of a message that is too large to be transmitted as a whole.Modifier 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) Modifier and TypeMethodDescriptionMessageChunksBufferInputList.iterator()
MessageChunksBufferInputList.listIterator()
MessageChunksBufferInputList.listIterator
(int index) MessageChunksBufferInputList.subList
(int fromIndex, int toIndex) Modifier 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) Modifier and TypeMethodDescriptionboolean
MessageChunksBufferInputList.addAll
(int index, Collection<? extends MessageChunk> c) boolean
MessageChunksBufferInputList.addAll
(Collection<? extends MessageChunk> c)