Introduce ClientRSocketConnector.getRequester()

* Restore `Mono<RSocketRequester> getRSocketRequester()` on
`ClientRSocketConnector` and deprecate it in favor of newly introduced
`RSocketRequester getRequester()`: there is no need in wrapping a
`RSocketRequester` to deferred `Mono` since internal logic of the
`RSocketRequester` on client side is based on lazy-load API of the
`RSocketClient`

Author: artembilan

spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/ClientRSocketConnector.java

@@ -29,6 +29,7 @@
 import io.rsocket.transport.ClientTransport;
 import io.rsocket.transport.netty.client.TcpClientTransport;
 import io.rsocket.transport.netty.client.WebsocketClientTransport;
+import reactor.core.publisher.Mono;
 
 /**
  * A client {@link AbstractRSocketConnector} extension to the RSocket connection.
@@ -210,7 +211,22 @@ public void connect() {
 		this.rsocketRequester.rsocketClient().source().subscribe();
 	}
 
-	public RSocketRequester getRSocketRequester() {
+	/**
+	 * Return the {@link Mono} for the {@link RSocketRequester}.
+	 * @return the {@link Mono} for the {@link RSocketRequester}.
+	 * @deprecated since 5.4 in favor of {@link #getRequester()}
+	 */
+	@Deprecated
+	public Mono<RSocketRequester> getRSocketRequester() {
+		return Mono.just(getRequester());
+	}
+
+	/**
+	 * Return the {@link RSocketRequester} this connector is built on.
+	 * @return the {@link RSocketRequester} this connector is built on.
+	 * @since 5.4
+	 */
+	public RSocketRequester getRequester() {
 		return this.rsocketRequester;
 	}
 

spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/dsl/RSocketOutboundGatewaySpec.java

@@ -48,7 +48,7 @@ protected RSocketOutboundGatewaySpec(Expression routeExpression) {
 
 	/**
 	 * Configure a {@link ClientRSocketConnector} for client side requests based on the connection
-	 * provided by the {@link ClientRSocketConnector#getRSocketRequester()}.
+	 * provided by the {@link ClientRSocketConnector#getRequester()}.
 	 * @param clientRSocketConnector the {@link ClientRSocketConnector} to use.
 	 * @return the spec
 	 * @see RSocketOutboundGateway#setClientRSocketConnector(ClientRSocketConnector)

spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/outbound/RSocketOutboundGateway.java

@@ -120,7 +120,7 @@ public RSocketOutboundGateway(Expression routeExpression) {
 
 	/**
 	 * Configure a {@link ClientRSocketConnector} for client side requests based on the connection
-	 * provided by the {@link ClientRSocketConnector#getRSocketRequester()}.
+	 * provided by the {@link ClientRSocketConnector#getRequester()}.
 	 * In case of server side, an {@link RSocketRequester} must be provided in the
 	 * {@link RSocketRequesterMethodArgumentResolver#RSOCKET_REQUESTER_HEADER} header of request message.
 	 * @param clientRSocketConnector the {@link ClientRSocketConnector} to use.
@@ -207,7 +207,7 @@ protected void doInit() {
 		super.doInit();
 		this.evaluationContext = ExpressionUtils.createStandardEvaluationContext(getBeanFactory());
 		if (this.clientRSocketConnector != null) {
-			this.rsocketRequester = this.clientRSocketConnector.getRSocketRequester();
+			this.rsocketRequester = this.clientRSocketConnector.getRequester();
 		}
 	}
 

spring-integration-rsocket/src/test/java/org/springframework/integration/rsocket/inbound/RSocketInboundGatewayIntegrationTests.java

@@ -96,8 +96,7 @@ void setupTest(TestInfo testInfo) {
 			this.serverRsocketRequester = serverConfig.clientRequester.asMono().block(Duration.ofSeconds(10));
 		}
 		else {
-			this.clientRsocketRequester =
-					this.clientRSocketConnector.getRSocketRequester();
+			this.clientRsocketRequester = this.clientRSocketConnector.getRequester();
 		}
 	}