Top Description Interfaces Classes
[default module]

Package io.rsocket.core

Annotations
@NonNullApi
Imports
reactor.util.annotation.NonNullApi
Contains RSocketConnector and RSocketServer, the main classes for connecting to or starting an RSocket server.

This package also contains a package private classes that implement support for the main RSocket interactions.

Interface Summary

Modifier and TypeInterface and Description
pack-priv interface
FrameHandler

pack-priv interface
Invalidatable

pack-priv interface
LeasePermitHandler

Handler which enables async lease permits issuing

pack-priv interface
RequesterFrameHandler

pack-priv interface
ResponderFrameHandler

public interface
RSocketClient

Contract for performing RSocket requests.

Class Summary

Modifier and TypeClass and Description
pack-priv class
ClientServerInputMultiplexer

DuplexConnection#receive() is a single stream on which the following type of frames arrive:

  • Frames for streams initiated by the initiator of the connection (client).
  • Frames for streams initiated by the acceptor of the connection (server).
pack-priv abstract class
ClientSetup

pack-priv class
DefaultClientSetup

public class
DefaultConnectionSetupPayload

Default implementation of ConnectionSetupPayload.

pack-priv class
DefaultRSocketClient

Default implementation of RSocketClient

pack-priv class
FireAndForgetRequesterMono

pack-priv class
FireAndForgetResponderSubscriber

pack-priv class
FragmentationUtils

public class
LeaseSpec

pack-priv class
LoggingDuplexConnection

pack-priv class
MetadataPushRequesterMono

pack-priv class
MetadataPushResponderSubscriber

pack-priv class
PayloadValidationUtils

pack-priv class
ReassemblyUtils

pack-priv class
ReconnectMono<T>

pack-priv class
RequestChannelRequesterFlux

pack-priv class
RequestChannelResponderSubscriber

pack-priv class
RequesterLeaseTracker

pack-priv class
RequesterResponderSupport

pack-priv class
RequestResponseRequesterMono

pack-priv class
RequestResponseResponderSubscriber

pack-priv class
RequestStreamRequesterFlux

pack-priv class
RequestStreamResponderSubscriber

pack-priv class
ResolvingOperator<T>

pack-priv class
ResponderLeaseTracker

pack-priv class
ResumableClientSetup

public class
Resume

Simple holder of configuration settings for the RSocket Resume capability.

pack-priv class
RSocketClientAdapter

Simple adapter from RSocket to RSocketClient.

public class
RSocketConnector

The main class to use to establish a connection to an RSocket server.

pack-priv class
RSocketRequester

Requester Side of a RSocket socket.

pack-priv class
RSocketResponder

Responder side of RSocket.

public class
RSocketServer

The main class for starting an RSocket server.

pack-priv class
SendUtils

pack-priv abstract class
ServerSetup

pack-priv class
SetupHandlingDuplexConnection

pack-priv class
SlowFireAndForgetRequesterMono

pack-priv class
StateUtils

pack-priv class
StreamIdSupplier

This API is not thread-safe and must be strictly used in serialized fashion