io.rsocket.frame

Class RequestStreamFrameFlyweight

java.lang.Object

io.rsocket.frame.RequestStreamFrameFlyweight

public class RequestStreamFrameFlyweight
extends Object

Method Summary

Modifier and Type	Method and Description
static ByteBuf	data(ByteBuf byteBuf)
static ByteBuf	encode(ByteBufAllocator allocator, int streamId, boolean fragmentFollows, int requestN, ByteBuf metadata, ByteBuf data)
static ByteBuf	encode(ByteBufAllocator allocator, int streamId, boolean fragmentFollows, int requestN, Payload payload)
static ByteBuf	encode(ByteBufAllocator allocator, int streamId, boolean fragmentFollows, long requestN, ByteBuf metadata, ByteBuf data)
static ByteBuf	encode(ByteBufAllocator allocator, int streamId, boolean fragmentFollows, long requestN, Payload payload)
static int	initialRequestN(ByteBuf byteBuf)
static ByteBuf	metadata(ByteBuf byteBuf)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

encode

public static ByteBuf encode(ByteBufAllocator allocator,
                             int streamId,
                             boolean fragmentFollows,
                             long requestN,
                             Payload payload)

encode

public static ByteBuf encode(ByteBufAllocator allocator,
                             int streamId,
                             boolean fragmentFollows,
                             int requestN,
                             Payload payload)

encode

public static ByteBuf encode(ByteBufAllocator allocator,
                             int streamId,
                             boolean fragmentFollows,
                             long requestN,
                             ByteBuf metadata,
                             ByteBuf data)

encode

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

data

public static ByteBuf data(ByteBuf byteBuf)

metadata

public static ByteBuf metadata(ByteBuf byteBuf)

initialRequestN

public static int initialRequestN(ByteBuf byteBuf)