Top Fields Constructors Methods

io.rsocket.core

pack-priv Class FragmentationUtils

Class Inheritance

extends Object

java.lang.Object
io.rsocket.core.FragmentationUtils

Imports

io.netty.buffer.ByteBuf, .ByteBufAllocator, .Unpooled, io.netty.util.IllegalReferenceCountException, io.rsocket.frame.FrameHeaderCodec, .FrameLengthCodec, .FrameType, .PayloadFrameCodec, .RequestChannelFrameCodec, .RequestFireAndForgetFrameCodec, .RequestResponseFrameCodec, .RequestStreamFrameCodec, reactor.util.annotation.Nullable

Field Summary

Modifier and Type	Field and Description
pack-priv static final int	FRAME_OFFSET
pack-priv static final int	FRAME_OFFSET_WITH_INITIAL_REQUEST_N
pack-priv static final int	FRAME_OFFSET_WITH_METADATA
pack-priv static final int	FRAME_OFFSET_WITH_METADATA_AND_INITIAL_REQUEST_N
pack-priv static final int	MIN_MTU_SIZE

Constructor Summary

Access	Constructor and Description
pack-priv	FragmentationUtils()

Method Summary

Modifier and Type	Method and Description
pack-priv static int	assertMtu(int mtu)
pack-priv static ByteBuf	encodeFirstFragment(ByteBufAllocator allocator, int mtu, FrameType frameType, int streamId, boolean hasMetadata, ByteBuf metadata, ByteBuf data)
pack-priv static ByteBuf	encodeFirstFragment(ByteBufAllocator allocator, int mtu, long initialRequestN, FrameType frameType, int streamId, boolean hasMetadata, ByteBuf metadata, ByteBuf data)
pack-priv static ByteBuf	encodeFollowsFragment(ByteBufAllocator allocator, int mtu, int streamId, boolean complete, ByteBuf metadata, ByteBuf data)
pack-priv static boolean	isFragmentable(int mtu, ByteBuf data, ByteBuf metadata, boolean hasInitialRequestN)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

FRAME_OFFSET	back to summary
pack-priv static final int FRAME_OFFSET

FRAME_OFFSET_WITH_INITIAL_REQUEST_N	back to summary
pack-priv static final int FRAME_OFFSET_WITH_INITIAL_REQUEST_N

FRAME_OFFSET_WITH_METADATA	back to summary
pack-priv static final int FRAME_OFFSET_WITH_METADATA

FRAME_OFFSET_WITH_METADATA_AND_INITIAL_REQUEST_N	back to summary
pack-priv static final int FRAME_OFFSET_WITH_METADATA_AND_INITIAL_REQUEST_N

MIN_MTU_SIZE	back to summary
pack-priv static final int MIN_MTU_SIZE

Constructor Detail

FragmentationUtils	back to summary
pack-priv FragmentationUtils()

Method Detail

assertMtu	back to summary
pack-priv static int assertMtu(int mtu)

encodeFirstFragment	back to summary
pack-priv static ByteBuf encodeFirstFragment(ByteBufAllocator allocator, int mtu, FrameType frameType, int streamId, boolean hasMetadata, ByteBuf metadata, ByteBuf data)

encodeFirstFragment	back to summary
pack-priv static ByteBuf encodeFirstFragment(ByteBufAllocator allocator, int mtu, long initialRequestN, FrameType frameType, int streamId, boolean hasMetadata, ByteBuf metadata, ByteBuf data)

encodeFollowsFragment	back to summary
pack-priv static ByteBuf encodeFollowsFragment(ByteBufAllocator allocator, int mtu, int streamId, boolean complete, ByteBuf metadata, ByteBuf data)

isFragmentable	back to summary
pack-priv static boolean isFragmentable(int mtu, ByteBuf data, ByteBuf metadata, boolean hasInitialRequestN)