Top Constructors Methods
io.rsocket.frame

public Class PayloadFrameCodec

extends Object
Class Inheritance
Imports
io.netty.buffer.ByteBuf, .ByteBufAllocator, io.rsocket.Payload, reactor.util.annotation.Nullable

Constructor Summary

AccessConstructor and Description
private

Method Summary

Modifier and TypeMethod and Description
public static ByteBuf
data(ByteBuf byteBuf)

public static ByteBuf
encode(ByteBufAllocator allocator, int streamId, boolean fragmentFollows, boolean complete, boolean next, ByteBuf metadata, ByteBuf data)

public static ByteBuf
encodeComplete(ByteBufAllocator allocator, int streamId)

public static ByteBuf
public static ByteBuf
encodeNextReleasingPayload(ByteBufAllocator allocator, int streamId, Payload payload)

pack-priv static ByteBuf
encodeReleasingPayload(ByteBufAllocator allocator, int streamId, boolean complete, Payload payload)

public static ByteBuf
metadata(ByteBuf byteBuf)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Constructor Detail

PayloadFrameCodecback to summary
private PayloadFrameCodec()

Method Detail

databack to summary
public static ByteBuf data(ByteBuf byteBuf)
encodeback to summary
public static ByteBuf encode(ByteBufAllocator allocator, int streamId, boolean fragmentFollows, boolean complete, boolean next, ByteBuf metadata, ByteBuf data)
encodeCompleteback to summary
public static ByteBuf encodeComplete(ByteBufAllocator allocator, int streamId)
encodeNextCompleteReleasingPayloadback to summary
public static ByteBuf encodeNextCompleteReleasingPayload(ByteBufAllocator allocator, int streamId, Payload payload)
encodeNextReleasingPayloadback to summary
public static ByteBuf encodeNextReleasingPayload(ByteBufAllocator allocator, int streamId, Payload payload)
encodeReleasingPayloadback to summary
pack-priv static ByteBuf encodeReleasingPayload(ByteBufAllocator allocator, int streamId, boolean complete, Payload payload)
metadataback to summary
public static ByteBuf metadata(ByteBuf byteBuf)
Annotations
@Nullable