Interface | Description |
---|---|
RSocketRequester |
A thin wrapper around a sending
RSocket with a fluent API accepting
and returning higher level Objects for input and for output, along with
methods specify routing and other metadata. |
RSocketRequester.RequestSpec |
Contract to provide input data for an RSocket request.
|
RSocketRequester.ResponseSpec |
Contract to declare the expected RSocket response.
|
RSocketStrategies |
Access to strategies for use by RSocket requester and responder components.
|
RSocketStrategies.Builder |
The builder options for creating
RSocketStrategies . |
Class | Description |
---|---|
DefaultRSocketRequester |
Default, package-private
RSocketRequester implementation. |
DefaultRSocketStrategies |
Default, package-private
RSocketStrategies implementation. |
DefaultRSocketStrategies.DefaultRSocketStrategiesBuilder |
Default RSocketStrategies.Builder implementation.
|
MessageHandlerAcceptor |
Extension of
RSocketMessageHandler that can be plugged directly into
RSocket to receive connections either on the
client or on the
server
side. |
MessagingRSocket |
Implementation of
RSocket that wraps incoming requests with a
Message , delegates to a Function for handling, and then
obtains the response from a "reply" header. |
PayloadUtils |
Static utility methods to create
Payload from DataBuffer s
and vice versa. |
RSocketMessageHandler |
RSocket-specific extension of
MessageMappingMessageHandler . |
RSocketPayloadReturnValueHandler |
Extension of
AbstractEncoderMethodReturnValueHandler that
handles encoded content by wrapping data buffers
as RSocket payloads and by passing those to the MonoProcessor
from the RSocketPayloadReturnValueHandler.RESPONSE_HEADER header. |
RSocketRequesterMethodArgumentResolver |
Resolves arguments of type
RSocket that can be used for making
requests to the remote peer. |