RSocketOG: rename method to prepareRetrieveSpec

artembilan · artembilan · commit 75c9db1b0e90 · 2019-11-25T14:04:42.000-05:00
diff --git a/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/outbound/RSocketOutboundGateway.java b/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/outbound/RSocketOutboundGateway.java
@@ -225,7 +225,7 @@ protected Object handleRequestMessage(Message<?> requestMessage) {
 
 		return requesterMono
 				.map((rSocketRequester) -> createRequestSpec(rSocketRequester, requestMessage))
-				.map((requestSpec) -> prepareRequestSpec(requestSpec, requestMessage))
+				.map((requestSpec) -> prepareRetrieveSpec(requestSpec, requestMessage))
 				.flatMap((responseSpec) -> performRequest(responseSpec, requestMessage));
 	}
 
@@ -248,7 +248,7 @@ private RSocketRequester.RequestSpec createRequestSpec(RSocketRequester rsocketR
 		return requestSpec;
 	}
 
-	private RSocketRequester.RetrieveSpec prepareRequestSpec(RSocketRequester.RequestSpec requestSpec,
+	private RSocketRequester.RetrieveSpec prepareRetrieveSpec(RSocketRequester.RequestSpec requestSpec,
 			Message<?> requestMessage) {
 
 		Object payload = requestMessage.getPayload();

Original file line number	Diff line number	Diff line change
`@@ -225,7 +225,7 @@ protected Object handleRequestMessage(Message<?> requestMessage) {`
`225`	`225`
`226`	`226`	`return requesterMono`
`227`	`227`	`.map((rSocketRequester) -> createRequestSpec(rSocketRequester, requestMessage))`
`228`		`- .map((requestSpec) -> prepareRequestSpec(requestSpec, requestMessage))`
	`228`	`+ .map((requestSpec) -> prepareRetrieveSpec(requestSpec, requestMessage))`
`229`	`229`	`.flatMap((responseSpec) -> performRequest(responseSpec, requestMessage));`
`230`	`230`	`}`
`231`	`231`
`@@ -248,7 +248,7 @@ private RSocketRequester.RequestSpec createRequestSpec(RSocketRequester rsocketR`
`248`	`248`	`return requestSpec;`
`249`	`249`	`}`
`250`	`250`
`251`		`- private RSocketRequester.RetrieveSpec prepareRequestSpec(RSocketRequester.RequestSpec requestSpec,`
	`251`	`+ private RSocketRequester.RetrieveSpec prepareRetrieveSpec(RSocketRequester.RequestSpec requestSpec,`
`252`	`252`	`Message<?> requestMessage) {`
`253`	`253`
`254`	`254`	`Object payload = requestMessage.getPayload();`