public static interface RSocketRequester.Builder
RSocketRequester by connecting to an
RSocket server and wrapping the resulting RSocket.| Modifier and Type | Method and Description |
|---|---|
reactor.core.publisher.Mono<RSocketRequester> |
connect(io.rsocket.transport.ClientTransport transport)
Connect to the RSocket server with the given
ClientTransport. |
reactor.core.publisher.Mono<RSocketRequester> |
connectTcp(String host,
int port)
Connect to the RSocket server over TCP.
|
reactor.core.publisher.Mono<RSocketRequester> |
connectWebSocket(URI uri)
Connect to the RSocket server over WebSocket.
|
RSocketRequester.Builder |
rsocketFactory(Consumer<io.rsocket.RSocketFactory.ClientRSocketFactory> configurer)
Configure the
ClientRSocketFactory. |
RSocketRequester.Builder |
rsocketStrategies(Consumer<RSocketStrategies.Builder> configurer)
Customize the
RSocketStrategies. |
RSocketRequester.Builder |
rsocketStrategies(RSocketStrategies strategies)
Set the
RSocketStrategies instance. |
RSocketRequester.Builder rsocketFactory(Consumer<io.rsocket.RSocketFactory.ClientRSocketFactory> configurer)
ClientRSocketFactory.
Note there is typically no need to set a data MimeType explicitly. By default a data MimeType is picked by taking the first concrete MimeType supported by the configured encoders and decoders.
configurer - the configurer to applyRSocketRequester.Builder rsocketStrategies(@Nullable RSocketStrategies strategies)
RSocketStrategies instance.strategies - the strategies to useRSocketRequester.Builder rsocketStrategies(Consumer<RSocketStrategies.Builder> configurer)
RSocketStrategies.
By default this starts out with an empty builder, i.e.
RSocketStrategies.builder(), but the strategies can also be
set via rsocketStrategies(RSocketStrategies).
configurer - the configurer to applyreactor.core.publisher.Mono<RSocketRequester> connectTcp(String host, int port)
host - the server hostport - the server portRSocketRequester for the connectionreactor.core.publisher.Mono<RSocketRequester> connectWebSocket(URI uri)
uri - the RSocket server endpoint URIRSocketRequester for the connectionreactor.core.publisher.Mono<RSocketRequester> connect(io.rsocket.transport.ClientTransport transport)
ClientTransport.transport - the client transport to useRSocketRequester for the connection