Top Fields Constructors Methods
io.rsocket.core

pack-priv final Class SendUtils

extends Object
Class Inheritance
Static Imports
io.rsocket.core.FragmentationUtils.isFragmentable

Field Summary

Modifier and TypeField and Description
pack-priv static final Context
private static final Consumer<?>

Constructor Summary

AccessConstructor and Description
pack-priv

Method Summary

Modifier and TypeMethod and Description
pack-priv static void
sendReleasingPayload(int streamId, FrameType frameType, int mtu, Payload payload, DuplexConnection connection, ByteBufAllocator allocator, boolean requester)

pack-priv static void
sendReleasingPayload(int streamId, FrameType frameType, long initialRequestN, int mtu, Payload payload, DuplexConnection connection, ByteBufAllocator allocator, boolean complete)

pack-priv static void
sendTerminalFrame(int streamId, FrameType frameType, DuplexConnection connection, ByteBufAllocator allocator, boolean requester, boolean onFollowingFrame, Throwable t)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

DISCARD_CONTEXTback to summary
pack-priv static final Context DISCARD_CONTEXT
DROPPED_ELEMENTS_CONSUMERback to summary
private static final Consumer<?> DROPPED_ELEMENTS_CONSUMER

Constructor Detail

SendUtilsback to summary
pack-priv SendUtils()

Method Detail

sendReleasingPayloadback to summary
pack-priv static void sendReleasingPayload(int streamId, FrameType frameType, int mtu, Payload payload, DuplexConnection connection, ByteBufAllocator allocator, boolean requester)
sendReleasingPayloadback to summary
pack-priv static void sendReleasingPayload(int streamId, FrameType frameType, long initialRequestN, int mtu, Payload payload, DuplexConnection connection, ByteBufAllocator allocator, boolean complete)
sendTerminalFrameback to summary
pack-priv static void sendTerminalFrame(int streamId, FrameType frameType, DuplexConnection connection, ByteBufAllocator allocator, boolean requester, boolean onFollowingFrame, Throwable t)