Package org.drasyl.handler.stream

package org.drasyl.handler.stream

Codecs, Channel Handlers, and Messages for sending large data streams asynchronously neither spending a lot of memory nor getting OutOfMemoryError

Related Packages

Package	Description
org.drasyl.handler	Handlers used to run a drasyl node.

Classes

Class	Description
ChunkedMessageAggregator	Aggregates MessageChunks to a ReassembledMessage.
ChunkedMessageInput	Wraps each chunk of the specified io.netty.handler.stream.ChunkedInput<io.netty.buffer.ByteBuf> into a series of sortable MessageChunks, allowing the receiver to reassemble the ByteBuf in correct order.
LargeByteBufToChunkedMessageEncoder	Encodes ByteBufs exceeding LargeByteBufToChunkedMessageEncoder.maxChunkLength to ChunkedMessageInputs.
LastMessageChunk	Represents the very last chunk of a message that is too large to be transmitted as a whole.
MessageChunk	Represents a chunk of a message that is too large to be transmitted as a whole.
MessageChunkDecoder	Decodes ByteBufs with correct magic number to MessageChunks.
MessageChunkEncoder	Encodes MessageChunks to ByteBufs.
MessageChunksBuffer	Buffers until all MessageChunks belonging to the same message have been collected, then passes them in the correct order.
MessageChunksBufferInputList	Special List implementation which is used within our MessageChunksBuffer.
ReassembledMessage	Represents a message that has been reassembled from MessageChunks.
ReassembledMessageDecoder	Decodes ReassembledMessages to ByteBufs.