Top Fields Constructors Methods

io.rsocket.frame

public Class SetupFrameCodec

Class Inheritance

extends Object

java.lang.Object
io.rsocket.frame.SetupFrameCodec

Imports

io.netty.buffer.ByteBuf, .ByteBufAllocator, .ByteBufUtil, .Unpooled, io.rsocket.Payload, java.nio.charset.StandardCharsets, reactor.util.annotation.Nullable

Field Summary

Modifier and Type	Field and Description
public static final int	CURRENT_VERSION
public static final int	FLAGS_RESUME_ENABLE A flag used to indicate that the client requires connection resumption, if possible (the frame contains a Resume Identification Token)
public static final int	FLAGS_WILL_HONOR_LEASE A flag used to indicate that the client will honor LEASE sent by the server
private static final int	KEEPALIVE_INTERVAL_FIELD_OFFSET
private static final int	KEEPALIVE_MAX_LIFETIME_FIELD_OFFSET
private static final int	VARIABLE_DATA_OFFSET
private static final int	VERSION_FIELD_OFFSET

Constructor Summary

Access	Constructor and Description
public	SetupFrameCodec()

Method Summary

Modifier and Type	Method and Description
private static int	bytesToSkipToMimeType(ByteBuf byteBuf)
public static ByteBuf	data(ByteBuf byteBuf)
public static String	dataMimeType(ByteBuf byteBuf)
public static ByteBuf	encode(final ByteBufAllocator allocator, final boolean lease, final int keepaliveInterval, final int maxLifetime, final String metadataMimeType, final String dataMimeType, final Payload setupPayload)
public static ByteBuf	encode(final ByteBufAllocator allocator, final boolean lease, final int keepaliveInterval, final int maxLifetime, final ByteBuf resumeToken, final String metadataMimeType, final String dataMimeType, final Payload setupPayload)
public static boolean	honorLease(ByteBuf byteBuf)
public static String	humanReadableVersion(ByteBuf byteBuf)
public static boolean	isSupportedVersion(ByteBuf byteBuf)
public static int	keepAliveInterval(ByteBuf byteBuf)
public static int	keepAliveMaxLifetime(ByteBuf byteBuf)
public static ByteBuf	metadata(ByteBuf byteBuf)
public static String	metadataMimeType(ByteBuf byteBuf)
public static boolean	resumeEnabled(ByteBuf byteBuf)
public static ByteBuf	resumeToken(ByteBuf byteBuf)
public static int	resumeTokenLength(ByteBuf byteBuf)
private static void	skipToPayload(ByteBuf byteBuf)
public static int	version(ByteBuf byteBuf)

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

Field Detail

CURRENT_VERSION	back to summary
public static final int CURRENT_VERSION

FLAGS_RESUME_ENABLE	back to summary
public static final int FLAGS_RESUME_ENABLE A flag used to indicate that the client requires connection resumption, if possible (the frame contains a Resume Identification Token)

FLAGS_WILL_HONOR_LEASE	back to summary
public static final int FLAGS_WILL_HONOR_LEASE A flag used to indicate that the client will honor LEASE sent by the server

KEEPALIVE_INTERVAL_FIELD_OFFSET	back to summary
private static final int KEEPALIVE_INTERVAL_FIELD_OFFSET

KEEPALIVE_MAX_LIFETIME_FIELD_OFFSET	back to summary
private static final int KEEPALIVE_MAX_LIFETIME_FIELD_OFFSET

VARIABLE_DATA_OFFSET	back to summary
private static final int VARIABLE_DATA_OFFSET

VERSION_FIELD_OFFSET	back to summary
private static final int VERSION_FIELD_OFFSET

Constructor Detail

SetupFrameCodec	back to summary
public SetupFrameCodec()

Method Detail

bytesToSkipToMimeType	back to summary
private static int bytesToSkipToMimeType(ByteBuf byteBuf)

data	back to summary
public static ByteBuf data(ByteBuf byteBuf)

dataMimeType	back to summary
public static String dataMimeType(ByteBuf byteBuf)

encode	back to summary
public static ByteBuf encode(final ByteBufAllocator allocator, final boolean lease, final int keepaliveInterval, final int maxLifetime, final String metadataMimeType, final String dataMimeType, final Payload setupPayload)

encode	back to summary
public static ByteBuf encode(final ByteBufAllocator allocator, final boolean lease, final int keepaliveInterval, final int maxLifetime, final ByteBuf resumeToken, final String metadataMimeType, final String dataMimeType, final Payload setupPayload)

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

humanReadableVersion	back to summary
public static String humanReadableVersion(ByteBuf byteBuf)

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

keepAliveInterval	back to summary
public static int keepAliveInterval(ByteBuf byteBuf)

keepAliveMaxLifetime	back to summary
public static int keepAliveMaxLifetime(ByteBuf byteBuf)

metadata	back to summary
public static ByteBuf metadata(ByteBuf byteBuf) Annotations @Nullable

metadataMimeType	back to summary
public static String metadataMimeType(ByteBuf byteBuf)

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

resumeToken	back to summary
public static ByteBuf resumeToken(ByteBuf byteBuf)

resumeTokenLength	back to summary
public static int resumeTokenLength(ByteBuf byteBuf)

skipToPayload	back to summary
private static void skipToPayload(ByteBuf byteBuf)

version	back to summary
public static int version(ByteBuf byteBuf)