public interface RSocketRequester
RSocket with a fluent API accepting
and returning higher level Objects for input and for output, along with
methods specify routing and other metadata.| Modifier and Type | Interface and Description |
|---|---|
static interface |
RSocketRequester.Builder
Builder to prepare an
RSocketRequester by connecting to an
RSocket server and wrapping the resulting RSocket. |
static interface |
RSocketRequester.RequestSpec
Contract to provide input data for an RSocket request.
|
static interface |
RSocketRequester.ResponseSpec
Contract to declare the expected RSocket response.
|
| Modifier and Type | Method and Description |
|---|---|
static RSocketRequester.Builder |
builder()
Obtain a builder for an
RSocketRequester by connecting to an
RSocket server. |
static RSocketRequester |
create(io.rsocket.RSocket rsocket,
MimeType dataMimeType,
RSocketStrategies strategies)
Deprecated.
use
wrap(RSocket, MimeType, RSocketStrategies) instead |
RSocketRequester.RequestSpec |
route(String route)
Entry point to prepare a new request to the given route.
|
io.rsocket.RSocket |
rsocket()
Return the underlying RSocket used to make requests.
|
static RSocketRequester |
wrap(io.rsocket.RSocket rsocket,
MimeType dataMimeType,
RSocketStrategies strategies)
Wrap an existing
RSocket. |
io.rsocket.RSocket rsocket()
RSocketRequester.RequestSpec route(String route)
For requestChannel interactions, i.e. Flux-to-Flux the metadata is attached to the first request payload.
route - the routing destinationstatic RSocketRequester.Builder builder()
RSocketRequester by connecting to an
RSocket server. The builder allows for customization of
ClientRSocketFactory settings,
RSocketStrategies, and for selecting the transport to use.static RSocketRequester wrap(io.rsocket.RSocket rsocket, @Nullable MimeType dataMimeType, RSocketStrategies strategies)
RSocket. Typically used in a client or server
responder to wrap the remote RSocket.rsocket - the RSocket to wrapdataMimeType - the data MimeType, obtained from the
ConnectionSetupPayload (server) or the
RSocketFactory.ClientRSocketFactory (client)strategies - the strategies to use@Deprecated static RSocketRequester create(io.rsocket.RSocket rsocket, @Nullable MimeType dataMimeType, RSocketStrategies strategies)
wrap(RSocket, MimeType, RSocketStrategies) insteadRSocketRequester from the given RSocket and
strategies for encoding and decoding request and response payloads.rsocket - the sending RSocket to usedataMimeType - the MimeType for data (from the SETUP frame)strategies - encoders, decoders, and others