Skip to content

Commit 4f44bee

Browse files
Fix language in docs
Co-authored-by: Gary Russell <[email protected]>
1 parent 997ec06 commit 4f44bee

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

spring-integration-core/src/main/java/org/springframework/integration/handler/support/MessagingMethodInvokerHelper.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -488,7 +488,7 @@ private Object processInternal(ParametersWrapper parameters) {
488488

489489
private synchronized void initialize() {
490490
if (isProvidedMessageHandlerFactoryBean()) {
491-
LOGGER.trace("Overriding default instance of MessageHandlerMethodFactory with provided one.");
491+
LOGGER.trace("Overriding default instance of MessageHandlerMethodFactory with the one provided.");
492492
this.messageHandlerMethodFactory =
493493
getBeanFactory()
494494
.getBean(

src/reference/asciidoc/kotlin-functions.adoc

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ fun kotlinSupplier(): () -> String {
3131
==== Kotlin Coroutines
3232

3333
Starting with version 6.0, Spring Integration provides support for https://kotlinlang.org/docs/coroutines-guide.html[Kotlin Coroutines].
34-
Now the `suspend` functions and `kotlinx.coroutines.Deferred` & `kotlinx.coroutines.flow.Flow` return types can be used for service methods:
34+
Now `suspend` functions and `kotlinx.coroutines.Deferred` & `kotlinx.coroutines.flow.Flow` return types can be used for service methods:
3535

3636
====
3737
[source, kotlin]
@@ -53,10 +53,10 @@ The framework treats them as Reactive Streams interactions and uses `ReactiveAda
5353
Such a function reply is processed then in the reply channel, if it is a `ReactiveStreamsSubscribableChannel`, or as a result of `CompletableFuture` in the respective callback.
5454

5555
NOTE: The functions with `Flow` result are not `async` by default on the `@ServiceActivator`, so `Flow` instance is produced as a reply message payload.
56-
It is already target application to process this object as a coroutine or convert it to `Flux`, respectively.
56+
It is the target application's responsibility to process this object as a coroutine or convert it to `Flux`, respectively.
5757

5858
The `@MessagingGateway` interface methods also can be marked with a `suspend` modifier when declared in Kotlin.
59-
The framework utilizes a `Mono` logic internally to perform request-reply for downstream flow.
59+
The framework utilizes a `Mono` internally to perform request-reply using the downstream flow.
6060
Such a `Mono` result is processed by the `MonoKt.awaitSingleOrNull()` API internally to fulfil a `kotlin.coroutines.Continuation` argument fo the called `suspend` function of the gateway:
6161

6262
====

0 commit comments

Comments
 (0)