rsocket-core 1.1.4 · io.rsocket.frame.FrameHeaderCodec

Per connection frame flyweight.

Not the latest frame layout, but close. Does not include - fragmentation / reassembly - encode should remove Type param and have it as part of method name (1 encode per type?)

Not thread-safe. Assumed to be used single-threaded

Field Summary

Modifier and Type	Field and Description
public static final String	DISABLE_FRAME_TYPE_CHECK
private static boolean	disableFrameTypeCheck
public static final int	FLAGS_C (C)omplete: bit to indicate stream completion (`Subscriber#onComplete()`)
public static final int	FLAGS_F (F)ollows: More fragments follow this fragment (in case of fragmented REQUEST_x or PAYLOAD frames)
public static final int	FLAGS_I (I)gnore flag: a value of 0 indicates the protocol can't ignore this frame
public static final int	FLAGS_M (M)etadata flag: a value of 1 indicates the frame contains metadata
public static final int	FLAGS_N (N)ext: bit to indicate payload or metadata present (`Subscriber#onNext(Object)`)
private static final int	FRAME_FLAGS_MASK
private static final int	FRAME_TYPE_BITS
private static final int	FRAME_TYPE_SHIFT
private static final int	HEADER_SIZE

Constructor Summary

Access	Constructor and Description
private	FrameHeaderCodec()

Method Summary

Modifier and Type	Method and Description
public static ByteBuf	encode(final ByteBufAllocator allocator, final int streamId, final FrameType frameType, int flags)
pack-priv static ByteBuf	encodeStreamZero(final ByteBufAllocator allocator, final FrameType frameType, int flags)
public static void	ensureFrameType(final FrameType frameType, ByteBuf byteBuf)
public static int	flags(final ByteBuf byteBuf)
public static FrameType	frameType(ByteBuf byteBuf)
public static boolean	hasComplete(ByteBuf byteBuf)
public static boolean	hasFollows(ByteBuf byteBuf)
public static boolean	hasMetadata(ByteBuf byteBuf)
public static FrameType	nativeFrameType(ByteBuf byteBuf) faster version of `frameType(ByteBuf)` which does not replace PAYLOAD with synthetic type
public static int	size()
public static int	streamId(ByteBuf byteBuf)

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

Field Detail

DISABLE_FRAME_TYPE_CHECK	back to summary
public static final String DISABLE_FRAME_TYPE_CHECK

disableFrameTypeCheck	back to summary
private static boolean disableFrameTypeCheck

FLAGS_C	back to summary
public static final int FLAGS_C (C)omplete: bit to indicate stream completion (`Subscriber#onComplete()`)

FLAGS_F	back to summary
public static final int FLAGS_F (F)ollows: More fragments follow this fragment (in case of fragmented REQUEST_x or PAYLOAD frames)

FLAGS_I	back to summary
public static final int FLAGS_I (I)gnore flag: a value of 0 indicates the protocol can't ignore this frame

FLAGS_M	back to summary
public static final int FLAGS_M (M)etadata flag: a value of 1 indicates the frame contains metadata

FLAGS_N	back to summary
public static final int FLAGS_N (N)ext: bit to indicate payload or metadata present (`Subscriber#onNext(Object)`)

FRAME_FLAGS_MASK	back to summary
private static final int FRAME_FLAGS_MASK

FRAME_TYPE_BITS	back to summary
private static final int FRAME_TYPE_BITS

FRAME_TYPE_SHIFT	back to summary
private static final int FRAME_TYPE_SHIFT

HEADER_SIZE	back to summary
private static final int HEADER_SIZE

Constructor Detail

FrameHeaderCodec	back to summary
private FrameHeaderCodec()

Method Detail

encode	back to summary
public static ByteBuf encode(final ByteBufAllocator allocator, final int streamId, final FrameType frameType, int flags)

encodeStreamZero	back to summary
pack-priv static ByteBuf encodeStreamZero(final ByteBufAllocator allocator, final FrameType frameType, int flags)

ensureFrameType	back to summary
public static void ensureFrameType(final FrameType frameType, ByteBuf byteBuf)

flags	back to summary
public static int flags(final ByteBuf byteBuf)

frameType	back to summary
public static FrameType frameType(ByteBuf byteBuf)

hasComplete	back to summary
public static boolean hasComplete(ByteBuf byteBuf)

hasFollows	back to summary
public static boolean hasFollows(ByteBuf byteBuf)

hasMetadata	back to summary
public static boolean hasMetadata(ByteBuf byteBuf)

nativeFrameType	back to summary
public static FrameType nativeFrameType(ByteBuf byteBuf) faster version of `frameType(ByteBuf)` which does not replace PAYLOAD with synthetic type

size	back to summary
public static int size()